forked from TrueCloudLab/frostfs-api-go
[#95] *: Regenerate proto files
Remove SetExtendedEACL and AnnounceUsedSpace methods from the container package. Signed-off-by: Evgenii Stratonikov <e.stratonikov@yadro.com>
This commit is contained in:
parent
f517e39491
commit
3dfa2f4fd6
31 changed files with 238 additions and 2006 deletions
2
accounting/grpc/service.pb.go
generated
2
accounting/grpc/service.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: accounting/grpc/service.proto
|
// source: accounting/grpc/service.proto
|
||||||
|
|
||||||
package accounting
|
package accounting
|
||||||
|
|
2
accounting/grpc/service_grpc.pb.go
generated
2
accounting/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: accounting/grpc/service.proto
|
// source: accounting/grpc/service.proto
|
||||||
|
|
||||||
package accounting
|
package accounting
|
||||||
|
|
2
accounting/grpc/types.pb.go
generated
2
accounting/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: accounting/grpc/types.proto
|
// source: accounting/grpc/types.proto
|
||||||
|
|
||||||
package accounting
|
package accounting
|
||||||
|
|
14
acl/grpc/types.pb.go
generated
14
acl/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: acl/grpc/types.proto
|
// source: acl/grpc/types.proto
|
||||||
|
|
||||||
package acl
|
package acl
|
||||||
|
@ -709,7 +709,8 @@ type BearerToken_Body struct {
|
||||||
// valid for this specific container. Otherwise, any container of the same
|
// valid for this specific container. Otherwise, any container of the same
|
||||||
// owner is allowed.
|
// owner is allowed.
|
||||||
//
|
//
|
||||||
// Deprecated: eACL tables are no longer relevant - `APEOverrides` should be used instead.
|
// Deprecated: eACL tables are no longer relevant - `APEOverrides` should be
|
||||||
|
// used instead.
|
||||||
EaclTable *EACLTable `protobuf:"bytes,1,opt,name=eacl_table,json=eaclTable,proto3" json:"eacl_table,omitempty"`
|
EaclTable *EACLTable `protobuf:"bytes,1,opt,name=eacl_table,json=eaclTable,proto3" json:"eacl_table,omitempty"`
|
||||||
// `OwnerID` defines to whom the token was issued. It must match the request
|
// `OwnerID` defines to whom the token was issued. It must match the request
|
||||||
// originator's `OwnerID`. If empty, any token bearer will be accepted.
|
// originator's `OwnerID`. If empty, any token bearer will be accepted.
|
||||||
|
@ -859,11 +860,12 @@ func (x *BearerToken_Body_TokenLifetime) GetIat() uint64 {
|
||||||
}
|
}
|
||||||
|
|
||||||
// APEOverride is the list of APE chains defined for a target.
|
// APEOverride is the list of APE chains defined for a target.
|
||||||
// These chains are meant to serve as overrides to the already defined (or even undefined)
|
// These chains are meant to serve as overrides to the already defined (or
|
||||||
// APE chains for the target (see contract `Policy`).
|
// even undefined) APE chains for the target (see contract `Policy`).
|
||||||
//
|
//
|
||||||
// The server-side processing of the bearer token with set APE overrides must verify if a client is permitted
|
// The server-side processing of the bearer token with set APE overrides
|
||||||
// to override chains for the target, preventing unauthorized access through the APE mechanism.
|
// must verify if a client is permitted to override chains for the target,
|
||||||
|
// preventing unauthorized access through the APE mechanism.
|
||||||
type BearerToken_Body_APEOverride struct {
|
type BearerToken_Body_APEOverride struct {
|
||||||
state protoimpl.MessageState
|
state protoimpl.MessageState
|
||||||
sizeCache protoimpl.SizeCache
|
sizeCache protoimpl.SizeCache
|
||||||
|
|
2
ape/grpc/types.pb.go
generated
2
ape/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: ape/grpc/types.proto
|
// source: ape/grpc/types.proto
|
||||||
|
|
||||||
package ape
|
package ape
|
||||||
|
|
2
apemanager/grpc/service.pb.go
generated
2
apemanager/grpc/service.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: apemanager/grpc/service.proto
|
// source: apemanager/grpc/service.proto
|
||||||
|
|
||||||
package apemanager
|
package apemanager
|
||||||
|
|
2
apemanager/grpc/service_grpc.pb.go
generated
2
apemanager/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: apemanager/grpc/service.proto
|
// source: apemanager/grpc/service.proto
|
||||||
|
|
||||||
package apemanager
|
package apemanager
|
||||||
|
|
|
@ -767,151 +767,6 @@ func (r *ListResponse) FromGRPCMessage(m grpc.Message) error {
|
||||||
return r.ResponseHeaders.FromMessage(v)
|
return r.ResponseHeaders.FromMessage(v)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.SetExtendedACLRequest_Body
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.SetExtendedACLRequest_Body)
|
|
||||||
|
|
||||||
m.SetEacl(r.eacl.ToGRPCMessage().(*aclGRPC.EACLTable))
|
|
||||||
m.SetSignature(toSignatureRFC6979(r.sig))
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.SetExtendedACLRequest_Body)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
eacl := v.GetEacl()
|
|
||||||
if eacl == nil {
|
|
||||||
r.eacl = nil
|
|
||||||
} else {
|
|
||||||
if r.eacl == nil {
|
|
||||||
r.eacl = new(acl.Table)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = r.eacl.FromGRPCMessage(eacl)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
sig := v.GetSignature()
|
|
||||||
if sig == nil {
|
|
||||||
r.sig = nil
|
|
||||||
} else {
|
|
||||||
if r.sig == nil {
|
|
||||||
r.sig = new(refs.Signature)
|
|
||||||
}
|
|
||||||
|
|
||||||
r.sig.SetKey(sig.GetKey())
|
|
||||||
r.sig.SetSign(sig.GetSign())
|
|
||||||
}
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequest) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.SetExtendedACLRequest
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.SetExtendedACLRequest)
|
|
||||||
|
|
||||||
m.SetBody(r.body.ToGRPCMessage().(*container.SetExtendedACLRequest_Body))
|
|
||||||
r.RequestHeaders.ToMessage(m)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequest) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.SetExtendedACLRequest)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
body := v.GetBody()
|
|
||||||
if body == nil {
|
|
||||||
r.body = nil
|
|
||||||
} else {
|
|
||||||
if r.body == nil {
|
|
||||||
r.body = new(SetExtendedACLRequestBody)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = r.body.FromGRPCMessage(body)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.RequestHeaders.FromMessage(v)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponseBody) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.SetExtendedACLResponse_Body
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.SetExtendedACLResponse_Body)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponseBody) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.SetExtendedACLResponse_Body)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponse) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.SetExtendedACLResponse
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.SetExtendedACLResponse)
|
|
||||||
|
|
||||||
m.SetBody(r.body.ToGRPCMessage().(*container.SetExtendedACLResponse_Body))
|
|
||||||
r.ResponseHeaders.ToMessage(m)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponse) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.SetExtendedACLResponse)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
body := v.GetBody()
|
|
||||||
if body == nil {
|
|
||||||
r.body = nil
|
|
||||||
} else {
|
|
||||||
if r.body == nil {
|
|
||||||
r.body = new(SetExtendedACLResponseBody)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = r.body.FromGRPCMessage(body)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.ResponseHeaders.FromMessage(v)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *GetExtendedACLRequestBody) ToGRPCMessage() grpc.Message {
|
func (r *GetExtendedACLRequestBody) ToGRPCMessage() grpc.Message {
|
||||||
var m *container.GetExtendedACLRequest_Body
|
var m *container.GetExtendedACLRequest_Body
|
||||||
|
|
||||||
|
@ -1083,198 +938,3 @@ func (r *GetExtendedACLResponse) FromGRPCMessage(m grpc.Message) error {
|
||||||
|
|
||||||
return r.ResponseHeaders.FromMessage(v)
|
return r.ResponseHeaders.FromMessage(v)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.AnnounceUsedSpaceRequest_Body_Announcement
|
|
||||||
|
|
||||||
if a != nil {
|
|
||||||
m = new(container.AnnounceUsedSpaceRequest_Body_Announcement)
|
|
||||||
|
|
||||||
m.SetContainerId(a.cid.ToGRPCMessage().(*refsGRPC.ContainerID))
|
|
||||||
m.SetEpoch(a.epoch)
|
|
||||||
m.SetUsedSpace(a.usedSpace)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.AnnounceUsedSpaceRequest_Body_Announcement)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
cid := v.GetContainerId()
|
|
||||||
if cid == nil {
|
|
||||||
a.cid = nil
|
|
||||||
} else {
|
|
||||||
if a.cid == nil {
|
|
||||||
a.cid = new(refs.ContainerID)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = a.cid.FromGRPCMessage(cid)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
a.epoch = v.GetEpoch()
|
|
||||||
a.usedSpace = v.GetUsedSpace()
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func UsedSpaceAnnouncementsToGRPCMessage(
|
|
||||||
ids []UsedSpaceAnnouncement,
|
|
||||||
) (res []*container.AnnounceUsedSpaceRequest_Body_Announcement) {
|
|
||||||
if ids != nil {
|
|
||||||
res = make([]*container.AnnounceUsedSpaceRequest_Body_Announcement, 0, len(ids))
|
|
||||||
|
|
||||||
for i := range ids {
|
|
||||||
res = append(res, ids[i].ToGRPCMessage().(*container.AnnounceUsedSpaceRequest_Body_Announcement))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func UsedSpaceAnnouncementssFromGRPCMessage(
|
|
||||||
asV2 []*container.AnnounceUsedSpaceRequest_Body_Announcement,
|
|
||||||
) (res []UsedSpaceAnnouncement, err error) {
|
|
||||||
if asV2 != nil {
|
|
||||||
res = make([]UsedSpaceAnnouncement, len(asV2))
|
|
||||||
|
|
||||||
for i := range asV2 {
|
|
||||||
if asV2[i] != nil {
|
|
||||||
err = res[i].FromGRPCMessage(asV2[i])
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.AnnounceUsedSpaceRequest_Body
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.AnnounceUsedSpaceRequest_Body)
|
|
||||||
|
|
||||||
m.SetAnnouncements(UsedSpaceAnnouncementsToGRPCMessage(r.announcements))
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.AnnounceUsedSpaceRequest_Body)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
r.announcements, err = UsedSpaceAnnouncementssFromGRPCMessage(v.GetAnnouncements())
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequest) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.AnnounceUsedSpaceRequest
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.AnnounceUsedSpaceRequest)
|
|
||||||
|
|
||||||
m.SetBody(r.body.ToGRPCMessage().(*container.AnnounceUsedSpaceRequest_Body))
|
|
||||||
r.RequestHeaders.ToMessage(m)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequest) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.AnnounceUsedSpaceRequest)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
body := v.GetBody()
|
|
||||||
if body == nil {
|
|
||||||
r.body = nil
|
|
||||||
} else {
|
|
||||||
if r.body == nil {
|
|
||||||
r.body = new(AnnounceUsedSpaceRequestBody)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = r.body.FromGRPCMessage(body)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.RequestHeaders.FromMessage(v)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponseBody) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.AnnounceUsedSpaceResponse_Body
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.AnnounceUsedSpaceResponse_Body)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponseBody) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.AnnounceUsedSpaceResponse_Body)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponse) ToGRPCMessage() grpc.Message {
|
|
||||||
var m *container.AnnounceUsedSpaceResponse
|
|
||||||
|
|
||||||
if r != nil {
|
|
||||||
m = new(container.AnnounceUsedSpaceResponse)
|
|
||||||
|
|
||||||
m.SetBody(r.body.ToGRPCMessage().(*container.AnnounceUsedSpaceResponse_Body))
|
|
||||||
r.ResponseHeaders.ToMessage(m)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponse) FromGRPCMessage(m grpc.Message) error {
|
|
||||||
v, ok := m.(*container.AnnounceUsedSpaceResponse)
|
|
||||||
if !ok {
|
|
||||||
return message.NewUnexpectedMessageType(m, v)
|
|
||||||
}
|
|
||||||
|
|
||||||
var err error
|
|
||||||
|
|
||||||
body := v.GetBody()
|
|
||||||
if body == nil {
|
|
||||||
r.body = nil
|
|
||||||
} else {
|
|
||||||
if r.body == nil {
|
|
||||||
r.body = new(AnnounceUsedSpaceResponseBody)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = r.body.FromGRPCMessage(body)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.ResponseHeaders.FromMessage(v)
|
|
||||||
}
|
|
||||||
|
|
|
@ -182,46 +182,6 @@ func (m *ListResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) {
|
||||||
m.VerifyHeader = v
|
m.VerifyHeader = v
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetEacl sets eACL table structure.
|
|
||||||
func (m *SetExtendedACLRequest_Body) SetEacl(v *acl.EACLTable) {
|
|
||||||
m.Eacl = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetSignature sets signature of the eACL table structure.
|
|
||||||
func (m *SetExtendedACLRequest_Body) SetSignature(v *refs.SignatureRFC6979) {
|
|
||||||
m.Signature = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetBody sets body of the request.
|
|
||||||
func (m *SetExtendedACLRequest) SetBody(v *SetExtendedACLRequest_Body) {
|
|
||||||
m.Body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetMetaHeader sets meta header of the request.
|
|
||||||
func (m *SetExtendedACLRequest) SetMetaHeader(v *session.RequestMetaHeader) {
|
|
||||||
m.MetaHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetVerifyHeader sets verification header of the request.
|
|
||||||
func (m *SetExtendedACLRequest) SetVerifyHeader(v *session.RequestVerificationHeader) {
|
|
||||||
m.VerifyHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetBody sets body of the response.
|
|
||||||
func (m *SetExtendedACLResponse) SetBody(v *SetExtendedACLResponse_Body) {
|
|
||||||
m.Body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetMetaHeader sets meta header of the response.
|
|
||||||
func (m *SetExtendedACLResponse) SetMetaHeader(v *session.ResponseMetaHeader) {
|
|
||||||
m.MetaHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetVerifyHeader sets verification header of the response.
|
|
||||||
func (m *SetExtendedACLResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) {
|
|
||||||
m.VerifyHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetContainerId sets identifier of the container.
|
// SetContainerId sets identifier of the container.
|
||||||
func (m *GetExtendedACLRequest_Body) SetContainerId(v *refs.ContainerID) {
|
func (m *GetExtendedACLRequest_Body) SetContainerId(v *refs.ContainerID) {
|
||||||
m.ContainerId = v
|
m.ContainerId = v
|
||||||
|
@ -272,53 +232,3 @@ func (m *GetExtendedACLResponse) SetMetaHeader(v *session.ResponseMetaHeader) {
|
||||||
func (m *GetExtendedACLResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) {
|
func (m *GetExtendedACLResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) {
|
||||||
m.VerifyHeader = v
|
m.VerifyHeader = v
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetEpoch sets epoch of the size estimation.
|
|
||||||
func (m *AnnounceUsedSpaceRequest_Body_Announcement) SetEpoch(v uint64) {
|
|
||||||
m.Epoch = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetContainerId sets identifier of the container.
|
|
||||||
func (m *AnnounceUsedSpaceRequest_Body_Announcement) SetContainerId(v *refs.ContainerID) {
|
|
||||||
m.ContainerId = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetUsedSpace sets used space value of the container.
|
|
||||||
func (m *AnnounceUsedSpaceRequest_Body_Announcement) SetUsedSpace(v uint64) {
|
|
||||||
m.UsedSpace = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetAnnouncements sets list of announcement for shared containers between nodes.
|
|
||||||
func (m *AnnounceUsedSpaceRequest_Body) SetAnnouncements(v []*AnnounceUsedSpaceRequest_Body_Announcement) {
|
|
||||||
m.Announcements = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetBody sets body of the request.
|
|
||||||
func (m *AnnounceUsedSpaceRequest) SetBody(v *AnnounceUsedSpaceRequest_Body) {
|
|
||||||
m.Body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetMetaHeader sets meta header of the request.
|
|
||||||
func (m *AnnounceUsedSpaceRequest) SetMetaHeader(v *session.RequestMetaHeader) {
|
|
||||||
m.MetaHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetVerifyHeader sets verification header of the request.
|
|
||||||
func (m *AnnounceUsedSpaceRequest) SetVerifyHeader(v *session.RequestVerificationHeader) {
|
|
||||||
m.VerifyHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetBody sets body of the response.
|
|
||||||
func (m *AnnounceUsedSpaceResponse) SetBody(v *AnnounceUsedSpaceResponse_Body) {
|
|
||||||
m.Body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetMetaHeader sets meta header of the response.
|
|
||||||
func (m *AnnounceUsedSpaceResponse) SetMetaHeader(v *session.ResponseMetaHeader) {
|
|
||||||
m.MetaHeader = v
|
|
||||||
}
|
|
||||||
|
|
||||||
// SetVerifyHeader sets verification header of the response.
|
|
||||||
func (m *AnnounceUsedSpaceResponse) SetVerifyHeader(v *session.ResponseVerificationHeader) {
|
|
||||||
m.VerifyHeader = v
|
|
||||||
}
|
|
||||||
|
|
1164
container/grpc/service.pb.go
generated
1164
container/grpc/service.pb.go
generated
File diff suppressed because it is too large
Load diff
118
container/grpc/service_grpc.pb.go
generated
118
container/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: container/grpc/service.proto
|
// source: container/grpc/service.proto
|
||||||
|
|
||||||
package container
|
package container
|
||||||
|
@ -19,13 +19,11 @@ import (
|
||||||
const _ = grpc.SupportPackageIsVersion7
|
const _ = grpc.SupportPackageIsVersion7
|
||||||
|
|
||||||
const (
|
const (
|
||||||
ContainerService_Put_FullMethodName = "/neo.fs.v2.container.ContainerService/Put"
|
ContainerService_Put_FullMethodName = "/neo.fs.v2.container.ContainerService/Put"
|
||||||
ContainerService_Delete_FullMethodName = "/neo.fs.v2.container.ContainerService/Delete"
|
ContainerService_Delete_FullMethodName = "/neo.fs.v2.container.ContainerService/Delete"
|
||||||
ContainerService_Get_FullMethodName = "/neo.fs.v2.container.ContainerService/Get"
|
ContainerService_Get_FullMethodName = "/neo.fs.v2.container.ContainerService/Get"
|
||||||
ContainerService_List_FullMethodName = "/neo.fs.v2.container.ContainerService/List"
|
ContainerService_List_FullMethodName = "/neo.fs.v2.container.ContainerService/List"
|
||||||
ContainerService_SetExtendedACL_FullMethodName = "/neo.fs.v2.container.ContainerService/SetExtendedACL"
|
ContainerService_GetExtendedACL_FullMethodName = "/neo.fs.v2.container.ContainerService/GetExtendedACL"
|
||||||
ContainerService_GetExtendedACL_FullMethodName = "/neo.fs.v2.container.ContainerService/GetExtendedACL"
|
|
||||||
ContainerService_AnnounceUsedSpace_FullMethodName = "/neo.fs.v2.container.ContainerService/AnnounceUsedSpace"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// ContainerServiceClient is the client API for ContainerService service.
|
// ContainerServiceClient is the client API for ContainerService service.
|
||||||
|
@ -76,17 +74,6 @@ type ContainerServiceClient interface {
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
||||||
// container list access denied.
|
// container list access denied.
|
||||||
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
|
List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
|
||||||
// Invokes 'SetEACL' method of 'Container` smart contract and returns response
|
|
||||||
// immediately. After one more block in sidechain, changes in an Extended ACL
|
|
||||||
// are added into smart contract storage.
|
|
||||||
//
|
|
||||||
// Statuses:
|
|
||||||
// - **OK** (0, SECTION_SUCCESS): \
|
|
||||||
// request to save container eACL has been sent to the sidechain;
|
|
||||||
// - Common failures (SECTION_FAILURE_COMMON);
|
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
|
||||||
// set container eACL access denied.
|
|
||||||
SetExtendedACL(ctx context.Context, in *SetExtendedACLRequest, opts ...grpc.CallOption) (*SetExtendedACLResponse, error)
|
|
||||||
// Returns Extended ACL table and signature from `Container` smart contract
|
// Returns Extended ACL table and signature from `Container` smart contract
|
||||||
// storage.
|
// storage.
|
||||||
//
|
//
|
||||||
|
@ -101,13 +88,6 @@ type ContainerServiceClient interface {
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
||||||
// access to container eACL is denied.
|
// access to container eACL is denied.
|
||||||
GetExtendedACL(ctx context.Context, in *GetExtendedACLRequest, opts ...grpc.CallOption) (*GetExtendedACLResponse, error)
|
GetExtendedACL(ctx context.Context, in *GetExtendedACLRequest, opts ...grpc.CallOption) (*GetExtendedACLResponse, error)
|
||||||
// Announces the space values used by the container for P2P synchronization.
|
|
||||||
//
|
|
||||||
// Statuses:
|
|
||||||
// - **OK** (0, SECTION_SUCCESS): \
|
|
||||||
// estimation of used space has been successfully announced;
|
|
||||||
// - Common failures (SECTION_FAILURE_COMMON).
|
|
||||||
AnnounceUsedSpace(ctx context.Context, in *AnnounceUsedSpaceRequest, opts ...grpc.CallOption) (*AnnounceUsedSpaceResponse, error)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type containerServiceClient struct {
|
type containerServiceClient struct {
|
||||||
|
@ -154,15 +134,6 @@ func (c *containerServiceClient) List(ctx context.Context, in *ListRequest, opts
|
||||||
return out, nil
|
return out, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *containerServiceClient) SetExtendedACL(ctx context.Context, in *SetExtendedACLRequest, opts ...grpc.CallOption) (*SetExtendedACLResponse, error) {
|
|
||||||
out := new(SetExtendedACLResponse)
|
|
||||||
err := c.cc.Invoke(ctx, ContainerService_SetExtendedACL_FullMethodName, in, out, opts...)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return out, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *containerServiceClient) GetExtendedACL(ctx context.Context, in *GetExtendedACLRequest, opts ...grpc.CallOption) (*GetExtendedACLResponse, error) {
|
func (c *containerServiceClient) GetExtendedACL(ctx context.Context, in *GetExtendedACLRequest, opts ...grpc.CallOption) (*GetExtendedACLResponse, error) {
|
||||||
out := new(GetExtendedACLResponse)
|
out := new(GetExtendedACLResponse)
|
||||||
err := c.cc.Invoke(ctx, ContainerService_GetExtendedACL_FullMethodName, in, out, opts...)
|
err := c.cc.Invoke(ctx, ContainerService_GetExtendedACL_FullMethodName, in, out, opts...)
|
||||||
|
@ -172,15 +143,6 @@ func (c *containerServiceClient) GetExtendedACL(ctx context.Context, in *GetExte
|
||||||
return out, nil
|
return out, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *containerServiceClient) AnnounceUsedSpace(ctx context.Context, in *AnnounceUsedSpaceRequest, opts ...grpc.CallOption) (*AnnounceUsedSpaceResponse, error) {
|
|
||||||
out := new(AnnounceUsedSpaceResponse)
|
|
||||||
err := c.cc.Invoke(ctx, ContainerService_AnnounceUsedSpace_FullMethodName, in, out, opts...)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return out, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// ContainerServiceServer is the server API for ContainerService service.
|
// ContainerServiceServer is the server API for ContainerService service.
|
||||||
// All implementations should embed UnimplementedContainerServiceServer
|
// All implementations should embed UnimplementedContainerServiceServer
|
||||||
// for forward compatibility
|
// for forward compatibility
|
||||||
|
@ -229,17 +191,6 @@ type ContainerServiceServer interface {
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
||||||
// container list access denied.
|
// container list access denied.
|
||||||
List(context.Context, *ListRequest) (*ListResponse, error)
|
List(context.Context, *ListRequest) (*ListResponse, error)
|
||||||
// Invokes 'SetEACL' method of 'Container` smart contract and returns response
|
|
||||||
// immediately. After one more block in sidechain, changes in an Extended ACL
|
|
||||||
// are added into smart contract storage.
|
|
||||||
//
|
|
||||||
// Statuses:
|
|
||||||
// - **OK** (0, SECTION_SUCCESS): \
|
|
||||||
// request to save container eACL has been sent to the sidechain;
|
|
||||||
// - Common failures (SECTION_FAILURE_COMMON);
|
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
|
||||||
// set container eACL access denied.
|
|
||||||
SetExtendedACL(context.Context, *SetExtendedACLRequest) (*SetExtendedACLResponse, error)
|
|
||||||
// Returns Extended ACL table and signature from `Container` smart contract
|
// Returns Extended ACL table and signature from `Container` smart contract
|
||||||
// storage.
|
// storage.
|
||||||
//
|
//
|
||||||
|
@ -254,13 +205,6 @@ type ContainerServiceServer interface {
|
||||||
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
// - **CONTAINER_ACCESS_DENIED** (3074, SECTION_CONTAINER): \
|
||||||
// access to container eACL is denied.
|
// access to container eACL is denied.
|
||||||
GetExtendedACL(context.Context, *GetExtendedACLRequest) (*GetExtendedACLResponse, error)
|
GetExtendedACL(context.Context, *GetExtendedACLRequest) (*GetExtendedACLResponse, error)
|
||||||
// Announces the space values used by the container for P2P synchronization.
|
|
||||||
//
|
|
||||||
// Statuses:
|
|
||||||
// - **OK** (0, SECTION_SUCCESS): \
|
|
||||||
// estimation of used space has been successfully announced;
|
|
||||||
// - Common failures (SECTION_FAILURE_COMMON).
|
|
||||||
AnnounceUsedSpace(context.Context, *AnnounceUsedSpaceRequest) (*AnnounceUsedSpaceResponse, error)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// UnimplementedContainerServiceServer should be embedded to have forward compatible implementations.
|
// UnimplementedContainerServiceServer should be embedded to have forward compatible implementations.
|
||||||
|
@ -279,15 +223,9 @@ func (UnimplementedContainerServiceServer) Get(context.Context, *GetRequest) (*G
|
||||||
func (UnimplementedContainerServiceServer) List(context.Context, *ListRequest) (*ListResponse, error) {
|
func (UnimplementedContainerServiceServer) List(context.Context, *ListRequest) (*ListResponse, error) {
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
|
return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
|
||||||
}
|
}
|
||||||
func (UnimplementedContainerServiceServer) SetExtendedACL(context.Context, *SetExtendedACLRequest) (*SetExtendedACLResponse, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method SetExtendedACL not implemented")
|
|
||||||
}
|
|
||||||
func (UnimplementedContainerServiceServer) GetExtendedACL(context.Context, *GetExtendedACLRequest) (*GetExtendedACLResponse, error) {
|
func (UnimplementedContainerServiceServer) GetExtendedACL(context.Context, *GetExtendedACLRequest) (*GetExtendedACLResponse, error) {
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method GetExtendedACL not implemented")
|
return nil, status.Errorf(codes.Unimplemented, "method GetExtendedACL not implemented")
|
||||||
}
|
}
|
||||||
func (UnimplementedContainerServiceServer) AnnounceUsedSpace(context.Context, *AnnounceUsedSpaceRequest) (*AnnounceUsedSpaceResponse, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method AnnounceUsedSpace not implemented")
|
|
||||||
}
|
|
||||||
|
|
||||||
// UnsafeContainerServiceServer may be embedded to opt out of forward compatibility for this service.
|
// UnsafeContainerServiceServer may be embedded to opt out of forward compatibility for this service.
|
||||||
// Use of this interface is not recommended, as added methods to ContainerServiceServer will
|
// Use of this interface is not recommended, as added methods to ContainerServiceServer will
|
||||||
|
@ -372,24 +310,6 @@ func _ContainerService_List_Handler(srv interface{}, ctx context.Context, dec fu
|
||||||
return interceptor(ctx, in, info, handler)
|
return interceptor(ctx, in, info, handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
func _ContainerService_SetExtendedACL_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(SetExtendedACLRequest)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
if interceptor == nil {
|
|
||||||
return srv.(ContainerServiceServer).SetExtendedACL(ctx, in)
|
|
||||||
}
|
|
||||||
info := &grpc.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ContainerService_SetExtendedACL_FullMethodName,
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
return srv.(ContainerServiceServer).SetExtendedACL(ctx, req.(*SetExtendedACLRequest))
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
func _ContainerService_GetExtendedACL_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
func _ContainerService_GetExtendedACL_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
||||||
in := new(GetExtendedACLRequest)
|
in := new(GetExtendedACLRequest)
|
||||||
if err := dec(in); err != nil {
|
if err := dec(in); err != nil {
|
||||||
|
@ -408,24 +328,6 @@ func _ContainerService_GetExtendedACL_Handler(srv interface{}, ctx context.Conte
|
||||||
return interceptor(ctx, in, info, handler)
|
return interceptor(ctx, in, info, handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
func _ContainerService_AnnounceUsedSpace_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(AnnounceUsedSpaceRequest)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
if interceptor == nil {
|
|
||||||
return srv.(ContainerServiceServer).AnnounceUsedSpace(ctx, in)
|
|
||||||
}
|
|
||||||
info := &grpc.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ContainerService_AnnounceUsedSpace_FullMethodName,
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
return srv.(ContainerServiceServer).AnnounceUsedSpace(ctx, req.(*AnnounceUsedSpaceRequest))
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ContainerService_ServiceDesc is the grpc.ServiceDesc for ContainerService service.
|
// ContainerService_ServiceDesc is the grpc.ServiceDesc for ContainerService service.
|
||||||
// It's only intended for direct use with grpc.RegisterService,
|
// It's only intended for direct use with grpc.RegisterService,
|
||||||
// and not to be introspected or modified (even as a copy)
|
// and not to be introspected or modified (even as a copy)
|
||||||
|
@ -449,18 +351,10 @@ var ContainerService_ServiceDesc = grpc.ServiceDesc{
|
||||||
MethodName: "List",
|
MethodName: "List",
|
||||||
Handler: _ContainerService_List_Handler,
|
Handler: _ContainerService_List_Handler,
|
||||||
},
|
},
|
||||||
{
|
|
||||||
MethodName: "SetExtendedACL",
|
|
||||||
Handler: _ContainerService_SetExtendedACL_Handler,
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
MethodName: "GetExtendedACL",
|
MethodName: "GetExtendedACL",
|
||||||
Handler: _ContainerService_GetExtendedACL_Handler,
|
Handler: _ContainerService_GetExtendedACL_Handler,
|
||||||
},
|
},
|
||||||
{
|
|
||||||
MethodName: "AnnounceUsedSpace",
|
|
||||||
Handler: _ContainerService_AnnounceUsedSpace_Handler,
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
Streams: []grpc.StreamDesc{},
|
Streams: []grpc.StreamDesc{},
|
||||||
Metadata: "container/grpc/service.proto",
|
Metadata: "container/grpc/service.proto",
|
||||||
|
|
2
container/grpc/types.pb.go
generated
2
container/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: container/grpc/types.proto
|
// source: container/grpc/types.proto
|
||||||
|
|
||||||
package container
|
package container
|
||||||
|
|
|
@ -35,20 +35,11 @@ const (
|
||||||
|
|
||||||
listRespBodyIDsField = 1
|
listRespBodyIDsField = 1
|
||||||
|
|
||||||
setEACLReqBodyTableField = 1
|
|
||||||
setEACLReqBodySignatureField = 2
|
|
||||||
|
|
||||||
getEACLReqBodyIDField = 1
|
getEACLReqBodyIDField = 1
|
||||||
|
|
||||||
getEACLRespBodyTableField = 1
|
getEACLRespBodyTableField = 1
|
||||||
getEACLRespBodySignatureField = 2
|
getEACLRespBodySignatureField = 2
|
||||||
getEACLRespBodyTokenField = 3
|
getEACLRespBodyTokenField = 3
|
||||||
|
|
||||||
usedSpaceAnnounceEpochField = 1
|
|
||||||
usedSpaceAnnounceCIDField = 2
|
|
||||||
usedSpaceAnnounceUsedSpaceField = 3
|
|
||||||
|
|
||||||
usedSpaceReqBodyAnnouncementsField = 1
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (a *Attribute) StableMarshal(buf []byte) []byte {
|
func (a *Attribute) StableMarshal(buf []byte) []byte {
|
||||||
|
@ -359,50 +350,6 @@ func (r *ListResponseBody) Unmarshal(data []byte) error {
|
||||||
return message.Unmarshal(r, data, new(container.ListResponse_Body))
|
return message.Unmarshal(r, data, new(container.ListResponse_Body))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) StableMarshal(buf []byte) []byte {
|
|
||||||
if r == nil {
|
|
||||||
return []byte{}
|
|
||||||
}
|
|
||||||
|
|
||||||
if buf == nil {
|
|
||||||
buf = make([]byte, r.StableSize())
|
|
||||||
}
|
|
||||||
|
|
||||||
var offset int
|
|
||||||
|
|
||||||
offset += protoutil.NestedStructureMarshal(setEACLReqBodyTableField, buf[offset:], r.eacl)
|
|
||||||
protoutil.NestedStructureMarshal(setEACLReqBodySignatureField, buf[offset:], r.sig)
|
|
||||||
|
|
||||||
return buf
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) StableSize() (size int) {
|
|
||||||
if r == nil {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
size += protoutil.NestedStructureSize(setEACLReqBodyTableField, r.eacl)
|
|
||||||
size += protoutil.NestedStructureSize(setEACLReqBodySignatureField, r.sig)
|
|
||||||
|
|
||||||
return size
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) Unmarshal(data []byte) error {
|
|
||||||
return message.Unmarshal(r, data, new(container.SetExtendedACLRequest_Body))
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponseBody) StableMarshal(_ []byte) []byte {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponseBody) StableSize() (size int) {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponseBody) Unmarshal([]byte) error {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *GetExtendedACLRequestBody) StableMarshal(buf []byte) []byte {
|
func (r *GetExtendedACLRequestBody) StableMarshal(buf []byte) []byte {
|
||||||
if r == nil {
|
if r == nil {
|
||||||
return []byte{}
|
return []byte{}
|
||||||
|
@ -464,83 +411,3 @@ func (r *GetExtendedACLResponseBody) StableSize() (size int) {
|
||||||
func (r *GetExtendedACLResponseBody) Unmarshal(data []byte) error {
|
func (r *GetExtendedACLResponseBody) Unmarshal(data []byte) error {
|
||||||
return message.Unmarshal(r, data, new(container.GetExtendedACLResponse_Body))
|
return message.Unmarshal(r, data, new(container.GetExtendedACLResponse_Body))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) StableMarshal(buf []byte) []byte {
|
|
||||||
if a == nil {
|
|
||||||
return []byte{}
|
|
||||||
}
|
|
||||||
|
|
||||||
if buf == nil {
|
|
||||||
buf = make([]byte, a.StableSize())
|
|
||||||
}
|
|
||||||
|
|
||||||
var offset int
|
|
||||||
|
|
||||||
offset += protoutil.UInt64Marshal(usedSpaceAnnounceEpochField, buf[offset:], a.epoch)
|
|
||||||
offset += protoutil.NestedStructureMarshal(usedSpaceAnnounceCIDField, buf[offset:], a.cid)
|
|
||||||
protoutil.UInt64Marshal(usedSpaceAnnounceUsedSpaceField, buf[offset:], a.usedSpace)
|
|
||||||
|
|
||||||
return buf
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) StableSize() (size int) {
|
|
||||||
if a == nil {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
size += protoutil.UInt64Size(usedSpaceAnnounceEpochField, a.epoch)
|
|
||||||
size += protoutil.NestedStructureSize(usedSpaceAnnounceCIDField, a.cid)
|
|
||||||
size += protoutil.UInt64Size(usedSpaceAnnounceUsedSpaceField, a.usedSpace)
|
|
||||||
|
|
||||||
return size
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) Unmarshal(data []byte) error {
|
|
||||||
return message.Unmarshal(a, data, new(container.AnnounceUsedSpaceRequest_Body_Announcement))
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) StableMarshal(buf []byte) []byte {
|
|
||||||
if r == nil {
|
|
||||||
return []byte{}
|
|
||||||
}
|
|
||||||
|
|
||||||
if buf == nil {
|
|
||||||
buf = make([]byte, r.StableSize())
|
|
||||||
}
|
|
||||||
|
|
||||||
var offset int
|
|
||||||
|
|
||||||
for i := range r.announcements {
|
|
||||||
offset += protoutil.NestedStructureMarshal(usedSpaceReqBodyAnnouncementsField, buf[offset:], &r.announcements[i])
|
|
||||||
}
|
|
||||||
|
|
||||||
return buf
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) StableSize() (size int) {
|
|
||||||
if r == nil {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
for i := range r.announcements {
|
|
||||||
size += protoutil.NestedStructureSize(usedSpaceReqBodyAnnouncementsField, &r.announcements[i])
|
|
||||||
}
|
|
||||||
|
|
||||||
return size
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) Unmarshal(data []byte) error {
|
|
||||||
return message.Unmarshal(r, data, new(container.AnnounceUsedSpaceRequest_Body))
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponseBody) StableMarshal(_ []byte) []byte {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponseBody) StableSize() (size int) {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponseBody) Unmarshal([]byte) error {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
|
@ -28,8 +28,6 @@ func TestMessageConvert(t *testing.T) {
|
||||||
func(empty bool) message.Message { return containertest.GenerateListRequest(empty) },
|
func(empty bool) message.Message { return containertest.GenerateListRequest(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateListResponseBody(empty) },
|
func(empty bool) message.Message { return containertest.GenerateListResponseBody(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateListResponse(empty) },
|
func(empty bool) message.Message { return containertest.GenerateListResponse(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateSetExtendedACLRequestBody(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateSetExtendedACLRequest(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetRequestBody(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetRequestBody(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetRequest(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetRequest(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetResponseBody(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetResponseBody(empty) },
|
||||||
|
@ -38,10 +36,5 @@ func TestMessageConvert(t *testing.T) {
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLRequest(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLRequest(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLResponseBody(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLResponseBody(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLResponse(empty) },
|
func(empty bool) message.Message { return containertest.GenerateGetExtendedACLResponse(empty) },
|
||||||
func(empty bool) message.Message { return containertest.GenerateUsedSpaceAnnouncement(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateAnnounceUsedSpaceRequestBody(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateAnnounceUsedSpaceRequest(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateAnnounceUsedSpaceResponseBody(empty) },
|
|
||||||
func(empty bool) message.Message { return containertest.GenerateAnnounceUsedSpaceResponse(empty) },
|
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
|
@ -235,50 +235,6 @@ func GenerateListResponse(empty bool) *container.ListResponse {
|
||||||
return m
|
return m
|
||||||
}
|
}
|
||||||
|
|
||||||
func GenerateSetExtendedACLRequestBody(empty bool) *container.SetExtendedACLRequestBody {
|
|
||||||
m := new(container.SetExtendedACLRequestBody)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetEACL(acltest.GenerateTable(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
m.SetSignature(refstest.GenerateSignature(empty))
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateSetExtendedACLRequest(empty bool) *container.SetExtendedACLRequest {
|
|
||||||
m := new(container.SetExtendedACLRequest)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetBody(GenerateSetExtendedACLRequestBody(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
m.SetMetaHeader(sessiontest.GenerateRequestMetaHeader(empty))
|
|
||||||
m.SetVerificationHeader(sessiontest.GenerateRequestVerificationHeader(empty))
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateSetExtendedACLResponseBody(_ bool) *container.SetExtendedACLResponseBody {
|
|
||||||
m := new(container.SetExtendedACLResponseBody)
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateSetExtendedACLResponse(empty bool) *container.SetExtendedACLResponse {
|
|
||||||
m := new(container.SetExtendedACLResponse)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetBody(GenerateSetExtendedACLResponseBody(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
m.SetMetaHeader(sessiontest.GenerateResponseMetaHeader(empty))
|
|
||||||
m.SetVerificationHeader(sessiontest.GenerateResponseVerificationHeader(empty))
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateGetExtendedACLRequestBody(empty bool) *container.GetExtendedACLRequestBody {
|
func GenerateGetExtendedACLRequestBody(empty bool) *container.GetExtendedACLRequestBody {
|
||||||
m := new(container.GetExtendedACLRequestBody)
|
m := new(container.GetExtendedACLRequestBody)
|
||||||
|
|
||||||
|
@ -327,70 +283,3 @@ func GenerateGetExtendedACLResponse(empty bool) *container.GetExtendedACLRespons
|
||||||
|
|
||||||
return m
|
return m
|
||||||
}
|
}
|
||||||
|
|
||||||
func GenerateUsedSpaceAnnouncement(empty bool) *container.UsedSpaceAnnouncement {
|
|
||||||
m := new(container.UsedSpaceAnnouncement)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetContainerID(refstest.GenerateContainerID(false))
|
|
||||||
m.SetEpoch(1)
|
|
||||||
m.SetUsedSpace(2)
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateUsedSpaceAnnouncements(empty bool) []container.UsedSpaceAnnouncement {
|
|
||||||
var res []container.UsedSpaceAnnouncement
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
res = append(res,
|
|
||||||
*GenerateUsedSpaceAnnouncement(false),
|
|
||||||
*GenerateUsedSpaceAnnouncement(false),
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
return res
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateAnnounceUsedSpaceRequestBody(empty bool) *container.AnnounceUsedSpaceRequestBody {
|
|
||||||
m := new(container.AnnounceUsedSpaceRequestBody)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetAnnouncements(GenerateUsedSpaceAnnouncements(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateAnnounceUsedSpaceRequest(empty bool) *container.AnnounceUsedSpaceRequest {
|
|
||||||
m := new(container.AnnounceUsedSpaceRequest)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetBody(GenerateAnnounceUsedSpaceRequestBody(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
m.SetMetaHeader(sessiontest.GenerateRequestMetaHeader(empty))
|
|
||||||
m.SetVerificationHeader(sessiontest.GenerateRequestVerificationHeader(empty))
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateAnnounceUsedSpaceResponseBody(_ bool) *container.AnnounceUsedSpaceResponseBody {
|
|
||||||
m := new(container.AnnounceUsedSpaceResponseBody)
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
||||||
func GenerateAnnounceUsedSpaceResponse(empty bool) *container.AnnounceUsedSpaceResponse {
|
|
||||||
m := new(container.AnnounceUsedSpaceResponse)
|
|
||||||
|
|
||||||
if !empty {
|
|
||||||
m.SetBody(GenerateAnnounceUsedSpaceResponseBody(false))
|
|
||||||
}
|
|
||||||
|
|
||||||
m.SetMetaHeader(sessiontest.GenerateResponseMetaHeader(empty))
|
|
||||||
m.SetVerificationHeader(sessiontest.GenerateResponseVerificationHeader(empty))
|
|
||||||
|
|
||||||
return m
|
|
||||||
}
|
|
||||||
|
|
|
@ -110,26 +110,6 @@ type ListResponse struct {
|
||||||
session.ResponseHeaders
|
session.ResponseHeaders
|
||||||
}
|
}
|
||||||
|
|
||||||
type SetExtendedACLRequestBody struct {
|
|
||||||
eacl *acl.Table
|
|
||||||
|
|
||||||
sig *refs.Signature
|
|
||||||
}
|
|
||||||
|
|
||||||
type SetExtendedACLRequest struct {
|
|
||||||
body *SetExtendedACLRequestBody
|
|
||||||
|
|
||||||
session.RequestHeaders
|
|
||||||
}
|
|
||||||
|
|
||||||
type SetExtendedACLResponseBody struct{}
|
|
||||||
|
|
||||||
type SetExtendedACLResponse struct {
|
|
||||||
body *SetExtendedACLResponseBody
|
|
||||||
|
|
||||||
session.ResponseHeaders
|
|
||||||
}
|
|
||||||
|
|
||||||
type GetExtendedACLRequestBody struct {
|
type GetExtendedACLRequestBody struct {
|
||||||
cid *refs.ContainerID
|
cid *refs.ContainerID
|
||||||
}
|
}
|
||||||
|
@ -154,32 +134,6 @@ type GetExtendedACLResponse struct {
|
||||||
session.ResponseHeaders
|
session.ResponseHeaders
|
||||||
}
|
}
|
||||||
|
|
||||||
type UsedSpaceAnnouncement struct {
|
|
||||||
epoch uint64
|
|
||||||
|
|
||||||
cid *refs.ContainerID
|
|
||||||
|
|
||||||
usedSpace uint64
|
|
||||||
}
|
|
||||||
|
|
||||||
type AnnounceUsedSpaceRequestBody struct {
|
|
||||||
announcements []UsedSpaceAnnouncement
|
|
||||||
}
|
|
||||||
|
|
||||||
type AnnounceUsedSpaceRequest struct {
|
|
||||||
body *AnnounceUsedSpaceRequestBody
|
|
||||||
|
|
||||||
session.RequestHeaders
|
|
||||||
}
|
|
||||||
|
|
||||||
type AnnounceUsedSpaceResponseBody struct{}
|
|
||||||
|
|
||||||
type AnnounceUsedSpaceResponse struct {
|
|
||||||
body *AnnounceUsedSpaceResponseBody
|
|
||||||
|
|
||||||
session.ResponseHeaders
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *Attribute) GetKey() string {
|
func (a *Attribute) GetKey() string {
|
||||||
if a != nil {
|
if a != nil {
|
||||||
return a.key
|
return a.key
|
||||||
|
@ -516,56 +470,6 @@ func (r *ListResponse) SetBody(v *ListResponseBody) {
|
||||||
r.body = v
|
r.body = v
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) GetEACL() *acl.Table {
|
|
||||||
if r != nil {
|
|
||||||
return r.eacl
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) SetEACL(v *acl.Table) {
|
|
||||||
r.eacl = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) GetSignature() *refs.Signature {
|
|
||||||
if r != nil {
|
|
||||||
return r.sig
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequestBody) SetSignature(v *refs.Signature) {
|
|
||||||
// TODO: (neofs-api-go#381) avoid this hack (e.g. create refs.SignatureRFC6979 type)
|
|
||||||
v.SetScheme(0)
|
|
||||||
r.sig = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequest) GetBody() *SetExtendedACLRequestBody {
|
|
||||||
if r != nil {
|
|
||||||
return r.body
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLRequest) SetBody(v *SetExtendedACLRequestBody) {
|
|
||||||
r.body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponse) GetBody() *SetExtendedACLResponseBody {
|
|
||||||
if r != nil {
|
|
||||||
return r.body
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *SetExtendedACLResponse) SetBody(v *SetExtendedACLResponseBody) {
|
|
||||||
r.body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *GetExtendedACLRequestBody) GetContainerID() *refs.ContainerID {
|
func (r *GetExtendedACLRequestBody) GetContainerID() *refs.ContainerID {
|
||||||
if r != nil {
|
if r != nil {
|
||||||
return r.cid
|
return r.cid
|
||||||
|
@ -643,75 +547,3 @@ func (r *GetExtendedACLResponse) GetBody() *GetExtendedACLResponseBody {
|
||||||
func (r *GetExtendedACLResponse) SetBody(v *GetExtendedACLResponseBody) {
|
func (r *GetExtendedACLResponse) SetBody(v *GetExtendedACLResponseBody) {
|
||||||
r.body = v
|
r.body = v
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) GetEpoch() uint64 {
|
|
||||||
if a != nil {
|
|
||||||
return a.epoch
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) SetEpoch(v uint64) {
|
|
||||||
a.epoch = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) GetUsedSpace() uint64 {
|
|
||||||
if a != nil {
|
|
||||||
return a.usedSpace
|
|
||||||
}
|
|
||||||
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) SetUsedSpace(v uint64) {
|
|
||||||
a.usedSpace = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) GetContainerID() *refs.ContainerID {
|
|
||||||
if a != nil {
|
|
||||||
return a.cid
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (a *UsedSpaceAnnouncement) SetContainerID(v *refs.ContainerID) {
|
|
||||||
a.cid = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) GetAnnouncements() []UsedSpaceAnnouncement {
|
|
||||||
if r != nil {
|
|
||||||
return r.announcements
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequestBody) SetAnnouncements(v []UsedSpaceAnnouncement) {
|
|
||||||
r.announcements = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequest) GetBody() *AnnounceUsedSpaceRequestBody {
|
|
||||||
if r != nil {
|
|
||||||
return r.body
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceRequest) SetBody(v *AnnounceUsedSpaceRequestBody) {
|
|
||||||
r.body = v
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponse) GetBody() *AnnounceUsedSpaceResponseBody {
|
|
||||||
if r != nil {
|
|
||||||
return r.body
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (r *AnnounceUsedSpaceResponse) SetBody(v *AnnounceUsedSpaceResponseBody) {
|
|
||||||
r.body = v
|
|
||||||
}
|
|
||||||
|
|
2
lock/grpc/types.pb.go
generated
2
lock/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: lock/grpc/types.proto
|
// source: lock/grpc/types.proto
|
||||||
|
|
||||||
package lock
|
package lock
|
||||||
|
|
2
netmap/grpc/service.pb.go
generated
2
netmap/grpc/service.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: netmap/grpc/service.proto
|
// source: netmap/grpc/service.proto
|
||||||
|
|
||||||
package netmap
|
package netmap
|
||||||
|
|
2
netmap/grpc/service_grpc.pb.go
generated
2
netmap/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: netmap/grpc/service.proto
|
// source: netmap/grpc/service.proto
|
||||||
|
|
||||||
package netmap
|
package netmap
|
||||||
|
|
2
netmap/grpc/types.pb.go
generated
2
netmap/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: netmap/grpc/types.proto
|
// source: netmap/grpc/types.proto
|
||||||
|
|
||||||
package netmap
|
package netmap
|
||||||
|
|
6
object/grpc/service.pb.go
generated
6
object/grpc/service.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: object/grpc/service.proto
|
// source: object/grpc/service.proto
|
||||||
|
|
||||||
package object
|
package object
|
||||||
|
@ -2114,8 +2114,8 @@ func (x *SearchRequest_Body) GetFilters() []*SearchRequest_Body_Filter {
|
||||||
// - $Object:split.splitID \
|
// - $Object:split.splitID \
|
||||||
// 16 byte UUIDv4 used to identify the split object hierarchy parts
|
// 16 byte UUIDv4 used to identify the split object hierarchy parts
|
||||||
// - $Object:ec.parent \
|
// - $Object:ec.parent \
|
||||||
// If the object is stored according to EC policy, then ec_parent attribute
|
// If the object is stored according to EC policy, then ec_parent
|
||||||
// is set to return an id list of all related EC chunks.
|
// attribute is set to return an id list of all related EC chunks.
|
||||||
//
|
//
|
||||||
// There are some well-known filter aliases to match objects by certain
|
// There are some well-known filter aliases to match objects by certain
|
||||||
// properties:
|
// properties:
|
||||||
|
|
2
object/grpc/service_grpc.pb.go
generated
2
object/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: object/grpc/service.proto
|
// source: object/grpc/service.proto
|
||||||
|
|
||||||
package object
|
package object
|
||||||
|
|
13
object/grpc/types.pb.go
generated
13
object/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: object/grpc/types.proto
|
// source: object/grpc/types.proto
|
||||||
|
|
||||||
package object
|
package object
|
||||||
|
@ -824,12 +824,13 @@ type Header_EC struct {
|
||||||
// Chunk of a parent header.
|
// Chunk of a parent header.
|
||||||
Header []byte `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"`
|
Header []byte `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"`
|
||||||
// As the origin object is EC-splitted its identifier is known to all
|
// As the origin object is EC-splitted its identifier is known to all
|
||||||
// chunks as parent. But parent itself can be a part of Split (does not relate to EC-split).
|
// chunks as parent. But parent itself can be a part of Split (does not
|
||||||
// In this case parent_split_id should be set.
|
// relate to EC-split). In this case parent_split_id should be set.
|
||||||
ParentSplitId []byte `protobuf:"bytes,6,opt,name=parent_split_id,json=parentSplitID,proto3" json:"parent_split_id,omitempty"`
|
ParentSplitId []byte `protobuf:"bytes,6,opt,name=parent_split_id,json=parentSplitID,proto3" json:"parent_split_id,omitempty"`
|
||||||
// EC-parent's parent ID. parent_split_parent_id is set if EC-parent, itself, is a part of Split and
|
// EC-parent's parent ID. parent_split_parent_id is set if EC-parent,
|
||||||
// if an object ID of its parent is presented. The field allows to determine how EC-chunk is placed
|
// itself, is a part of Split and if an object ID of its parent is
|
||||||
// in Split hierarchy.
|
// presented. The field allows to determine how EC-chunk is placed in Split
|
||||||
|
// hierarchy.
|
||||||
ParentSplitParentId *grpc.ObjectID `protobuf:"bytes,7,opt,name=parent_split_parent_id,json=parentSplitParentID,proto3" json:"parent_split_parent_id,omitempty"`
|
ParentSplitParentId *grpc.ObjectID `protobuf:"bytes,7,opt,name=parent_split_parent_id,json=parentSplitParentID,proto3" json:"parent_split_parent_id,omitempty"`
|
||||||
// EC parent's attributes.
|
// EC parent's attributes.
|
||||||
ParentAttributes []*Header_Attribute `protobuf:"bytes,8,rep,name=parent_attributes,json=parentAttributes,proto3" json:"parent_attributes,omitempty"`
|
ParentAttributes []*Header_Attribute `protobuf:"bytes,8,rep,name=parent_attributes,json=parentAttributes,proto3" json:"parent_attributes,omitempty"`
|
||||||
|
|
2
refs/grpc/types.pb.go
generated
2
refs/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: refs/grpc/types.proto
|
// source: refs/grpc/types.proto
|
||||||
|
|
||||||
package refs
|
package refs
|
||||||
|
|
|
@ -13,7 +13,6 @@ const (
|
||||||
rpcContainerGet = "Get"
|
rpcContainerGet = "Get"
|
||||||
rpcContainerDel = "Delete"
|
rpcContainerDel = "Delete"
|
||||||
rpcContainerList = "List"
|
rpcContainerList = "List"
|
||||||
rpcContainerSetEACL = "SetExtendedACL"
|
|
||||||
rpcContainerGetEACL = "GetExtendedACL"
|
rpcContainerGetEACL = "GetExtendedACL"
|
||||||
rpcContainerUsedSpace = "AnnounceUsedSpace"
|
rpcContainerUsedSpace = "AnnounceUsedSpace"
|
||||||
)
|
)
|
||||||
|
@ -82,22 +81,6 @@ func ListContainers(
|
||||||
return resp, nil
|
return resp, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// SetEACL executes ContainerService.SetExtendedACL RPC.
|
|
||||||
func SetEACL(
|
|
||||||
cli *client.Client,
|
|
||||||
req *container.SetExtendedACLRequest,
|
|
||||||
opts ...client.CallOption,
|
|
||||||
) (*container.PutResponse, error) {
|
|
||||||
resp := new(container.PutResponse)
|
|
||||||
|
|
||||||
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerSetEACL), req, resp, opts...)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return resp, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetEACL executes ContainerService.GetExtendedACL RPC.
|
// GetEACL executes ContainerService.GetExtendedACL RPC.
|
||||||
func GetEACL(
|
func GetEACL(
|
||||||
cli *client.Client,
|
cli *client.Client,
|
||||||
|
@ -113,19 +96,3 @@ func GetEACL(
|
||||||
|
|
||||||
return resp, nil
|
return resp, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// AnnounceUsedSpace executes ContainerService.AnnounceUsedSpace RPC.
|
|
||||||
func AnnounceUsedSpace(
|
|
||||||
cli *client.Client,
|
|
||||||
req *container.AnnounceUsedSpaceRequest,
|
|
||||||
opts ...client.CallOption,
|
|
||||||
) (*container.PutResponse, error) {
|
|
||||||
resp := new(container.PutResponse)
|
|
||||||
|
|
||||||
err := client.SendUnary(cli, common.CallMethodInfoUnary(serviceContainer, rpcContainerUsedSpace), req, resp, opts...)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return resp, nil
|
|
||||||
}
|
|
||||||
|
|
2
session/grpc/service.pb.go
generated
2
session/grpc/service.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: session/grpc/service.proto
|
// source: session/grpc/service.proto
|
||||||
|
|
||||||
package session
|
package session
|
||||||
|
|
2
session/grpc/service_grpc.pb.go
generated
2
session/grpc/service_grpc.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// - protoc-gen-go-grpc v1.3.0
|
// - protoc-gen-go-grpc v1.3.0
|
||||||
// - protoc v4.25.3
|
// - protoc v5.27.2
|
||||||
// source: session/grpc/service.proto
|
// source: session/grpc/service.proto
|
||||||
|
|
||||||
package session
|
package session
|
||||||
|
|
2
session/grpc/types.pb.go
generated
2
session/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: session/grpc/types.proto
|
// source: session/grpc/types.proto
|
||||||
|
|
||||||
package session
|
package session
|
||||||
|
|
|
@ -46,18 +46,10 @@ func serviceMessageBody(req any) stableMarshaler {
|
||||||
return v.GetBody()
|
return v.GetBody()
|
||||||
case *container.ListResponse:
|
case *container.ListResponse:
|
||||||
return v.GetBody()
|
return v.GetBody()
|
||||||
case *container.SetExtendedACLRequest:
|
|
||||||
return v.GetBody()
|
|
||||||
case *container.SetExtendedACLResponse:
|
|
||||||
return v.GetBody()
|
|
||||||
case *container.GetExtendedACLRequest:
|
case *container.GetExtendedACLRequest:
|
||||||
return v.GetBody()
|
return v.GetBody()
|
||||||
case *container.GetExtendedACLResponse:
|
case *container.GetExtendedACLResponse:
|
||||||
return v.GetBody()
|
return v.GetBody()
|
||||||
case *container.AnnounceUsedSpaceRequest:
|
|
||||||
return v.GetBody()
|
|
||||||
case *container.AnnounceUsedSpaceResponse:
|
|
||||||
return v.GetBody()
|
|
||||||
|
|
||||||
/* Object */
|
/* Object */
|
||||||
case *object.PutRequest:
|
case *object.PutRequest:
|
||||||
|
|
5
status/grpc/types.pb.go
generated
5
status/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: status/grpc/types.proto
|
// source: status/grpc/types.proto
|
||||||
|
|
||||||
package status
|
package status
|
||||||
|
@ -150,7 +150,8 @@ const (
|
||||||
// [**1027**] Node is under maintenance.
|
// [**1027**] Node is under maintenance.
|
||||||
CommonFail_NODE_UNDER_MAINTENANCE CommonFail = 3
|
CommonFail_NODE_UNDER_MAINTENANCE CommonFail = 3
|
||||||
// [**1028**] Invalid argument error. If the server fails on validation of a
|
// [**1028**] Invalid argument error. If the server fails on validation of a
|
||||||
// request parameter as the client sent it incorrectly, then this code should be used.
|
// request parameter as the client sent it incorrectly, then this code should
|
||||||
|
// be used.
|
||||||
CommonFail_INVALID_ARGUMENT CommonFail = 4
|
CommonFail_INVALID_ARGUMENT CommonFail = 4
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
2
tombstone/grpc/types.pb.go
generated
2
tombstone/grpc/types.pb.go
generated
|
@ -1,7 +1,7 @@
|
||||||
// Code generated by protoc-gen-go. DO NOT EDIT.
|
// Code generated by protoc-gen-go. DO NOT EDIT.
|
||||||
// versions:
|
// versions:
|
||||||
// protoc-gen-go v1.33.0
|
// protoc-gen-go v1.33.0
|
||||||
// protoc v4.25.3
|
// protoc v5.27.2
|
||||||
// source: tombstone/grpc/types.proto
|
// source: tombstone/grpc/types.proto
|
||||||
|
|
||||||
package tombstone
|
package tombstone
|
||||||
|
|
Loading…
Reference in a new issue