forked from TrueCloudLab/frostfs-api-go
v2/object: Implement uni-structures for ObjectService
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
parent
d4336d8d5b
commit
7a55865f74
3 changed files with 2688 additions and 41 deletions
1228
v2/object/convert.go
1228
v2/object/convert.go
File diff suppressed because it is too large
Load diff
|
@ -61,6 +61,22 @@ func (m *GetResponse_Body_Init) SetHeader(v *Header) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetChunk returns chunk of the object payload bytes.
|
||||||
|
func (m *GetResponse_Body_Chunk) GetChunk() []byte {
|
||||||
|
if m != nil {
|
||||||
|
return m.Chunk
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetChunk sets chunk of the object payload bytes.
|
||||||
|
func (m *GetResponse_Body_Chunk) SetChunk(v []byte) {
|
||||||
|
if m != nil {
|
||||||
|
m.Chunk = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// SetInit sets initial part of the object.
|
// SetInit sets initial part of the object.
|
||||||
func (m *GetResponse_Body) SetInit(v *GetResponse_Body_Init) {
|
func (m *GetResponse_Body) SetInit(v *GetResponse_Body_Init) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
|
@ -70,12 +86,10 @@ func (m *GetResponse_Body) SetInit(v *GetResponse_Body_Init) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetChunk sets chunk of the object payload bytes.
|
// SetChunk sets part of the object payload.
|
||||||
func (m *GetResponse_Body) SetChunk(v []byte) {
|
func (m *GetResponse_Body) SetChunk(v *GetResponse_Body_Chunk) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.ObjectPart = &GetResponse_Body_Chunk{
|
m.ObjectPart = v
|
||||||
Chunk: v,
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -128,6 +142,22 @@ func (m *PutRequest_Body_Init) SetCopiesNumber(v uint32) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetChunk returns chunk of the object payload bytes.
|
||||||
|
func (m *PutRequest_Body_Chunk) GetChunk() []byte {
|
||||||
|
if m != nil {
|
||||||
|
return m.Chunk
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetChunk sets chunk of the object payload bytes.
|
||||||
|
func (m *PutRequest_Body_Chunk) SetChunk(v []byte) {
|
||||||
|
if m != nil {
|
||||||
|
m.Chunk = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// SetInit sets initial part of the object.
|
// SetInit sets initial part of the object.
|
||||||
func (m *PutRequest_Body) SetInit(v *PutRequest_Body_Init) {
|
func (m *PutRequest_Body) SetInit(v *PutRequest_Body_Init) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
|
@ -137,12 +167,10 @@ func (m *PutRequest_Body) SetInit(v *PutRequest_Body_Init) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetChunk sets chunk of the object paloyad bytes.
|
// SetChunk sets part of the object payload.
|
||||||
func (m *PutRequest_Body) SetChunk(v []byte) {
|
func (m *PutRequest_Body) SetChunk(v *PutRequest_Body_Chunk) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.ObjectPart = &PutRequest_Body_Chunk{
|
m.ObjectPart = v
|
||||||
Chunk: v,
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -251,8 +279,8 @@ func (m *DeleteResponse) SetVerifyHeader(v *service.ResponseVerificationHeader)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetOwnerId sets identifier of the object with the requested header.
|
// SetAddress sets address of the object with the requested header.
|
||||||
func (m *HeadRequest_Body) SetOwnerId(v *refs.Address) {
|
func (m *HeadRequest_Body) SetAddress(v *refs.Address) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.Address = v
|
m.Address = v
|
||||||
}
|
}
|
||||||
|
@ -293,47 +321,42 @@ func (m *HeadRequest) SetVerifyHeader(v *service.RequestVerificationHeader) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetVersion sets version of the object format.
|
// GetShortHeader returns short header of the object.
|
||||||
func (m *HeadResponse_Body_ShortHeader) SetVersion(v *service.Version) {
|
func (m *HeadResponse_Body_ShortHeader) GetShortHeader() *ShortHeader {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.ShortHeader.Version = v
|
return m.ShortHeader
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetShortHeader sets short header of the object.
|
||||||
|
func (m *HeadResponse_Body_ShortHeader) SetShortHeader(v *ShortHeader) {
|
||||||
|
if m != nil {
|
||||||
|
m.ShortHeader = v
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetCreationEpoch sets creation epoch number of the object.
|
// GetHeader returns object header.
|
||||||
func (m *HeadResponse_Body_ShortHeader) SetCreationEpoch(v uint64) {
|
func (m *HeadResponse_Body_Header) GetHeader() *Header {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.ShortHeader.CreationEpoch = v
|
return m.Header
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetOwnerId sets identifier of the object owner.
|
return nil
|
||||||
func (m *HeadResponse_Body_ShortHeader) SetOwnerId(v *refs.OwnerID) {
|
|
||||||
if m != nil {
|
|
||||||
m.ShortHeader.OwnerId = v
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetObjectType sets type of the object.
|
// SetHeader sets object header.
|
||||||
func (m *HeadResponse_Body_ShortHeader) SetObjectType(v ObjectType) {
|
func (m *HeadResponse_Body_Header) SetHeader(v *Header) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.ShortHeader.ObjectType = v
|
m.Header = v
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetPayloadLength sets length of the object payload.
|
|
||||||
func (m *HeadResponse_Body_ShortHeader) SetPayloadLength(v uint64) {
|
|
||||||
if m != nil {
|
|
||||||
m.ShortHeader.PayloadLength = v
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetHeader sets full header of the object.
|
// SetHeader sets full header of the object.
|
||||||
func (m *HeadResponse_Body) SetHeader(v *Header) {
|
func (m *HeadResponse_Body) SetHeader(v *HeadResponse_Body_Header) {
|
||||||
if m != nil {
|
if m != nil {
|
||||||
m.Head = &HeadResponse_Body_Header{
|
m.Head = v
|
||||||
Header: v,
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -574,3 +597,31 @@ func (m *GetRangeHashRequest) SetVerifyHeader(v *service.RequestVerificationHead
|
||||||
m.VerifyHeader = v
|
m.VerifyHeader = v
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// SetHashList returns list of the range hashes.
|
||||||
|
func (m *GetRangeHashResponse_Body) SetHashList(v [][]byte) {
|
||||||
|
if m != nil {
|
||||||
|
m.HashList = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetBody sets body of the response.
|
||||||
|
func (m *GetRangeHashResponse) SetBody(v *GetRangeHashResponse_Body) {
|
||||||
|
if m != nil {
|
||||||
|
m.Body = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetMetaHeader sets meta header of the response.
|
||||||
|
func (m *GetRangeHashResponse) SetMetaHeader(v *service.ResponseMetaHeader) {
|
||||||
|
if m != nil {
|
||||||
|
m.MetaHeader = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// SetVerifyHeader sets verification header of the response.
|
||||||
|
func (m *GetRangeHashResponse) SetVerifyHeader(v *service.ResponseVerificationHeader) {
|
||||||
|
if m != nil {
|
||||||
|
m.VerifyHeader = v
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
1372
v2/object/types.go
1372
v2/object/types.go
File diff suppressed because it is too large
Load diff
Loading…
Reference in a new issue