Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
- type BlobstorInfo
- func (*BlobstorInfo) Descriptor() ([]byte, []int)deprecated
- func (x *BlobstorInfo) GetPath() string
- func (x *BlobstorInfo) GetType() string
- func (*BlobstorInfo) ProtoMessage()
- func (x *BlobstorInfo) ProtoReflect() protoreflect.Message
- func (x *BlobstorInfo) Reset()
- func (x *BlobstorInfo) StableMarshal(buf []byte) []byte
- func (x *BlobstorInfo) StableSize() (size int)
- func (x *BlobstorInfo) String() string
- type ControlServiceClient
- type ControlServiceServer
- type DropObjectsRequest
- func (*DropObjectsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DropObjectsRequest) GetBody() *DropObjectsRequest_Body
- func (x *DropObjectsRequest) GetSignature() *Signature
- func (*DropObjectsRequest) ProtoMessage()
- func (x *DropObjectsRequest) ProtoReflect() protoreflect.Message
- func (x *DropObjectsRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *DropObjectsRequest) Reset()
- func (x *DropObjectsRequest) SetBody(v *DropObjectsRequest_Body)
- func (x *DropObjectsRequest) SetSignature(sig *Signature)
- func (x *DropObjectsRequest) SignedDataSize() int
- func (x *DropObjectsRequest) StableMarshal(buf []byte) []byte
- func (x *DropObjectsRequest) StableSize() (size int)
- func (x *DropObjectsRequest) String() string
- type DropObjectsRequest_Body
- func (*DropObjectsRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *DropObjectsRequest_Body) GetAddressList() [][]byte
- func (*DropObjectsRequest_Body) ProtoMessage()
- func (x *DropObjectsRequest_Body) ProtoReflect() protoreflect.Message
- func (x *DropObjectsRequest_Body) Reset()
- func (x *DropObjectsRequest_Body) SetAddressList(v [][]byte)
- func (x *DropObjectsRequest_Body) StableMarshal(buf []byte) []byte
- func (x *DropObjectsRequest_Body) StableSize() (size int)
- func (x *DropObjectsRequest_Body) String() string
- type DropObjectsResponse
- func (*DropObjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DropObjectsResponse) GetBody() *DropObjectsResponse_Body
- func (x *DropObjectsResponse) GetSignature() *Signature
- func (*DropObjectsResponse) ProtoMessage()
- func (x *DropObjectsResponse) ProtoReflect() protoreflect.Message
- func (x *DropObjectsResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *DropObjectsResponse) Reset()
- func (x *DropObjectsResponse) SetBody(v *DropObjectsResponse_Body)
- func (x *DropObjectsResponse) SetSignature(sig *Signature)
- func (x *DropObjectsResponse) SignedDataSize() int
- func (x *DropObjectsResponse) StableMarshal(buf []byte) []byte
- func (x *DropObjectsResponse) StableSize() (size int)
- func (x *DropObjectsResponse) String() string
- type DropObjectsResponse_Body
- func (*DropObjectsResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*DropObjectsResponse_Body) ProtoMessage()
- func (x *DropObjectsResponse_Body) ProtoReflect() protoreflect.Message
- func (x *DropObjectsResponse_Body) Reset()
- func (x *DropObjectsResponse_Body) StableMarshal(buf []byte) []byte
- func (x *DropObjectsResponse_Body) StableSize() (size int)
- func (x *DropObjectsResponse_Body) String() string
- type DumpShardRequest
- func (*DumpShardRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DumpShardRequest) GetBody() *DumpShardRequest_Body
- func (x *DumpShardRequest) GetSignature() *Signature
- func (*DumpShardRequest) ProtoMessage()
- func (x *DumpShardRequest) ProtoReflect() protoreflect.Message
- func (x *DumpShardRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *DumpShardRequest) Reset()
- func (x *DumpShardRequest) SetBody(v *DumpShardRequest_Body)
- func (x *DumpShardRequest) SetSignature(sig *Signature)
- func (x *DumpShardRequest) SignedDataSize() int
- func (x *DumpShardRequest) StableMarshal(buf []byte) []byte
- func (x *DumpShardRequest) StableSize() (size int)
- func (x *DumpShardRequest) String() string
- type DumpShardRequest_Body
- func (*DumpShardRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *DumpShardRequest_Body) GetFilepath() string
- func (x *DumpShardRequest_Body) GetIgnoreErrors() bool
- func (x *DumpShardRequest_Body) GetShard_ID() []byte
- func (*DumpShardRequest_Body) ProtoMessage()
- func (x *DumpShardRequest_Body) ProtoReflect() protoreflect.Message
- func (x *DumpShardRequest_Body) Reset()
- func (x *DumpShardRequest_Body) SetFilepath(p string)
- func (x *DumpShardRequest_Body) SetIgnoreErrors(ignore bool)
- func (x *DumpShardRequest_Body) SetShardID(id []byte)
- func (x *DumpShardRequest_Body) StableMarshal(buf []byte) []byte
- func (x *DumpShardRequest_Body) StableSize() (size int)
- func (x *DumpShardRequest_Body) String() string
- type DumpShardResponse
- func (*DumpShardResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DumpShardResponse) GetBody() *DumpShardResponse_Body
- func (x *DumpShardResponse) GetSignature() *Signature
- func (*DumpShardResponse) ProtoMessage()
- func (x *DumpShardResponse) ProtoReflect() protoreflect.Message
- func (x *DumpShardResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *DumpShardResponse) Reset()
- func (x *DumpShardResponse) SetBody(v *DumpShardResponse_Body)
- func (x *DumpShardResponse) SetSignature(sig *Signature)
- func (x *DumpShardResponse) SignedDataSize() int
- func (x *DumpShardResponse) StableMarshal(buf []byte) []byte
- func (x *DumpShardResponse) StableSize() (size int)
- func (x *DumpShardResponse) String() string
- type DumpShardResponse_Body
- func (*DumpShardResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*DumpShardResponse_Body) ProtoMessage()
- func (x *DumpShardResponse_Body) ProtoReflect() protoreflect.Message
- func (x *DumpShardResponse_Body) Reset()
- func (x *DumpShardResponse_Body) StableMarshal(buf []byte) []byte
- func (x *DumpShardResponse_Body) StableSize() (size int)
- func (x *DumpShardResponse_Body) String() string
- type EvacuateShardRequest
- func (*EvacuateShardRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EvacuateShardRequest) GetBody() *EvacuateShardRequest_Body
- func (x *EvacuateShardRequest) GetSignature() *Signature
- func (*EvacuateShardRequest) ProtoMessage()
- func (x *EvacuateShardRequest) ProtoReflect() protoreflect.Message
- func (x *EvacuateShardRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *EvacuateShardRequest) Reset()
- func (x *EvacuateShardRequest) SetSignature(sig *Signature)
- func (x *EvacuateShardRequest) SignedDataSize() int
- func (x *EvacuateShardRequest) StableMarshal(buf []byte) []byte
- func (x *EvacuateShardRequest) StableSize() (size int)
- func (x *EvacuateShardRequest) String() string
- type EvacuateShardRequest_Body
- func (*EvacuateShardRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *EvacuateShardRequest_Body) GetIgnoreErrors() bool
- func (x *EvacuateShardRequest_Body) GetShard_ID() [][]byte
- func (*EvacuateShardRequest_Body) ProtoMessage()
- func (x *EvacuateShardRequest_Body) ProtoReflect() protoreflect.Message
- func (x *EvacuateShardRequest_Body) Reset()
- func (x *EvacuateShardRequest_Body) StableMarshal(buf []byte) []byte
- func (x *EvacuateShardRequest_Body) StableSize() (size int)
- func (x *EvacuateShardRequest_Body) String() string
- type EvacuateShardResponse
- func (*EvacuateShardResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EvacuateShardResponse) GetBody() *EvacuateShardResponse_Body
- func (x *EvacuateShardResponse) GetSignature() *Signature
- func (*EvacuateShardResponse) ProtoMessage()
- func (x *EvacuateShardResponse) ProtoReflect() protoreflect.Message
- func (x *EvacuateShardResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *EvacuateShardResponse) Reset()
- func (x *EvacuateShardResponse) SetSignature(sig *Signature)
- func (x *EvacuateShardResponse) SignedDataSize() int
- func (x *EvacuateShardResponse) StableMarshal(buf []byte) []byte
- func (x *EvacuateShardResponse) StableSize() (size int)
- func (x *EvacuateShardResponse) String() string
- type EvacuateShardResponse_Body
- func (*EvacuateShardResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (x *EvacuateShardResponse_Body) GetCount() uint32
- func (*EvacuateShardResponse_Body) ProtoMessage()
- func (x *EvacuateShardResponse_Body) ProtoReflect() protoreflect.Message
- func (x *EvacuateShardResponse_Body) Reset()
- func (x *EvacuateShardResponse_Body) StableMarshal(buf []byte) []byte
- func (x *EvacuateShardResponse_Body) StableSize() (size int)
- func (x *EvacuateShardResponse_Body) String() string
- type FlushCacheRequest
- func (*FlushCacheRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FlushCacheRequest) GetBody() *FlushCacheRequest_Body
- func (x *FlushCacheRequest) GetSignature() *Signature
- func (*FlushCacheRequest) ProtoMessage()
- func (x *FlushCacheRequest) ProtoReflect() protoreflect.Message
- func (x *FlushCacheRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *FlushCacheRequest) Reset()
- func (x *FlushCacheRequest) SetSignature(sig *Signature)
- func (x *FlushCacheRequest) SignedDataSize() int
- func (x *FlushCacheRequest) StableMarshal(buf []byte) []byte
- func (x *FlushCacheRequest) StableSize() (size int)
- func (x *FlushCacheRequest) String() string
- type FlushCacheRequest_Body
- func (*FlushCacheRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *FlushCacheRequest_Body) GetShard_ID() [][]byte
- func (*FlushCacheRequest_Body) ProtoMessage()
- func (x *FlushCacheRequest_Body) ProtoReflect() protoreflect.Message
- func (x *FlushCacheRequest_Body) Reset()
- func (x *FlushCacheRequest_Body) StableMarshal(buf []byte) []byte
- func (x *FlushCacheRequest_Body) StableSize() (size int)
- func (x *FlushCacheRequest_Body) String() string
- type FlushCacheResponse
- func (*FlushCacheResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FlushCacheResponse) GetBody() *FlushCacheResponse_Body
- func (x *FlushCacheResponse) GetSignature() *Signature
- func (*FlushCacheResponse) ProtoMessage()
- func (x *FlushCacheResponse) ProtoReflect() protoreflect.Message
- func (x *FlushCacheResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *FlushCacheResponse) Reset()
- func (x *FlushCacheResponse) SetSignature(sig *Signature)
- func (x *FlushCacheResponse) SignedDataSize() int
- func (x *FlushCacheResponse) StableMarshal(buf []byte) []byte
- func (x *FlushCacheResponse) StableSize() (size int)
- func (x *FlushCacheResponse) String() string
- type FlushCacheResponse_Body
- func (*FlushCacheResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*FlushCacheResponse_Body) ProtoMessage()
- func (x *FlushCacheResponse_Body) ProtoReflect() protoreflect.Message
- func (x *FlushCacheResponse_Body) Reset()
- func (x *FlushCacheResponse_Body) StableMarshal(buf []byte) []byte
- func (x *FlushCacheResponse_Body) StableSize() (size int)
- func (x *FlushCacheResponse_Body) String() string
- type HealthCheckRequest
- func (*HealthCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckRequest) GetBody() *HealthCheckRequest_Body
- func (x *HealthCheckRequest) GetSignature() *Signature
- func (*HealthCheckRequest) ProtoMessage()
- func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *HealthCheckRequest) Reset()
- func (x *HealthCheckRequest) SetBody(v *HealthCheckRequest_Body)
- func (x *HealthCheckRequest) SetSignature(sig *Signature)
- func (x *HealthCheckRequest) SignedDataSize() int
- func (x *HealthCheckRequest) StableMarshal(buf []byte) []byte
- func (x *HealthCheckRequest) StableSize() (size int)
- func (x *HealthCheckRequest) String() string
- type HealthCheckRequest_Body
- func (*HealthCheckRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (*HealthCheckRequest_Body) ProtoMessage()
- func (x *HealthCheckRequest_Body) ProtoReflect() protoreflect.Message
- func (x *HealthCheckRequest_Body) Reset()
- func (x *HealthCheckRequest_Body) StableMarshal(buf []byte) []byte
- func (x *HealthCheckRequest_Body) StableSize() (size int)
- func (x *HealthCheckRequest_Body) String() string
- type HealthCheckResponse
- func (*HealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse) GetBody() *HealthCheckResponse_Body
- func (x *HealthCheckResponse) GetSignature() *Signature
- func (*HealthCheckResponse) ProtoMessage()
- func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *HealthCheckResponse) Reset()
- func (x *HealthCheckResponse) SetBody(v *HealthCheckResponse_Body)
- func (x *HealthCheckResponse) SetSignature(sig *Signature)
- func (x *HealthCheckResponse) SignedDataSize() int
- func (x *HealthCheckResponse) StableMarshal(buf []byte) []byte
- func (x *HealthCheckResponse) StableSize() (size int)
- func (x *HealthCheckResponse) String() string
- type HealthCheckResponse_Body
- func (*HealthCheckResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckResponse_Body) GetHealthStatus() HealthStatus
- func (x *HealthCheckResponse_Body) GetNetmapStatus() NetmapStatus
- func (*HealthCheckResponse_Body) ProtoMessage()
- func (x *HealthCheckResponse_Body) ProtoReflect() protoreflect.Message
- func (x *HealthCheckResponse_Body) Reset()
- func (x *HealthCheckResponse_Body) SetHealthStatus(v HealthStatus)
- func (x *HealthCheckResponse_Body) SetNetmapStatus(v NetmapStatus)
- func (x *HealthCheckResponse_Body) StableMarshal(buf []byte) []byte
- func (x *HealthCheckResponse_Body) StableSize() (size int)
- func (x *HealthCheckResponse_Body) String() string
- type HealthStatus
- func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthStatus) Enum() *HealthStatus
- func (HealthStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthStatus) Number() protoreflect.EnumNumber
- func (x HealthStatus) String() string
- func (HealthStatus) Type() protoreflect.EnumType
- type ListShardsRequest
- func (*ListShardsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListShardsRequest) GetBody() *ListShardsRequest_Body
- func (x *ListShardsRequest) GetSignature() *Signature
- func (*ListShardsRequest) ProtoMessage()
- func (x *ListShardsRequest) ProtoReflect() protoreflect.Message
- func (x *ListShardsRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *ListShardsRequest) Reset()
- func (x *ListShardsRequest) SetBody(v *ListShardsRequest_Body)
- func (x *ListShardsRequest) SetSignature(sig *Signature)
- func (x *ListShardsRequest) SignedDataSize() int
- func (x *ListShardsRequest) StableMarshal(buf []byte) []byte
- func (x *ListShardsRequest) StableSize() (size int)
- func (x *ListShardsRequest) String() string
- type ListShardsRequest_Body
- func (*ListShardsRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (*ListShardsRequest_Body) ProtoMessage()
- func (x *ListShardsRequest_Body) ProtoReflect() protoreflect.Message
- func (x *ListShardsRequest_Body) Reset()
- func (x *ListShardsRequest_Body) StableMarshal(buf []byte) []byte
- func (x *ListShardsRequest_Body) StableSize() (size int)
- func (x *ListShardsRequest_Body) String() string
- type ListShardsResponse
- func (*ListShardsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListShardsResponse) GetBody() *ListShardsResponse_Body
- func (x *ListShardsResponse) GetSignature() *Signature
- func (*ListShardsResponse) ProtoMessage()
- func (x *ListShardsResponse) ProtoReflect() protoreflect.Message
- func (x *ListShardsResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *ListShardsResponse) Reset()
- func (x *ListShardsResponse) SetBody(v *ListShardsResponse_Body)
- func (x *ListShardsResponse) SetSignature(sig *Signature)
- func (x *ListShardsResponse) SignedDataSize() int
- func (x *ListShardsResponse) StableMarshal(buf []byte) []byte
- func (x *ListShardsResponse) StableSize() (size int)
- func (x *ListShardsResponse) String() string
- type ListShardsResponse_Body
- func (*ListShardsResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (x *ListShardsResponse_Body) GetShards() []*ShardInfo
- func (*ListShardsResponse_Body) ProtoMessage()
- func (x *ListShardsResponse_Body) ProtoReflect() protoreflect.Message
- func (x *ListShardsResponse_Body) Reset()
- func (x *ListShardsResponse_Body) SetShards(v []*ShardInfo)
- func (x *ListShardsResponse_Body) StableMarshal(buf []byte) []byte
- func (x *ListShardsResponse_Body) StableSize() (size int)
- func (x *ListShardsResponse_Body) String() string
- type Netmap
- func (*Netmap) Descriptor() ([]byte, []int)deprecated
- func (x *Netmap) GetEpoch() uint64
- func (x *Netmap) GetNodes() []*NodeInfo
- func (x *Netmap) MarshalJSON() ([]byte, error)
- func (*Netmap) ProtoMessage()
- func (x *Netmap) ProtoReflect() protoreflect.Message
- func (x *Netmap) Reset()
- func (x *Netmap) SetEpoch(v uint64)
- func (x *Netmap) SetNodes(v []*NodeInfo)
- func (x *Netmap) StableMarshal(buf []byte) []byte
- func (x *Netmap) StableSize() (size int)
- func (x *Netmap) String() string
- type NetmapStatus
- func (NetmapStatus) Descriptor() protoreflect.EnumDescriptor
- func (x NetmapStatus) Enum() *NetmapStatus
- func (NetmapStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x NetmapStatus) Number() protoreflect.EnumNumber
- func (x NetmapStatus) String() string
- func (NetmapStatus) Type() protoreflect.EnumType
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetAddresses() []string
- func (x *NodeInfo) GetAttributes() []*NodeInfo_Attribute
- func (x *NodeInfo) GetPublicKey() []byte
- func (x *NodeInfo) GetState() NetmapStatus
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) SetAddresses(v []string)
- func (x *NodeInfo) SetAttributes(v []*NodeInfo_Attribute)
- func (x *NodeInfo) SetPublicKey(v []byte)
- func (x *NodeInfo) SetState(v NetmapStatus)
- func (x *NodeInfo) StableMarshal(buf []byte) []byte
- func (x *NodeInfo) StableSize() (size int)
- func (x *NodeInfo) String() string
- type NodeInfo_Attribute
- func (*NodeInfo_Attribute) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo_Attribute) GetKey() string
- func (x *NodeInfo_Attribute) GetParents() []string
- func (x *NodeInfo_Attribute) GetValue() string
- func (*NodeInfo_Attribute) ProtoMessage()
- func (x *NodeInfo_Attribute) ProtoReflect() protoreflect.Message
- func (x *NodeInfo_Attribute) Reset()
- func (x *NodeInfo_Attribute) SetKey(v string)
- func (x *NodeInfo_Attribute) SetParents(v []string)
- func (x *NodeInfo_Attribute) SetValue(v string)
- func (x *NodeInfo_Attribute) StableMarshal(buf []byte) []byte
- func (x *NodeInfo_Attribute) StableSize() (size int)
- func (x *NodeInfo_Attribute) String() string
- type RestoreShardRequest
- func (*RestoreShardRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreShardRequest) GetBody() *RestoreShardRequest_Body
- func (x *RestoreShardRequest) GetSignature() *Signature
- func (*RestoreShardRequest) ProtoMessage()
- func (x *RestoreShardRequest) ProtoReflect() protoreflect.Message
- func (x *RestoreShardRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *RestoreShardRequest) Reset()
- func (x *RestoreShardRequest) SetBody(v *RestoreShardRequest_Body)
- func (x *RestoreShardRequest) SetSignature(sig *Signature)
- func (x *RestoreShardRequest) SignedDataSize() int
- func (x *RestoreShardRequest) StableMarshal(buf []byte) []byte
- func (x *RestoreShardRequest) StableSize() (size int)
- func (x *RestoreShardRequest) String() string
- type RestoreShardRequest_Body
- func (*RestoreShardRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreShardRequest_Body) GetFilepath() string
- func (x *RestoreShardRequest_Body) GetIgnoreErrors() bool
- func (x *RestoreShardRequest_Body) GetShard_ID() []byte
- func (*RestoreShardRequest_Body) ProtoMessage()
- func (x *RestoreShardRequest_Body) ProtoReflect() protoreflect.Message
- func (x *RestoreShardRequest_Body) Reset()
- func (x *RestoreShardRequest_Body) SetFilepath(p string)
- func (x *RestoreShardRequest_Body) SetIgnoreErrors(ignore bool)
- func (x *RestoreShardRequest_Body) SetShardID(id []byte)
- func (x *RestoreShardRequest_Body) StableMarshal(buf []byte) []byte
- func (x *RestoreShardRequest_Body) StableSize() (size int)
- func (x *RestoreShardRequest_Body) String() string
- type RestoreShardResponse
- func (*RestoreShardResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreShardResponse) GetBody() *RestoreShardResponse_Body
- func (x *RestoreShardResponse) GetSignature() *Signature
- func (*RestoreShardResponse) ProtoMessage()
- func (x *RestoreShardResponse) ProtoReflect() protoreflect.Message
- func (x *RestoreShardResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *RestoreShardResponse) Reset()
- func (x *RestoreShardResponse) SetBody(v *RestoreShardResponse_Body)
- func (x *RestoreShardResponse) SetSignature(sig *Signature)
- func (x *RestoreShardResponse) SignedDataSize() int
- func (x *RestoreShardResponse) StableMarshal(buf []byte) []byte
- func (x *RestoreShardResponse) StableSize() (size int)
- func (x *RestoreShardResponse) String() string
- type RestoreShardResponse_Body
- func (*RestoreShardResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*RestoreShardResponse_Body) ProtoMessage()
- func (x *RestoreShardResponse_Body) ProtoReflect() protoreflect.Message
- func (x *RestoreShardResponse_Body) Reset()
- func (x *RestoreShardResponse_Body) StableMarshal(buf []byte) []byte
- func (x *RestoreShardResponse_Body) StableSize() (size int)
- func (x *RestoreShardResponse_Body) String() string
- type SetNetmapStatusRequest
- func (*SetNetmapStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetNetmapStatusRequest) GetBody() *SetNetmapStatusRequest_Body
- func (x *SetNetmapStatusRequest) GetSignature() *Signature
- func (*SetNetmapStatusRequest) ProtoMessage()
- func (x *SetNetmapStatusRequest) ProtoReflect() protoreflect.Message
- func (x *SetNetmapStatusRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SetNetmapStatusRequest) Reset()
- func (x *SetNetmapStatusRequest) SetBody(v *SetNetmapStatusRequest_Body)
- func (x *SetNetmapStatusRequest) SetSignature(sig *Signature)
- func (x *SetNetmapStatusRequest) SignedDataSize() int
- func (x *SetNetmapStatusRequest) StableMarshal(buf []byte) []byte
- func (x *SetNetmapStatusRequest) StableSize() (size int)
- func (x *SetNetmapStatusRequest) String() string
- type SetNetmapStatusRequest_Body
- func (*SetNetmapStatusRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *SetNetmapStatusRequest_Body) GetForceMaintenance() bool
- func (x *SetNetmapStatusRequest_Body) GetStatus() NetmapStatus
- func (*SetNetmapStatusRequest_Body) ProtoMessage()
- func (x *SetNetmapStatusRequest_Body) ProtoReflect() protoreflect.Message
- func (x *SetNetmapStatusRequest_Body) Reset()
- func (x *SetNetmapStatusRequest_Body) SetForceMaintenance()
- func (x *SetNetmapStatusRequest_Body) SetStatus(v NetmapStatus)
- func (x *SetNetmapStatusRequest_Body) StableMarshal(buf []byte) []byte
- func (x *SetNetmapStatusRequest_Body) StableSize() (size int)
- func (x *SetNetmapStatusRequest_Body) String() string
- type SetNetmapStatusResponse
- func (*SetNetmapStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetNetmapStatusResponse) GetBody() *SetNetmapStatusResponse_Body
- func (x *SetNetmapStatusResponse) GetSignature() *Signature
- func (*SetNetmapStatusResponse) ProtoMessage()
- func (x *SetNetmapStatusResponse) ProtoReflect() protoreflect.Message
- func (x *SetNetmapStatusResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SetNetmapStatusResponse) Reset()
- func (x *SetNetmapStatusResponse) SetBody(v *SetNetmapStatusResponse_Body)
- func (x *SetNetmapStatusResponse) SetSignature(sig *Signature)
- func (x *SetNetmapStatusResponse) SignedDataSize() int
- func (x *SetNetmapStatusResponse) StableMarshal(buf []byte) []byte
- func (x *SetNetmapStatusResponse) StableSize() (size int)
- func (x *SetNetmapStatusResponse) String() string
- type SetNetmapStatusResponse_Body
- func (*SetNetmapStatusResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*SetNetmapStatusResponse_Body) ProtoMessage()
- func (x *SetNetmapStatusResponse_Body) ProtoReflect() protoreflect.Message
- func (x *SetNetmapStatusResponse_Body) Reset()
- func (x *SetNetmapStatusResponse_Body) StableMarshal(buf []byte) []byte
- func (x *SetNetmapStatusResponse_Body) StableSize() (size int)
- func (x *SetNetmapStatusResponse_Body) String() string
- type SetShardModeRequest
- func (*SetShardModeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetShardModeRequest) GetBody() *SetShardModeRequest_Body
- func (x *SetShardModeRequest) GetSignature() *Signature
- func (*SetShardModeRequest) ProtoMessage()
- func (x *SetShardModeRequest) ProtoReflect() protoreflect.Message
- func (x *SetShardModeRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SetShardModeRequest) Reset()
- func (x *SetShardModeRequest) SetBody(v *SetShardModeRequest_Body)
- func (x *SetShardModeRequest) SetSignature(sig *Signature)
- func (x *SetShardModeRequest) SignedDataSize() int
- func (x *SetShardModeRequest) StableMarshal(buf []byte) []byte
- func (x *SetShardModeRequest) StableSize() (size int)
- func (x *SetShardModeRequest) String() string
- type SetShardModeRequest_Body
- func (x *SetShardModeRequest_Body) ClearErrorCounter(reset bool)
- func (*SetShardModeRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *SetShardModeRequest_Body) GetMode() ShardMode
- func (x *SetShardModeRequest_Body) GetResetErrorCounter() bool
- func (x *SetShardModeRequest_Body) GetShard_ID() [][]byte
- func (*SetShardModeRequest_Body) ProtoMessage()
- func (x *SetShardModeRequest_Body) ProtoReflect() protoreflect.Message
- func (x *SetShardModeRequest_Body) Reset()
- func (x *SetShardModeRequest_Body) SetMode(v ShardMode)
- func (x *SetShardModeRequest_Body) SetShardIDList(v [][]byte)
- func (x *SetShardModeRequest_Body) StableMarshal(buf []byte) []byte
- func (x *SetShardModeRequest_Body) StableSize() (size int)
- func (x *SetShardModeRequest_Body) String() string
- type SetShardModeResponse
- func (*SetShardModeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SetShardModeResponse) GetBody() *SetShardModeResponse_Body
- func (x *SetShardModeResponse) GetSignature() *Signature
- func (*SetShardModeResponse) ProtoMessage()
- func (x *SetShardModeResponse) ProtoReflect() protoreflect.Message
- func (x *SetShardModeResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SetShardModeResponse) Reset()
- func (x *SetShardModeResponse) SetBody(v *SetShardModeResponse_Body)
- func (x *SetShardModeResponse) SetSignature(sig *Signature)
- func (x *SetShardModeResponse) SignedDataSize() int
- func (x *SetShardModeResponse) StableMarshal(buf []byte) []byte
- func (x *SetShardModeResponse) StableSize() (size int)
- func (x *SetShardModeResponse) String() string
- type SetShardModeResponse_Body
- func (*SetShardModeResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*SetShardModeResponse_Body) ProtoMessage()
- func (x *SetShardModeResponse_Body) ProtoReflect() protoreflect.Message
- func (x *SetShardModeResponse_Body) Reset()
- func (x *SetShardModeResponse_Body) StableMarshal(buf []byte) []byte
- func (x *SetShardModeResponse_Body) StableSize() (size int)
- func (x *SetShardModeResponse_Body) String() string
- type ShardInfo
- func (*ShardInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ShardInfo) GetBlobstor() []*BlobstorInfo
- func (x *ShardInfo) GetErrorCount() uint32
- func (x *ShardInfo) GetMetabasePath() string
- func (x *ShardInfo) GetMode() ShardMode
- func (x *ShardInfo) GetPiloramaPath() string
- func (x *ShardInfo) GetShard_ID() []byte
- func (x *ShardInfo) GetWritecachePath() string
- func (*ShardInfo) ProtoMessage()
- func (x *ShardInfo) ProtoReflect() protoreflect.Message
- func (x *ShardInfo) Reset()
- func (x *ShardInfo) SetErrorCount(count uint32)
- func (x *ShardInfo) SetID(v []byte)
- func (x *ShardInfo) SetMetabasePath(v string)
- func (x *ShardInfo) SetMode(v ShardMode)
- func (x *ShardInfo) SetPiloramaPath(v string)
- func (x *ShardInfo) SetWriteCachePath(v string)
- func (x *ShardInfo) StableMarshal(buf []byte) []byte
- func (x *ShardInfo) StableSize() (size int)
- func (x *ShardInfo) String() string
- type ShardMode
- type Signature
- func (*Signature) Descriptor() ([]byte, []int)deprecated
- func (x *Signature) GetKey() []byte
- func (x *Signature) GetSign() []byte
- func (*Signature) ProtoMessage()
- func (x *Signature) ProtoReflect() protoreflect.Message
- func (x *Signature) Reset()
- func (x *Signature) SetKey(v []byte)
- func (x *Signature) SetSign(v []byte)
- func (x *Signature) StableMarshal(buf []byte) []byte
- func (x *Signature) StableSize() (size int)
- func (x *Signature) String() string
- type SynchronizeTreeRequest
- func (*SynchronizeTreeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizeTreeRequest) GetBody() *SynchronizeTreeRequest_Body
- func (x *SynchronizeTreeRequest) GetSignature() *Signature
- func (*SynchronizeTreeRequest) ProtoMessage()
- func (x *SynchronizeTreeRequest) ProtoReflect() protoreflect.Message
- func (x *SynchronizeTreeRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SynchronizeTreeRequest) Reset()
- func (x *SynchronizeTreeRequest) SetBody(v *SynchronizeTreeRequest_Body)
- func (x *SynchronizeTreeRequest) SetSignature(sig *Signature)
- func (x *SynchronizeTreeRequest) SignedDataSize() int
- func (x *SynchronizeTreeRequest) StableMarshal(buf []byte) []byte
- func (x *SynchronizeTreeRequest) StableSize() (size int)
- func (x *SynchronizeTreeRequest) String() string
- type SynchronizeTreeRequest_Body
- func (*SynchronizeTreeRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizeTreeRequest_Body) GetContainerId() []byte
- func (x *SynchronizeTreeRequest_Body) GetHeight() uint64
- func (x *SynchronizeTreeRequest_Body) GetTreeId() string
- func (*SynchronizeTreeRequest_Body) ProtoMessage()
- func (x *SynchronizeTreeRequest_Body) ProtoReflect() protoreflect.Message
- func (x *SynchronizeTreeRequest_Body) Reset()
- func (x *SynchronizeTreeRequest_Body) StableMarshal(buf []byte) []byte
- func (x *SynchronizeTreeRequest_Body) StableSize() (size int)
- func (x *SynchronizeTreeRequest_Body) String() string
- type SynchronizeTreeResponse
- func (*SynchronizeTreeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SynchronizeTreeResponse) GetBody() *SynchronizeTreeResponse_Body
- func (x *SynchronizeTreeResponse) GetSignature() *Signature
- func (*SynchronizeTreeResponse) ProtoMessage()
- func (x *SynchronizeTreeResponse) ProtoReflect() protoreflect.Message
- func (x *SynchronizeTreeResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *SynchronizeTreeResponse) Reset()
- func (x *SynchronizeTreeResponse) SetBody(v *SynchronizeTreeResponse_Body)
- func (x *SynchronizeTreeResponse) SetSignature(sig *Signature)
- func (x *SynchronizeTreeResponse) SignedDataSize() int
- func (x *SynchronizeTreeResponse) StableMarshal(buf []byte) []byte
- func (x *SynchronizeTreeResponse) StableSize() (size int)
- func (x *SynchronizeTreeResponse) String() string
- type SynchronizeTreeResponse_Body
- func (*SynchronizeTreeResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (*SynchronizeTreeResponse_Body) ProtoMessage()
- func (x *SynchronizeTreeResponse_Body) ProtoReflect() protoreflect.Message
- func (x *SynchronizeTreeResponse_Body) Reset()
- func (x *SynchronizeTreeResponse_Body) StableMarshal(buf []byte) []byte
- func (x *SynchronizeTreeResponse_Body) StableSize() (size int)
- func (x *SynchronizeTreeResponse_Body) String() string
- type UnimplementedControlServiceServer
- func (UnimplementedControlServiceServer) DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)
- func (UnimplementedControlServiceServer) DumpShard(context.Context, *DumpShardRequest) (*DumpShardResponse, error)
- func (UnimplementedControlServiceServer) EvacuateShard(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error)
- func (UnimplementedControlServiceServer) FlushCache(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error)
- func (UnimplementedControlServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
- func (UnimplementedControlServiceServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)
- func (UnimplementedControlServiceServer) RestoreShard(context.Context, *RestoreShardRequest) (*RestoreShardResponse, error)
- func (UnimplementedControlServiceServer) SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)
- func (UnimplementedControlServiceServer) SetShardMode(context.Context, *SetShardModeRequest) (*SetShardModeResponse, error)
- func (UnimplementedControlServiceServer) SynchronizeTree(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error)
- type UnsafeControlServiceServer
Constants ¶
const ( ControlService_HealthCheck_FullMethodName = "/control.ControlService/HealthCheck" ControlService_SetNetmapStatus_FullMethodName = "/control.ControlService/SetNetmapStatus" ControlService_DropObjects_FullMethodName = "/control.ControlService/DropObjects" ControlService_ListShards_FullMethodName = "/control.ControlService/ListShards" ControlService_SetShardMode_FullMethodName = "/control.ControlService/SetShardMode" ControlService_DumpShard_FullMethodName = "/control.ControlService/DumpShard" ControlService_RestoreShard_FullMethodName = "/control.ControlService/RestoreShard" ControlService_SynchronizeTree_FullMethodName = "/control.ControlService/SynchronizeTree" ControlService_EvacuateShard_FullMethodName = "/control.ControlService/EvacuateShard" ControlService_FlushCache_FullMethodName = "/control.ControlService/FlushCache" )
Variables ¶
var ( NetmapStatus_name = map[int32]string{ 0: "STATUS_UNDEFINED", 1: "ONLINE", 2: "OFFLINE", 3: "MAINTENANCE", } NetmapStatus_value = map[string]int32{ "STATUS_UNDEFINED": 0, "ONLINE": 1, "OFFLINE": 2, "MAINTENANCE": 3, } )
Enum value maps for NetmapStatus.
var ( HealthStatus_name = map[int32]string{ 0: "HEALTH_STATUS_UNDEFINED", 1: "STARTING", 2: "READY", 3: "SHUTTING_DOWN", } HealthStatus_value = map[string]int32{ "HEALTH_STATUS_UNDEFINED": 0, "STARTING": 1, "READY": 2, "SHUTTING_DOWN": 3, } )
Enum value maps for HealthStatus.
var ( ShardMode_name = map[int32]string{ 0: "SHARD_MODE_UNDEFINED", 1: "READ_WRITE", 2: "READ_ONLY", 3: "DEGRADED", 4: "DEGRADED_READ_ONLY", } ShardMode_value = map[string]int32{ "SHARD_MODE_UNDEFINED": 0, "READ_WRITE": 1, "READ_ONLY": 2, "DEGRADED": 3, "DEGRADED_READ_ONLY": 4, } )
Enum value maps for ShardMode.
var ControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "control.ControlService", HandlerType: (*ControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "HealthCheck", Handler: _ControlService_HealthCheck_Handler, }, { MethodName: "SetNetmapStatus", Handler: _ControlService_SetNetmapStatus_Handler, }, { MethodName: "DropObjects", Handler: _ControlService_DropObjects_Handler, }, { MethodName: "ListShards", Handler: _ControlService_ListShards_Handler, }, { MethodName: "SetShardMode", Handler: _ControlService_SetShardMode_Handler, }, { MethodName: "DumpShard", Handler: _ControlService_DumpShard_Handler, }, { MethodName: "RestoreShard", Handler: _ControlService_RestoreShard_Handler, }, { MethodName: "SynchronizeTree", Handler: _ControlService_SynchronizeTree_Handler, }, { MethodName: "EvacuateShard", Handler: _ControlService_EvacuateShard_Handler, }, { MethodName: "FlushCache", Handler: _ControlService_FlushCache_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/services/control/service.proto", }
ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_services_control_service_proto protoreflect.FileDescriptor
var File_pkg_services_control_types_proto protoreflect.FileDescriptor
Functions ¶
func RegisterControlServiceServer ¶
func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
Types ¶
type BlobstorInfo ¶
type BlobstorInfo struct { // Path to the root. Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Component type. Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // contains filtered or unexported fields }
Blobstor component description.
func (*BlobstorInfo) Descriptor
deprecated
func (*BlobstorInfo) Descriptor() ([]byte, []int)
Deprecated: Use BlobstorInfo.ProtoReflect.Descriptor instead.
func (*BlobstorInfo) GetPath ¶
func (x *BlobstorInfo) GetPath() string
func (*BlobstorInfo) GetType ¶
func (x *BlobstorInfo) GetType() string
func (*BlobstorInfo) ProtoMessage ¶
func (*BlobstorInfo) ProtoMessage()
func (*BlobstorInfo) ProtoReflect ¶
func (x *BlobstorInfo) ProtoReflect() protoreflect.Message
func (*BlobstorInfo) Reset ¶
func (x *BlobstorInfo) Reset()
func (*BlobstorInfo) StableMarshal ¶
func (x *BlobstorInfo) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*BlobstorInfo) StableSize ¶
func (x *BlobstorInfo) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*BlobstorInfo) String ¶
func (x *BlobstorInfo) String() string
type ControlServiceClient ¶
type ControlServiceClient interface { // Performs health check of the storage node. HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) // Sets status of the storage node in NeoFS network map. SetNetmapStatus(ctx context.Context, in *SetNetmapStatusRequest, opts ...grpc.CallOption) (*SetNetmapStatusResponse, error) // Mark objects to be removed from node's local object storage. DropObjects(ctx context.Context, in *DropObjectsRequest, opts ...grpc.CallOption) (*DropObjectsResponse, error) // Returns list that contains information about all shards of a node. ListShards(ctx context.Context, in *ListShardsRequest, opts ...grpc.CallOption) (*ListShardsResponse, error) // Sets mode of the shard. SetShardMode(ctx context.Context, in *SetShardModeRequest, opts ...grpc.CallOption) (*SetShardModeResponse, error) // Dump objects from the shard. DumpShard(ctx context.Context, in *DumpShardRequest, opts ...grpc.CallOption) (*DumpShardResponse, error) // Restore objects from dump. RestoreShard(ctx context.Context, in *RestoreShardRequest, opts ...grpc.CallOption) (*RestoreShardResponse, error) // Synchronizes all log operations for the specified tree. SynchronizeTree(ctx context.Context, in *SynchronizeTreeRequest, opts ...grpc.CallOption) (*SynchronizeTreeResponse, error) // EvacuateShard moves all data from one shard to the others. EvacuateShard(ctx context.Context, in *EvacuateShardRequest, opts ...grpc.CallOption) (*EvacuateShardResponse, error) // FlushCache moves all data from one shard to the others. FlushCache(ctx context.Context, in *FlushCacheRequest, opts ...grpc.CallOption) (*FlushCacheResponse, error) }
ControlServiceClient is the client API for ControlService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewControlServiceClient ¶
func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient
type ControlServiceServer ¶
type ControlServiceServer interface { // Performs health check of the storage node. HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) // Sets status of the storage node in NeoFS network map. SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error) // Mark objects to be removed from node's local object storage. DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error) // Returns list that contains information about all shards of a node. ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error) // Sets mode of the shard. SetShardMode(context.Context, *SetShardModeRequest) (*SetShardModeResponse, error) // Dump objects from the shard. DumpShard(context.Context, *DumpShardRequest) (*DumpShardResponse, error) // Restore objects from dump. RestoreShard(context.Context, *RestoreShardRequest) (*RestoreShardResponse, error) // Synchronizes all log operations for the specified tree. SynchronizeTree(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error) // EvacuateShard moves all data from one shard to the others. EvacuateShard(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error) // FlushCache moves all data from one shard to the others. FlushCache(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error) }
ControlServiceServer is the server API for ControlService service. All implementations should embed UnimplementedControlServiceServer for forward compatibility
type DropObjectsRequest ¶
type DropObjectsRequest struct { // Body of the request message. Body *DropObjectsRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Request to drop the objects.
func (*DropObjectsRequest) Descriptor
deprecated
func (*DropObjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsRequest.ProtoReflect.Descriptor instead.
func (*DropObjectsRequest) GetBody ¶
func (x *DropObjectsRequest) GetBody() *DropObjectsRequest_Body
func (*DropObjectsRequest) GetSignature ¶
func (x *DropObjectsRequest) GetSignature() *Signature
func (*DropObjectsRequest) ProtoMessage ¶
func (*DropObjectsRequest) ProtoMessage()
func (*DropObjectsRequest) ProtoReflect ¶
func (x *DropObjectsRequest) ProtoReflect() protoreflect.Message
func (*DropObjectsRequest) ReadSignedData ¶
func (x *DropObjectsRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*DropObjectsRequest) Reset ¶
func (x *DropObjectsRequest) Reset()
func (*DropObjectsRequest) SetBody ¶
func (x *DropObjectsRequest) SetBody(v *DropObjectsRequest_Body)
SetBody sets body of the set "Drop objects" request.
func (*DropObjectsRequest) SetSignature ¶
func (x *DropObjectsRequest) SetSignature(sig *Signature)
func (*DropObjectsRequest) SignedDataSize ¶
func (x *DropObjectsRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*DropObjectsRequest) StableMarshal ¶
func (x *DropObjectsRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DropObjectsRequest) StableSize ¶
func (x *DropObjectsRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DropObjectsRequest) String ¶
func (x *DropObjectsRequest) String() string
type DropObjectsRequest_Body ¶
type DropObjectsRequest_Body struct { // List of object addresses to be removed. // in NeoFS API binary format. AddressList [][]byte `protobuf:"bytes,1,rep,name=address_list,json=addressList,proto3" json:"address_list,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*DropObjectsRequest_Body) Descriptor
deprecated
func (*DropObjectsRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsRequest_Body.ProtoReflect.Descriptor instead.
func (*DropObjectsRequest_Body) GetAddressList ¶
func (x *DropObjectsRequest_Body) GetAddressList() [][]byte
func (*DropObjectsRequest_Body) ProtoMessage ¶
func (*DropObjectsRequest_Body) ProtoMessage()
func (*DropObjectsRequest_Body) ProtoReflect ¶
func (x *DropObjectsRequest_Body) ProtoReflect() protoreflect.Message
func (*DropObjectsRequest_Body) Reset ¶
func (x *DropObjectsRequest_Body) Reset()
func (*DropObjectsRequest_Body) SetAddressList ¶
func (x *DropObjectsRequest_Body) SetAddressList(v [][]byte)
SetAddressList sets list of objects to be removed in NeoFS API binary format.
func (*DropObjectsRequest_Body) StableMarshal ¶
func (x *DropObjectsRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DropObjectsRequest_Body) StableSize ¶
func (x *DropObjectsRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DropObjectsRequest_Body) String ¶
func (x *DropObjectsRequest_Body) String() string
type DropObjectsResponse ¶
type DropObjectsResponse struct { // Body of the response message. Body *DropObjectsResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Response to request to drop the objects.
func DropObjects ¶
func DropObjects( cli *client.Client, req *DropObjectsRequest, opts ...client.CallOption, ) (*DropObjectsResponse, error)
DropObjects executes ControlService.DropObjects RPC.
func (*DropObjectsResponse) Descriptor
deprecated
func (*DropObjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsResponse.ProtoReflect.Descriptor instead.
func (*DropObjectsResponse) GetBody ¶
func (x *DropObjectsResponse) GetBody() *DropObjectsResponse_Body
func (*DropObjectsResponse) GetSignature ¶
func (x *DropObjectsResponse) GetSignature() *Signature
func (*DropObjectsResponse) ProtoMessage ¶
func (*DropObjectsResponse) ProtoMessage()
func (*DropObjectsResponse) ProtoReflect ¶
func (x *DropObjectsResponse) ProtoReflect() protoreflect.Message
func (*DropObjectsResponse) ReadSignedData ¶
func (x *DropObjectsResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*DropObjectsResponse) Reset ¶
func (x *DropObjectsResponse) Reset()
func (*DropObjectsResponse) SetBody ¶
func (x *DropObjectsResponse) SetBody(v *DropObjectsResponse_Body)
SetBody sets set body of the "Drop objects" response.
func (*DropObjectsResponse) SetSignature ¶
func (x *DropObjectsResponse) SetSignature(sig *Signature)
func (*DropObjectsResponse) SignedDataSize ¶
func (x *DropObjectsResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*DropObjectsResponse) StableMarshal ¶
func (x *DropObjectsResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DropObjectsResponse) StableSize ¶
func (x *DropObjectsResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DropObjectsResponse) String ¶
func (x *DropObjectsResponse) String() string
type DropObjectsResponse_Body ¶
type DropObjectsResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*DropObjectsResponse_Body) Descriptor
deprecated
func (*DropObjectsResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsResponse_Body.ProtoReflect.Descriptor instead.
func (*DropObjectsResponse_Body) ProtoMessage ¶
func (*DropObjectsResponse_Body) ProtoMessage()
func (*DropObjectsResponse_Body) ProtoReflect ¶
func (x *DropObjectsResponse_Body) ProtoReflect() protoreflect.Message
func (*DropObjectsResponse_Body) Reset ¶
func (x *DropObjectsResponse_Body) Reset()
func (*DropObjectsResponse_Body) StableMarshal ¶
func (x *DropObjectsResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DropObjectsResponse_Body) StableSize ¶
func (x *DropObjectsResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DropObjectsResponse_Body) String ¶
func (x *DropObjectsResponse_Body) String() string
type DumpShardRequest ¶
type DumpShardRequest struct { // Body of dump shard request message. Body *DumpShardRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
DumpShard request.
func (*DumpShardRequest) Descriptor
deprecated
func (*DumpShardRequest) Descriptor() ([]byte, []int)
Deprecated: Use DumpShardRequest.ProtoReflect.Descriptor instead.
func (*DumpShardRequest) GetBody ¶
func (x *DumpShardRequest) GetBody() *DumpShardRequest_Body
func (*DumpShardRequest) GetSignature ¶
func (x *DumpShardRequest) GetSignature() *Signature
func (*DumpShardRequest) ProtoMessage ¶
func (*DumpShardRequest) ProtoMessage()
func (*DumpShardRequest) ProtoReflect ¶
func (x *DumpShardRequest) ProtoReflect() protoreflect.Message
func (*DumpShardRequest) ReadSignedData ¶
func (x *DumpShardRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*DumpShardRequest) Reset ¶
func (x *DumpShardRequest) Reset()
func (*DumpShardRequest) SetBody ¶
func (x *DumpShardRequest) SetBody(v *DumpShardRequest_Body)
SetBody sets request body.
func (*DumpShardRequest) SetSignature ¶
func (x *DumpShardRequest) SetSignature(sig *Signature)
func (*DumpShardRequest) SignedDataSize ¶
func (x *DumpShardRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*DumpShardRequest) StableMarshal ¶
func (x *DumpShardRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DumpShardRequest) StableSize ¶
func (x *DumpShardRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DumpShardRequest) String ¶
func (x *DumpShardRequest) String() string
type DumpShardRequest_Body ¶
type DumpShardRequest_Body struct { // ID of the shard. Shard_ID []byte `protobuf:"bytes,1,opt,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // Path to the output. Filepath string `protobuf:"bytes,2,opt,name=filepath,proto3" json:"filepath,omitempty"` // Flag indicating whether object read errors should be ignored. IgnoreErrors bool `protobuf:"varint,3,opt,name=ignore_errors,json=ignoreErrors,proto3" json:"ignore_errors,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*DumpShardRequest_Body) Descriptor
deprecated
func (*DumpShardRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use DumpShardRequest_Body.ProtoReflect.Descriptor instead.
func (*DumpShardRequest_Body) GetFilepath ¶
func (x *DumpShardRequest_Body) GetFilepath() string
func (*DumpShardRequest_Body) GetIgnoreErrors ¶
func (x *DumpShardRequest_Body) GetIgnoreErrors() bool
func (*DumpShardRequest_Body) GetShard_ID ¶
func (x *DumpShardRequest_Body) GetShard_ID() []byte
func (*DumpShardRequest_Body) ProtoMessage ¶
func (*DumpShardRequest_Body) ProtoMessage()
func (*DumpShardRequest_Body) ProtoReflect ¶
func (x *DumpShardRequest_Body) ProtoReflect() protoreflect.Message
func (*DumpShardRequest_Body) Reset ¶
func (x *DumpShardRequest_Body) Reset()
func (*DumpShardRequest_Body) SetFilepath ¶
func (x *DumpShardRequest_Body) SetFilepath(p string)
SetFilepath sets filepath for the dump shard request.
func (*DumpShardRequest_Body) SetIgnoreErrors ¶
func (x *DumpShardRequest_Body) SetIgnoreErrors(ignore bool)
SetIgnoreErrors sets ignore errors flag for the dump shard request.
func (*DumpShardRequest_Body) SetShardID ¶
func (x *DumpShardRequest_Body) SetShardID(id []byte)
SetShardID sets shard ID for the dump shard request.
func (*DumpShardRequest_Body) StableMarshal ¶
func (x *DumpShardRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DumpShardRequest_Body) StableSize ¶
func (x *DumpShardRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DumpShardRequest_Body) String ¶
func (x *DumpShardRequest_Body) String() string
type DumpShardResponse ¶
type DumpShardResponse struct { // Body of dump shard response message. Body *DumpShardResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
DumpShard response.
func DumpShard ¶
func DumpShard(cli *client.Client, req *DumpShardRequest, opts ...client.CallOption) (*DumpShardResponse, error)
DumpShard executes ControlService.DumpShard RPC.
func (*DumpShardResponse) Descriptor
deprecated
func (*DumpShardResponse) Descriptor() ([]byte, []int)
Deprecated: Use DumpShardResponse.ProtoReflect.Descriptor instead.
func (*DumpShardResponse) GetBody ¶
func (x *DumpShardResponse) GetBody() *DumpShardResponse_Body
func (*DumpShardResponse) GetSignature ¶
func (x *DumpShardResponse) GetSignature() *Signature
func (*DumpShardResponse) ProtoMessage ¶
func (*DumpShardResponse) ProtoMessage()
func (*DumpShardResponse) ProtoReflect ¶
func (x *DumpShardResponse) ProtoReflect() protoreflect.Message
func (*DumpShardResponse) ReadSignedData ¶
func (x *DumpShardResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*DumpShardResponse) Reset ¶
func (x *DumpShardResponse) Reset()
func (*DumpShardResponse) SetBody ¶
func (x *DumpShardResponse) SetBody(v *DumpShardResponse_Body)
SetBody sets response body.
func (*DumpShardResponse) SetSignature ¶
func (x *DumpShardResponse) SetSignature(sig *Signature)
func (*DumpShardResponse) SignedDataSize ¶
func (x *DumpShardResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*DumpShardResponse) StableMarshal ¶
func (x *DumpShardResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DumpShardResponse) StableSize ¶
func (x *DumpShardResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DumpShardResponse) String ¶
func (x *DumpShardResponse) String() string
type DumpShardResponse_Body ¶
type DumpShardResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*DumpShardResponse_Body) Descriptor
deprecated
func (*DumpShardResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use DumpShardResponse_Body.ProtoReflect.Descriptor instead.
func (*DumpShardResponse_Body) ProtoMessage ¶
func (*DumpShardResponse_Body) ProtoMessage()
func (*DumpShardResponse_Body) ProtoReflect ¶
func (x *DumpShardResponse_Body) ProtoReflect() protoreflect.Message
func (*DumpShardResponse_Body) Reset ¶
func (x *DumpShardResponse_Body) Reset()
func (*DumpShardResponse_Body) StableMarshal ¶
func (x *DumpShardResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*DumpShardResponse_Body) StableSize ¶
func (x *DumpShardResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*DumpShardResponse_Body) String ¶
func (x *DumpShardResponse_Body) String() string
type EvacuateShardRequest ¶
type EvacuateShardRequest struct { Body *EvacuateShardRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
EvacuateShard request.
func (*EvacuateShardRequest) Descriptor
deprecated
func (*EvacuateShardRequest) Descriptor() ([]byte, []int)
Deprecated: Use EvacuateShardRequest.ProtoReflect.Descriptor instead.
func (*EvacuateShardRequest) GetBody ¶
func (x *EvacuateShardRequest) GetBody() *EvacuateShardRequest_Body
func (*EvacuateShardRequest) GetSignature ¶
func (x *EvacuateShardRequest) GetSignature() *Signature
func (*EvacuateShardRequest) ProtoMessage ¶
func (*EvacuateShardRequest) ProtoMessage()
func (*EvacuateShardRequest) ProtoReflect ¶
func (x *EvacuateShardRequest) ProtoReflect() protoreflect.Message
func (*EvacuateShardRequest) ReadSignedData ¶
func (x *EvacuateShardRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*EvacuateShardRequest) Reset ¶
func (x *EvacuateShardRequest) Reset()
func (*EvacuateShardRequest) SetSignature ¶
func (x *EvacuateShardRequest) SetSignature(sig *Signature)
func (*EvacuateShardRequest) SignedDataSize ¶
func (x *EvacuateShardRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*EvacuateShardRequest) StableMarshal ¶
func (x *EvacuateShardRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*EvacuateShardRequest) StableSize ¶
func (x *EvacuateShardRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*EvacuateShardRequest) String ¶
func (x *EvacuateShardRequest) String() string
type EvacuateShardRequest_Body ¶
type EvacuateShardRequest_Body struct { // ID of the shard. Shard_ID [][]byte `protobuf:"bytes,1,rep,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // Flag indicating whether object read errors should be ignored. IgnoreErrors bool `protobuf:"varint,2,opt,name=ignore_errors,json=ignoreErrors,proto3" json:"ignore_errors,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*EvacuateShardRequest_Body) Descriptor
deprecated
func (*EvacuateShardRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use EvacuateShardRequest_Body.ProtoReflect.Descriptor instead.
func (*EvacuateShardRequest_Body) GetIgnoreErrors ¶
func (x *EvacuateShardRequest_Body) GetIgnoreErrors() bool
func (*EvacuateShardRequest_Body) GetShard_ID ¶
func (x *EvacuateShardRequest_Body) GetShard_ID() [][]byte
func (*EvacuateShardRequest_Body) ProtoMessage ¶
func (*EvacuateShardRequest_Body) ProtoMessage()
func (*EvacuateShardRequest_Body) ProtoReflect ¶
func (x *EvacuateShardRequest_Body) ProtoReflect() protoreflect.Message
func (*EvacuateShardRequest_Body) Reset ¶
func (x *EvacuateShardRequest_Body) Reset()
func (*EvacuateShardRequest_Body) StableMarshal ¶
func (x *EvacuateShardRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*EvacuateShardRequest_Body) StableSize ¶
func (x *EvacuateShardRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*EvacuateShardRequest_Body) String ¶
func (x *EvacuateShardRequest_Body) String() string
type EvacuateShardResponse ¶
type EvacuateShardResponse struct { Body *EvacuateShardResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
EvacuateShard response.
func EvacuateShard ¶
func EvacuateShard(cli *client.Client, req *EvacuateShardRequest, opts ...client.CallOption) (*EvacuateShardResponse, error)
EvacuateShard executes ControlService.EvacuateShard RPC.
func (*EvacuateShardResponse) Descriptor
deprecated
func (*EvacuateShardResponse) Descriptor() ([]byte, []int)
Deprecated: Use EvacuateShardResponse.ProtoReflect.Descriptor instead.
func (*EvacuateShardResponse) GetBody ¶
func (x *EvacuateShardResponse) GetBody() *EvacuateShardResponse_Body
func (*EvacuateShardResponse) GetSignature ¶
func (x *EvacuateShardResponse) GetSignature() *Signature
func (*EvacuateShardResponse) ProtoMessage ¶
func (*EvacuateShardResponse) ProtoMessage()
func (*EvacuateShardResponse) ProtoReflect ¶
func (x *EvacuateShardResponse) ProtoReflect() protoreflect.Message
func (*EvacuateShardResponse) ReadSignedData ¶
func (x *EvacuateShardResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*EvacuateShardResponse) Reset ¶
func (x *EvacuateShardResponse) Reset()
func (*EvacuateShardResponse) SetSignature ¶
func (x *EvacuateShardResponse) SetSignature(sig *Signature)
func (*EvacuateShardResponse) SignedDataSize ¶
func (x *EvacuateShardResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*EvacuateShardResponse) StableMarshal ¶
func (x *EvacuateShardResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*EvacuateShardResponse) StableSize ¶
func (x *EvacuateShardResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*EvacuateShardResponse) String ¶
func (x *EvacuateShardResponse) String() string
type EvacuateShardResponse_Body ¶
type EvacuateShardResponse_Body struct { Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
Response body structure.
func (*EvacuateShardResponse_Body) Descriptor
deprecated
func (*EvacuateShardResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use EvacuateShardResponse_Body.ProtoReflect.Descriptor instead.
func (*EvacuateShardResponse_Body) GetCount ¶
func (x *EvacuateShardResponse_Body) GetCount() uint32
func (*EvacuateShardResponse_Body) ProtoMessage ¶
func (*EvacuateShardResponse_Body) ProtoMessage()
func (*EvacuateShardResponse_Body) ProtoReflect ¶
func (x *EvacuateShardResponse_Body) ProtoReflect() protoreflect.Message
func (*EvacuateShardResponse_Body) Reset ¶
func (x *EvacuateShardResponse_Body) Reset()
func (*EvacuateShardResponse_Body) StableMarshal ¶
func (x *EvacuateShardResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*EvacuateShardResponse_Body) StableSize ¶
func (x *EvacuateShardResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*EvacuateShardResponse_Body) String ¶
func (x *EvacuateShardResponse_Body) String() string
type FlushCacheRequest ¶
type FlushCacheRequest struct { Body *FlushCacheRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
FlushCache request.
func (*FlushCacheRequest) Descriptor
deprecated
func (*FlushCacheRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlushCacheRequest.ProtoReflect.Descriptor instead.
func (*FlushCacheRequest) GetBody ¶
func (x *FlushCacheRequest) GetBody() *FlushCacheRequest_Body
func (*FlushCacheRequest) GetSignature ¶
func (x *FlushCacheRequest) GetSignature() *Signature
func (*FlushCacheRequest) ProtoMessage ¶
func (*FlushCacheRequest) ProtoMessage()
func (*FlushCacheRequest) ProtoReflect ¶
func (x *FlushCacheRequest) ProtoReflect() protoreflect.Message
func (*FlushCacheRequest) ReadSignedData ¶
func (x *FlushCacheRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*FlushCacheRequest) Reset ¶
func (x *FlushCacheRequest) Reset()
func (*FlushCacheRequest) SetSignature ¶
func (x *FlushCacheRequest) SetSignature(sig *Signature)
func (*FlushCacheRequest) SignedDataSize ¶
func (x *FlushCacheRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*FlushCacheRequest) StableMarshal ¶
func (x *FlushCacheRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*FlushCacheRequest) StableSize ¶
func (x *FlushCacheRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*FlushCacheRequest) String ¶
func (x *FlushCacheRequest) String() string
type FlushCacheRequest_Body ¶
type FlushCacheRequest_Body struct { // ID of the shard. Shard_ID [][]byte `protobuf:"bytes,1,rep,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*FlushCacheRequest_Body) Descriptor
deprecated
func (*FlushCacheRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use FlushCacheRequest_Body.ProtoReflect.Descriptor instead.
func (*FlushCacheRequest_Body) GetShard_ID ¶
func (x *FlushCacheRequest_Body) GetShard_ID() [][]byte
func (*FlushCacheRequest_Body) ProtoMessage ¶
func (*FlushCacheRequest_Body) ProtoMessage()
func (*FlushCacheRequest_Body) ProtoReflect ¶
func (x *FlushCacheRequest_Body) ProtoReflect() protoreflect.Message
func (*FlushCacheRequest_Body) Reset ¶
func (x *FlushCacheRequest_Body) Reset()
func (*FlushCacheRequest_Body) StableMarshal ¶
func (x *FlushCacheRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*FlushCacheRequest_Body) StableSize ¶
func (x *FlushCacheRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*FlushCacheRequest_Body) String ¶
func (x *FlushCacheRequest_Body) String() string
type FlushCacheResponse ¶
type FlushCacheResponse struct { Body *FlushCacheResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
FlushCache response.
func FlushCache ¶
func FlushCache(cli *client.Client, req *FlushCacheRequest, opts ...client.CallOption) (*FlushCacheResponse, error)
FlushCache executes ControlService.FlushCache RPC.
func (*FlushCacheResponse) Descriptor
deprecated
func (*FlushCacheResponse) Descriptor() ([]byte, []int)
Deprecated: Use FlushCacheResponse.ProtoReflect.Descriptor instead.
func (*FlushCacheResponse) GetBody ¶
func (x *FlushCacheResponse) GetBody() *FlushCacheResponse_Body
func (*FlushCacheResponse) GetSignature ¶
func (x *FlushCacheResponse) GetSignature() *Signature
func (*FlushCacheResponse) ProtoMessage ¶
func (*FlushCacheResponse) ProtoMessage()
func (*FlushCacheResponse) ProtoReflect ¶
func (x *FlushCacheResponse) ProtoReflect() protoreflect.Message
func (*FlushCacheResponse) ReadSignedData ¶
func (x *FlushCacheResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*FlushCacheResponse) Reset ¶
func (x *FlushCacheResponse) Reset()
func (*FlushCacheResponse) SetSignature ¶
func (x *FlushCacheResponse) SetSignature(sig *Signature)
func (*FlushCacheResponse) SignedDataSize ¶
func (x *FlushCacheResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*FlushCacheResponse) StableMarshal ¶
func (x *FlushCacheResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*FlushCacheResponse) StableSize ¶
func (x *FlushCacheResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*FlushCacheResponse) String ¶
func (x *FlushCacheResponse) String() string
type FlushCacheResponse_Body ¶
type FlushCacheResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*FlushCacheResponse_Body) Descriptor
deprecated
func (*FlushCacheResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use FlushCacheResponse_Body.ProtoReflect.Descriptor instead.
func (*FlushCacheResponse_Body) ProtoMessage ¶
func (*FlushCacheResponse_Body) ProtoMessage()
func (*FlushCacheResponse_Body) ProtoReflect ¶
func (x *FlushCacheResponse_Body) ProtoReflect() protoreflect.Message
func (*FlushCacheResponse_Body) Reset ¶
func (x *FlushCacheResponse_Body) Reset()
func (*FlushCacheResponse_Body) StableMarshal ¶
func (x *FlushCacheResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*FlushCacheResponse_Body) StableSize ¶
func (x *FlushCacheResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*FlushCacheResponse_Body) String ¶
func (x *FlushCacheResponse_Body) String() string
type HealthCheckRequest ¶
type HealthCheckRequest struct { // Body of health check request message. Body *HealthCheckRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Health check request.
func (*HealthCheckRequest) Descriptor
deprecated
func (*HealthCheckRequest) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest) GetBody ¶
func (x *HealthCheckRequest) GetBody() *HealthCheckRequest_Body
func (*HealthCheckRequest) GetSignature ¶
func (x *HealthCheckRequest) GetSignature() *Signature
func (*HealthCheckRequest) ProtoMessage ¶
func (*HealthCheckRequest) ProtoMessage()
func (*HealthCheckRequest) ProtoReflect ¶
func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest) ReadSignedData ¶
func (x *HealthCheckRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*HealthCheckRequest) Reset ¶
func (x *HealthCheckRequest) Reset()
func (*HealthCheckRequest) SetBody ¶
func (x *HealthCheckRequest) SetBody(v *HealthCheckRequest_Body)
SetBody sets health check request body.
func (*HealthCheckRequest) SetSignature ¶
func (x *HealthCheckRequest) SetSignature(sig *Signature)
func (*HealthCheckRequest) SignedDataSize ¶
func (x *HealthCheckRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*HealthCheckRequest) StableMarshal ¶
func (x *HealthCheckRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*HealthCheckRequest) StableSize ¶
func (x *HealthCheckRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*HealthCheckRequest) String ¶
func (x *HealthCheckRequest) String() string
type HealthCheckRequest_Body ¶
type HealthCheckRequest_Body struct {
// contains filtered or unexported fields
}
Health check request body.
func (*HealthCheckRequest_Body) Descriptor
deprecated
func (*HealthCheckRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckRequest_Body.ProtoReflect.Descriptor instead.
func (*HealthCheckRequest_Body) ProtoMessage ¶
func (*HealthCheckRequest_Body) ProtoMessage()
func (*HealthCheckRequest_Body) ProtoReflect ¶
func (x *HealthCheckRequest_Body) ProtoReflect() protoreflect.Message
func (*HealthCheckRequest_Body) Reset ¶
func (x *HealthCheckRequest_Body) Reset()
func (*HealthCheckRequest_Body) StableMarshal ¶
func (x *HealthCheckRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*HealthCheckRequest_Body) StableSize ¶
func (x *HealthCheckRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*HealthCheckRequest_Body) String ¶
func (x *HealthCheckRequest_Body) String() string
type HealthCheckResponse ¶
type HealthCheckResponse struct { // Body of health check response message. Body *HealthCheckResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Health check request.
func HealthCheck ¶
func HealthCheck( cli *client.Client, req *HealthCheckRequest, opts ...client.CallOption, ) (*HealthCheckResponse, error)
HealthCheck executes ControlService.HealthCheck RPC.
func (*HealthCheckResponse) Descriptor
deprecated
func (*HealthCheckResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse.ProtoReflect.Descriptor instead.
func (*HealthCheckResponse) GetBody ¶
func (x *HealthCheckResponse) GetBody() *HealthCheckResponse_Body
func (*HealthCheckResponse) GetSignature ¶
func (x *HealthCheckResponse) GetSignature() *Signature
func (*HealthCheckResponse) ProtoMessage ¶
func (*HealthCheckResponse) ProtoMessage()
func (*HealthCheckResponse) ProtoReflect ¶
func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message
func (*HealthCheckResponse) ReadSignedData ¶
func (x *HealthCheckResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*HealthCheckResponse) Reset ¶
func (x *HealthCheckResponse) Reset()
func (*HealthCheckResponse) SetBody ¶
func (x *HealthCheckResponse) SetBody(v *HealthCheckResponse_Body)
SetBody sets health check response body.
func (*HealthCheckResponse) SetSignature ¶
func (x *HealthCheckResponse) SetSignature(sig *Signature)
func (*HealthCheckResponse) SignedDataSize ¶
func (x *HealthCheckResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*HealthCheckResponse) StableMarshal ¶
func (x *HealthCheckResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*HealthCheckResponse) StableSize ¶
func (x *HealthCheckResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*HealthCheckResponse) String ¶
func (x *HealthCheckResponse) String() string
type HealthCheckResponse_Body ¶
type HealthCheckResponse_Body struct { // Status of the storage node in NeoFS network map. NetmapStatus NetmapStatus `protobuf:"varint,1,opt,name=netmap_status,json=netmapStatus,proto3,enum=control.NetmapStatus" json:"netmap_status,omitempty"` // Health status of storage node application. HealthStatus HealthStatus `protobuf:"varint,2,opt,name=health_status,json=healthStatus,proto3,enum=control.HealthStatus" json:"health_status,omitempty"` // contains filtered or unexported fields }
Health check response body
func (*HealthCheckResponse_Body) Descriptor
deprecated
func (*HealthCheckResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use HealthCheckResponse_Body.ProtoReflect.Descriptor instead.
func (*HealthCheckResponse_Body) GetHealthStatus ¶
func (x *HealthCheckResponse_Body) GetHealthStatus() HealthStatus
func (*HealthCheckResponse_Body) GetNetmapStatus ¶
func (x *HealthCheckResponse_Body) GetNetmapStatus() NetmapStatus
func (*HealthCheckResponse_Body) ProtoMessage ¶
func (*HealthCheckResponse_Body) ProtoMessage()
func (*HealthCheckResponse_Body) ProtoReflect ¶
func (x *HealthCheckResponse_Body) ProtoReflect() protoreflect.Message
func (*HealthCheckResponse_Body) Reset ¶
func (x *HealthCheckResponse_Body) Reset()
func (*HealthCheckResponse_Body) SetHealthStatus ¶
func (x *HealthCheckResponse_Body) SetHealthStatus(v HealthStatus)
SetHealthStatus sets health status of the storage node application.
func (*HealthCheckResponse_Body) SetNetmapStatus ¶
func (x *HealthCheckResponse_Body) SetNetmapStatus(v NetmapStatus)
SetNetmapStatus sets status of the storage node in NeoFS network map.
func (*HealthCheckResponse_Body) StableMarshal ¶
func (x *HealthCheckResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*HealthCheckResponse_Body) StableSize ¶
func (x *HealthCheckResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*HealthCheckResponse_Body) String ¶
func (x *HealthCheckResponse_Body) String() string
type HealthStatus ¶
type HealthStatus int32
Health status of the storage node application.
const ( // Undefined status, default value. HealthStatus_HEALTH_STATUS_UNDEFINED HealthStatus = 0 // Storage node application is starting. HealthStatus_STARTING HealthStatus = 1 // Storage node application is started and serves all services. HealthStatus_READY HealthStatus = 2 // Storage node application is shutting down. HealthStatus_SHUTTING_DOWN HealthStatus = 3 )
func (HealthStatus) Descriptor ¶
func (HealthStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthStatus) Enum ¶
func (x HealthStatus) Enum() *HealthStatus
func (HealthStatus) EnumDescriptor
deprecated
func (HealthStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthStatus.Descriptor instead.
func (HealthStatus) Number ¶
func (x HealthStatus) Number() protoreflect.EnumNumber
func (HealthStatus) String ¶
func (x HealthStatus) String() string
func (HealthStatus) Type ¶
func (HealthStatus) Type() protoreflect.EnumType
type ListShardsRequest ¶
type ListShardsRequest struct { // Body of the request message. Body *ListShardsRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Request to list all shards of the node.
func (*ListShardsRequest) Descriptor
deprecated
func (*ListShardsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListShardsRequest.ProtoReflect.Descriptor instead.
func (*ListShardsRequest) GetBody ¶
func (x *ListShardsRequest) GetBody() *ListShardsRequest_Body
func (*ListShardsRequest) GetSignature ¶
func (x *ListShardsRequest) GetSignature() *Signature
func (*ListShardsRequest) ProtoMessage ¶
func (*ListShardsRequest) ProtoMessage()
func (*ListShardsRequest) ProtoReflect ¶
func (x *ListShardsRequest) ProtoReflect() protoreflect.Message
func (*ListShardsRequest) ReadSignedData ¶
func (x *ListShardsRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*ListShardsRequest) Reset ¶
func (x *ListShardsRequest) Reset()
func (*ListShardsRequest) SetBody ¶
func (x *ListShardsRequest) SetBody(v *ListShardsRequest_Body)
SetBody sets list shards request body.
func (*ListShardsRequest) SetSignature ¶
func (x *ListShardsRequest) SetSignature(sig *Signature)
func (*ListShardsRequest) SignedDataSize ¶
func (x *ListShardsRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*ListShardsRequest) StableMarshal ¶
func (x *ListShardsRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*ListShardsRequest) StableSize ¶
func (x *ListShardsRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*ListShardsRequest) String ¶
func (x *ListShardsRequest) String() string
type ListShardsRequest_Body ¶
type ListShardsRequest_Body struct {
// contains filtered or unexported fields
}
Request body structure.
func (*ListShardsRequest_Body) Descriptor
deprecated
func (*ListShardsRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use ListShardsRequest_Body.ProtoReflect.Descriptor instead.
func (*ListShardsRequest_Body) ProtoMessage ¶
func (*ListShardsRequest_Body) ProtoMessage()
func (*ListShardsRequest_Body) ProtoReflect ¶
func (x *ListShardsRequest_Body) ProtoReflect() protoreflect.Message
func (*ListShardsRequest_Body) Reset ¶
func (x *ListShardsRequest_Body) Reset()
func (*ListShardsRequest_Body) StableMarshal ¶
func (x *ListShardsRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*ListShardsRequest_Body) StableSize ¶
func (x *ListShardsRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*ListShardsRequest_Body) String ¶
func (x *ListShardsRequest_Body) String() string
type ListShardsResponse ¶
type ListShardsResponse struct { // Body of the response message. Body *ListShardsResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
ListShards response.
func ListShards ¶
func ListShards( cli *client.Client, req *ListShardsRequest, opts ...client.CallOption, ) (*ListShardsResponse, error)
ListShards executes ControlService.ListShards RPC.
func (*ListShardsResponse) Descriptor
deprecated
func (*ListShardsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListShardsResponse.ProtoReflect.Descriptor instead.
func (*ListShardsResponse) GetBody ¶
func (x *ListShardsResponse) GetBody() *ListShardsResponse_Body
func (*ListShardsResponse) GetSignature ¶
func (x *ListShardsResponse) GetSignature() *Signature
func (*ListShardsResponse) ProtoMessage ¶
func (*ListShardsResponse) ProtoMessage()
func (*ListShardsResponse) ProtoReflect ¶
func (x *ListShardsResponse) ProtoReflect() protoreflect.Message
func (*ListShardsResponse) ReadSignedData ¶
func (x *ListShardsResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*ListShardsResponse) Reset ¶
func (x *ListShardsResponse) Reset()
func (*ListShardsResponse) SetBody ¶
func (x *ListShardsResponse) SetBody(v *ListShardsResponse_Body)
SetBody sets list shards response body.
func (*ListShardsResponse) SetSignature ¶
func (x *ListShardsResponse) SetSignature(sig *Signature)
func (*ListShardsResponse) SignedDataSize ¶
func (x *ListShardsResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*ListShardsResponse) StableMarshal ¶
func (x *ListShardsResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*ListShardsResponse) StableSize ¶
func (x *ListShardsResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*ListShardsResponse) String ¶
func (x *ListShardsResponse) String() string
type ListShardsResponse_Body ¶
type ListShardsResponse_Body struct { // List of the node's shards. Shards []*ShardInfo `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
Response body structure.
func (*ListShardsResponse_Body) Descriptor
deprecated
func (*ListShardsResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use ListShardsResponse_Body.ProtoReflect.Descriptor instead.
func (*ListShardsResponse_Body) GetShards ¶
func (x *ListShardsResponse_Body) GetShards() []*ShardInfo
func (*ListShardsResponse_Body) ProtoMessage ¶
func (*ListShardsResponse_Body) ProtoMessage()
func (*ListShardsResponse_Body) ProtoReflect ¶
func (x *ListShardsResponse_Body) ProtoReflect() protoreflect.Message
func (*ListShardsResponse_Body) Reset ¶
func (x *ListShardsResponse_Body) Reset()
func (*ListShardsResponse_Body) SetShards ¶
func (x *ListShardsResponse_Body) SetShards(v []*ShardInfo)
SetShards sets shards of the storage node.
func (*ListShardsResponse_Body) StableMarshal ¶
func (x *ListShardsResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*ListShardsResponse_Body) StableSize ¶
func (x *ListShardsResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*ListShardsResponse_Body) String ¶
func (x *ListShardsResponse_Body) String() string
type Netmap ¶
type Netmap struct { // Network map revision number. Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // Nodes presented in network. Nodes []*NodeInfo `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"` // contains filtered or unexported fields }
Network map structure.
func (*Netmap) Descriptor
deprecated
func (*Netmap) MarshalJSON ¶
func (*Netmap) ProtoMessage ¶
func (*Netmap) ProtoMessage()
func (*Netmap) ProtoReflect ¶
func (x *Netmap) ProtoReflect() protoreflect.Message
func (*Netmap) StableMarshal ¶
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*Netmap) StableSize ¶
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
type NetmapStatus ¶
type NetmapStatus int32
Status of the storage node in the NeoFS network map.
const ( // Undefined status, default value. NetmapStatus_STATUS_UNDEFINED NetmapStatus = 0 // Node is online. NetmapStatus_ONLINE NetmapStatus = 1 // Node is offline. NetmapStatus_OFFLINE NetmapStatus = 2 // Node is maintained by the owner. NetmapStatus_MAINTENANCE NetmapStatus = 3 )
func (NetmapStatus) Descriptor ¶
func (NetmapStatus) Descriptor() protoreflect.EnumDescriptor
func (NetmapStatus) Enum ¶
func (x NetmapStatus) Enum() *NetmapStatus
func (NetmapStatus) EnumDescriptor
deprecated
func (NetmapStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use NetmapStatus.Descriptor instead.
func (NetmapStatus) Number ¶
func (x NetmapStatus) Number() protoreflect.EnumNumber
func (NetmapStatus) String ¶
func (x NetmapStatus) String() string
func (NetmapStatus) Type ¶
func (NetmapStatus) Type() protoreflect.EnumType
type NodeInfo ¶
type NodeInfo struct { // Public key of the NeoFS node in a binary format. PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"` // Ways to connect to a node. Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"` // Carries list of the NeoFS node attributes in a key-value form. Key name // must be a node-unique valid UTF-8 string. Value can't be empty. NodeInfo // structures with duplicated attribute names or attributes with empty values // will be considered invalid. Attributes []*NodeInfo_Attribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"` // Carries state of the NeoFS node. State NetmapStatus `protobuf:"varint,4,opt,name=state,proto3,enum=control.NetmapStatus" json:"state,omitempty"` // contains filtered or unexported fields }
NeoFS node description.
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetAddresses ¶
func (*NodeInfo) GetAttributes ¶
func (x *NodeInfo) GetAttributes() []*NodeInfo_Attribute
func (*NodeInfo) GetPublicKey ¶
func (*NodeInfo) GetState ¶
func (x *NodeInfo) GetState() NetmapStatus
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
func (*NodeInfo) SetAddresses ¶
SetAddresses sets ways to connect to a node.
func (*NodeInfo) SetAttributes ¶
func (x *NodeInfo) SetAttributes(v []*NodeInfo_Attribute)
SetAttributes sets attributes of the NeoFS Storage Node.
func (*NodeInfo) SetPublicKey ¶
SetPublicKey sets public key of the NeoFS node in a binary format.
func (*NodeInfo) SetState ¶
func (x *NodeInfo) SetState(v NetmapStatus)
SetState sets state of the NeoFS node.
func (*NodeInfo) StableMarshal ¶
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*NodeInfo) StableSize ¶
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
type NodeInfo_Attribute ¶
type NodeInfo_Attribute struct { // Key of the node attribute. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Value of the node attribute. Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // Parent keys, if any. For example for `City` it could be `Region` and // `Country`. Parents []string `protobuf:"bytes,3,rep,name=parents,proto3" json:"parents,omitempty"` // contains filtered or unexported fields }
Administrator-defined Attributes of the NeoFS Storage Node.
`Attribute` is a Key-Value metadata pair. Key name must be a valid UTF-8 string. Value can't be empty.
Node's attributes are mostly used during Storage Policy evaluation to calculate object's placement and find a set of nodes satisfying policy requirements. There are some "well-known" node attributes common to all the Storage Nodes in the network and used implicitly with default values if not explicitly set:
- Capacity \ Total available disk space in Gigabytes.
- Price \ Price in GAS tokens for storing one GB of data during one Epoch. In node attributes it's a string presenting floating point number with comma or point delimiter for decimal part. In the Network Map it will be saved as 64-bit unsigned integer representing number of minimal token fractions.
- Locode \ Node's geographic location in UN/LOCODE(https://www.unece.org/cefact/codesfortrade/codes_index.html) format approximated to the nearest point defined in standard.
- Country \ Country code in [ISO 3166-1_alpha-2](https://en.wikipedia.org/wiki/ISO_3166-1_alpha-2) format. Calculated automatically from `Locode` attribute
- Region \ Country's administative subdivision where node is located. Calculated automatically from `Locode` attribute based on `SubDiv` field. Presented in [ISO 3166-2](https://en.wikipedia.org/wiki/ISO_3166-2) format.
- City \ City, town, village or rural area name where node is located written without diacritics . Calculated automatically from `Locode` attribute.
For detailed description of each well-known attribute please see the corresponding section in NeoFS Technical specification.
func (*NodeInfo_Attribute) Descriptor
deprecated
func (*NodeInfo_Attribute) Descriptor() ([]byte, []int)
Deprecated: Use NodeInfo_Attribute.ProtoReflect.Descriptor instead.
func (*NodeInfo_Attribute) GetKey ¶
func (x *NodeInfo_Attribute) GetKey() string
func (*NodeInfo_Attribute) GetParents ¶
func (x *NodeInfo_Attribute) GetParents() []string
func (*NodeInfo_Attribute) GetValue ¶
func (x *NodeInfo_Attribute) GetValue() string
func (*NodeInfo_Attribute) ProtoMessage ¶
func (*NodeInfo_Attribute) ProtoMessage()
func (*NodeInfo_Attribute) ProtoReflect ¶
func (x *NodeInfo_Attribute) ProtoReflect() protoreflect.Message
func (*NodeInfo_Attribute) Reset ¶
func (x *NodeInfo_Attribute) Reset()
func (*NodeInfo_Attribute) SetKey ¶
func (x *NodeInfo_Attribute) SetKey(v string)
SetKey sets key of the node attribute.
func (*NodeInfo_Attribute) SetParents ¶
func (x *NodeInfo_Attribute) SetParents(v []string)
SetParents sets parent keys.
func (*NodeInfo_Attribute) SetValue ¶
func (x *NodeInfo_Attribute) SetValue(v string)
SetValue sets value of the node attribute.
func (*NodeInfo_Attribute) StableMarshal ¶
func (x *NodeInfo_Attribute) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*NodeInfo_Attribute) StableSize ¶
func (x *NodeInfo_Attribute) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*NodeInfo_Attribute) String ¶
func (x *NodeInfo_Attribute) String() string
type RestoreShardRequest ¶
type RestoreShardRequest struct { // Body of restore shard request message. Body *RestoreShardRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
RestoreShard request.
func (*RestoreShardRequest) Descriptor
deprecated
func (*RestoreShardRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestoreShardRequest.ProtoReflect.Descriptor instead.
func (*RestoreShardRequest) GetBody ¶
func (x *RestoreShardRequest) GetBody() *RestoreShardRequest_Body
func (*RestoreShardRequest) GetSignature ¶
func (x *RestoreShardRequest) GetSignature() *Signature
func (*RestoreShardRequest) ProtoMessage ¶
func (*RestoreShardRequest) ProtoMessage()
func (*RestoreShardRequest) ProtoReflect ¶
func (x *RestoreShardRequest) ProtoReflect() protoreflect.Message
func (*RestoreShardRequest) ReadSignedData ¶
func (x *RestoreShardRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*RestoreShardRequest) Reset ¶
func (x *RestoreShardRequest) Reset()
func (*RestoreShardRequest) SetBody ¶
func (x *RestoreShardRequest) SetBody(v *RestoreShardRequest_Body)
SetBody sets request body.
func (*RestoreShardRequest) SetSignature ¶
func (x *RestoreShardRequest) SetSignature(sig *Signature)
func (*RestoreShardRequest) SignedDataSize ¶
func (x *RestoreShardRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*RestoreShardRequest) StableMarshal ¶
func (x *RestoreShardRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*RestoreShardRequest) StableSize ¶
func (x *RestoreShardRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*RestoreShardRequest) String ¶
func (x *RestoreShardRequest) String() string
type RestoreShardRequest_Body ¶
type RestoreShardRequest_Body struct { // ID of the shard. Shard_ID []byte `protobuf:"bytes,1,opt,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // Path to the output. Filepath string `protobuf:"bytes,2,opt,name=filepath,proto3" json:"filepath,omitempty"` // Flag indicating whether object read errors should be ignored. IgnoreErrors bool `protobuf:"varint,3,opt,name=ignore_errors,json=ignoreErrors,proto3" json:"ignore_errors,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*RestoreShardRequest_Body) Descriptor
deprecated
func (*RestoreShardRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use RestoreShardRequest_Body.ProtoReflect.Descriptor instead.
func (*RestoreShardRequest_Body) GetFilepath ¶
func (x *RestoreShardRequest_Body) GetFilepath() string
func (*RestoreShardRequest_Body) GetIgnoreErrors ¶
func (x *RestoreShardRequest_Body) GetIgnoreErrors() bool
func (*RestoreShardRequest_Body) GetShard_ID ¶
func (x *RestoreShardRequest_Body) GetShard_ID() []byte
func (*RestoreShardRequest_Body) ProtoMessage ¶
func (*RestoreShardRequest_Body) ProtoMessage()
func (*RestoreShardRequest_Body) ProtoReflect ¶
func (x *RestoreShardRequest_Body) ProtoReflect() protoreflect.Message
func (*RestoreShardRequest_Body) Reset ¶
func (x *RestoreShardRequest_Body) Reset()
func (*RestoreShardRequest_Body) SetFilepath ¶
func (x *RestoreShardRequest_Body) SetFilepath(p string)
SetFilepath sets filepath for the restore shard request.
func (*RestoreShardRequest_Body) SetIgnoreErrors ¶
func (x *RestoreShardRequest_Body) SetIgnoreErrors(ignore bool)
SetIgnoreErrors sets ignore errors flag for the restore shard request.
func (*RestoreShardRequest_Body) SetShardID ¶
func (x *RestoreShardRequest_Body) SetShardID(id []byte)
SetShardID sets shard ID for the restore shard request.
func (*RestoreShardRequest_Body) StableMarshal ¶
func (x *RestoreShardRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*RestoreShardRequest_Body) StableSize ¶
func (x *RestoreShardRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*RestoreShardRequest_Body) String ¶
func (x *RestoreShardRequest_Body) String() string
type RestoreShardResponse ¶
type RestoreShardResponse struct { // Body of restore shard response message. Body *RestoreShardResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
RestoreShard response.
func RestoreShard ¶
func RestoreShard(cli *client.Client, req *RestoreShardRequest, opts ...client.CallOption) (*RestoreShardResponse, error)
RestoreShard executes ControlService.DumpShard RPC.
func (*RestoreShardResponse) Descriptor
deprecated
func (*RestoreShardResponse) Descriptor() ([]byte, []int)
Deprecated: Use RestoreShardResponse.ProtoReflect.Descriptor instead.
func (*RestoreShardResponse) GetBody ¶
func (x *RestoreShardResponse) GetBody() *RestoreShardResponse_Body
func (*RestoreShardResponse) GetSignature ¶
func (x *RestoreShardResponse) GetSignature() *Signature
func (*RestoreShardResponse) ProtoMessage ¶
func (*RestoreShardResponse) ProtoMessage()
func (*RestoreShardResponse) ProtoReflect ¶
func (x *RestoreShardResponse) ProtoReflect() protoreflect.Message
func (*RestoreShardResponse) ReadSignedData ¶
func (x *RestoreShardResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*RestoreShardResponse) Reset ¶
func (x *RestoreShardResponse) Reset()
func (*RestoreShardResponse) SetBody ¶
func (x *RestoreShardResponse) SetBody(v *RestoreShardResponse_Body)
SetBody sets response body.
func (*RestoreShardResponse) SetSignature ¶
func (x *RestoreShardResponse) SetSignature(sig *Signature)
func (*RestoreShardResponse) SignedDataSize ¶
func (x *RestoreShardResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*RestoreShardResponse) StableMarshal ¶
func (x *RestoreShardResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*RestoreShardResponse) StableSize ¶
func (x *RestoreShardResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*RestoreShardResponse) String ¶
func (x *RestoreShardResponse) String() string
type RestoreShardResponse_Body ¶
type RestoreShardResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*RestoreShardResponse_Body) Descriptor
deprecated
func (*RestoreShardResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use RestoreShardResponse_Body.ProtoReflect.Descriptor instead.
func (*RestoreShardResponse_Body) ProtoMessage ¶
func (*RestoreShardResponse_Body) ProtoMessage()
func (*RestoreShardResponse_Body) ProtoReflect ¶
func (x *RestoreShardResponse_Body) ProtoReflect() protoreflect.Message
func (*RestoreShardResponse_Body) Reset ¶
func (x *RestoreShardResponse_Body) Reset()
func (*RestoreShardResponse_Body) StableMarshal ¶
func (x *RestoreShardResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*RestoreShardResponse_Body) StableSize ¶
func (x *RestoreShardResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*RestoreShardResponse_Body) String ¶
func (x *RestoreShardResponse_Body) String() string
type SetNetmapStatusRequest ¶
type SetNetmapStatusRequest struct { // Body of set netmap status request message. Body *SetNetmapStatusRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Set netmap status request.
func (*SetNetmapStatusRequest) Descriptor
deprecated
func (*SetNetmapStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetNetmapStatusRequest.ProtoReflect.Descriptor instead.
func (*SetNetmapStatusRequest) GetBody ¶
func (x *SetNetmapStatusRequest) GetBody() *SetNetmapStatusRequest_Body
func (*SetNetmapStatusRequest) GetSignature ¶
func (x *SetNetmapStatusRequest) GetSignature() *Signature
func (*SetNetmapStatusRequest) ProtoMessage ¶
func (*SetNetmapStatusRequest) ProtoMessage()
func (*SetNetmapStatusRequest) ProtoReflect ¶
func (x *SetNetmapStatusRequest) ProtoReflect() protoreflect.Message
func (*SetNetmapStatusRequest) ReadSignedData ¶
func (x *SetNetmapStatusRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SetNetmapStatusRequest) Reset ¶
func (x *SetNetmapStatusRequest) Reset()
func (*SetNetmapStatusRequest) SetBody ¶
func (x *SetNetmapStatusRequest) SetBody(v *SetNetmapStatusRequest_Body)
SetBody sets body of the set netmap status request .
func (*SetNetmapStatusRequest) SetSignature ¶
func (x *SetNetmapStatusRequest) SetSignature(sig *Signature)
func (*SetNetmapStatusRequest) SignedDataSize ¶
func (x *SetNetmapStatusRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SetNetmapStatusRequest) StableMarshal ¶
func (x *SetNetmapStatusRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetNetmapStatusRequest) StableSize ¶
func (x *SetNetmapStatusRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetNetmapStatusRequest) String ¶
func (x *SetNetmapStatusRequest) String() string
type SetNetmapStatusRequest_Body ¶
type SetNetmapStatusRequest_Body struct { // New storage node status in NeoFS network map. // If status is MAINTENANCE, the node checks whether maintenance is // allowed in the network settings. In case of prohibition, the request // is denied. Otherwise, node switches to local maintenance state. To // force local maintenance, use `force_maintenance` flag. Status NetmapStatus `protobuf:"varint,1,opt,name=status,proto3,enum=control.NetmapStatus" json:"status,omitempty"` // MAINTENANCE status validation skip flag. If set, node starts local // maintenance regardless of network settings. The flag MUST NOT be // set for any other status. ForceMaintenance bool `protobuf:"varint,2,opt,name=force_maintenance,json=forceMaintenance,proto3" json:"force_maintenance,omitempty"` // contains filtered or unexported fields }
Set netmap status request body.
func (*SetNetmapStatusRequest_Body) Descriptor
deprecated
func (*SetNetmapStatusRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use SetNetmapStatusRequest_Body.ProtoReflect.Descriptor instead.
func (*SetNetmapStatusRequest_Body) GetForceMaintenance ¶
func (x *SetNetmapStatusRequest_Body) GetForceMaintenance() bool
func (*SetNetmapStatusRequest_Body) GetStatus ¶
func (x *SetNetmapStatusRequest_Body) GetStatus() NetmapStatus
func (*SetNetmapStatusRequest_Body) ProtoMessage ¶
func (*SetNetmapStatusRequest_Body) ProtoMessage()
func (*SetNetmapStatusRequest_Body) ProtoReflect ¶
func (x *SetNetmapStatusRequest_Body) ProtoReflect() protoreflect.Message
func (*SetNetmapStatusRequest_Body) Reset ¶
func (x *SetNetmapStatusRequest_Body) Reset()
func (*SetNetmapStatusRequest_Body) SetForceMaintenance ¶
func (x *SetNetmapStatusRequest_Body) SetForceMaintenance()
SetForceMaintenance sets force_maintenance flag in the message.
func (*SetNetmapStatusRequest_Body) SetStatus ¶
func (x *SetNetmapStatusRequest_Body) SetStatus(v NetmapStatus)
SetStatus sets new storage node status in NeoFS network map.
func (*SetNetmapStatusRequest_Body) StableMarshal ¶
func (x *SetNetmapStatusRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetNetmapStatusRequest_Body) StableSize ¶
func (x *SetNetmapStatusRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetNetmapStatusRequest_Body) String ¶
func (x *SetNetmapStatusRequest_Body) String() string
type SetNetmapStatusResponse ¶
type SetNetmapStatusResponse struct { // Body of set netmap status response message. Body *SetNetmapStatusResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Set netmap status response.
func SetNetmapStatus ¶
func SetNetmapStatus( cli *client.Client, req *SetNetmapStatusRequest, opts ...client.CallOption, ) (*SetNetmapStatusResponse, error)
SetNetmapStatus executes ControlService.SetNetmapStatus RPC.
func (*SetNetmapStatusResponse) Descriptor
deprecated
func (*SetNetmapStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetNetmapStatusResponse.ProtoReflect.Descriptor instead.
func (*SetNetmapStatusResponse) GetBody ¶
func (x *SetNetmapStatusResponse) GetBody() *SetNetmapStatusResponse_Body
func (*SetNetmapStatusResponse) GetSignature ¶
func (x *SetNetmapStatusResponse) GetSignature() *Signature
func (*SetNetmapStatusResponse) ProtoMessage ¶
func (*SetNetmapStatusResponse) ProtoMessage()
func (*SetNetmapStatusResponse) ProtoReflect ¶
func (x *SetNetmapStatusResponse) ProtoReflect() protoreflect.Message
func (*SetNetmapStatusResponse) ReadSignedData ¶
func (x *SetNetmapStatusResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SetNetmapStatusResponse) Reset ¶
func (x *SetNetmapStatusResponse) Reset()
func (*SetNetmapStatusResponse) SetBody ¶
func (x *SetNetmapStatusResponse) SetBody(v *SetNetmapStatusResponse_Body)
SetBody sets set body of the netmap status response.
func (*SetNetmapStatusResponse) SetSignature ¶
func (x *SetNetmapStatusResponse) SetSignature(sig *Signature)
func (*SetNetmapStatusResponse) SignedDataSize ¶
func (x *SetNetmapStatusResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SetNetmapStatusResponse) StableMarshal ¶
func (x *SetNetmapStatusResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetNetmapStatusResponse) StableSize ¶
func (x *SetNetmapStatusResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetNetmapStatusResponse) String ¶
func (x *SetNetmapStatusResponse) String() string
type SetNetmapStatusResponse_Body ¶
type SetNetmapStatusResponse_Body struct {
// contains filtered or unexported fields
}
Set netmap status response body
func (*SetNetmapStatusResponse_Body) Descriptor
deprecated
func (*SetNetmapStatusResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use SetNetmapStatusResponse_Body.ProtoReflect.Descriptor instead.
func (*SetNetmapStatusResponse_Body) ProtoMessage ¶
func (*SetNetmapStatusResponse_Body) ProtoMessage()
func (*SetNetmapStatusResponse_Body) ProtoReflect ¶
func (x *SetNetmapStatusResponse_Body) ProtoReflect() protoreflect.Message
func (*SetNetmapStatusResponse_Body) Reset ¶
func (x *SetNetmapStatusResponse_Body) Reset()
func (*SetNetmapStatusResponse_Body) StableMarshal ¶
func (x *SetNetmapStatusResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetNetmapStatusResponse_Body) StableSize ¶
func (x *SetNetmapStatusResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetNetmapStatusResponse_Body) String ¶
func (x *SetNetmapStatusResponse_Body) String() string
type SetShardModeRequest ¶
type SetShardModeRequest struct { // Body of set shard mode request message. Body *SetShardModeRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
Request to set mode of the shard.
func (*SetShardModeRequest) Descriptor
deprecated
func (*SetShardModeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetShardModeRequest.ProtoReflect.Descriptor instead.
func (*SetShardModeRequest) GetBody ¶
func (x *SetShardModeRequest) GetBody() *SetShardModeRequest_Body
func (*SetShardModeRequest) GetSignature ¶
func (x *SetShardModeRequest) GetSignature() *Signature
func (*SetShardModeRequest) ProtoMessage ¶
func (*SetShardModeRequest) ProtoMessage()
func (*SetShardModeRequest) ProtoReflect ¶
func (x *SetShardModeRequest) ProtoReflect() protoreflect.Message
func (*SetShardModeRequest) ReadSignedData ¶
func (x *SetShardModeRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SetShardModeRequest) Reset ¶
func (x *SetShardModeRequest) Reset()
func (*SetShardModeRequest) SetBody ¶
func (x *SetShardModeRequest) SetBody(v *SetShardModeRequest_Body)
SetBody sets request body.
func (*SetShardModeRequest) SetSignature ¶
func (x *SetShardModeRequest) SetSignature(sig *Signature)
func (*SetShardModeRequest) SignedDataSize ¶
func (x *SetShardModeRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SetShardModeRequest) StableMarshal ¶
func (x *SetShardModeRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetShardModeRequest) StableSize ¶
func (x *SetShardModeRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetShardModeRequest) String ¶
func (x *SetShardModeRequest) String() string
type SetShardModeRequest_Body ¶
type SetShardModeRequest_Body struct { // ID of the shard. Shard_ID [][]byte `protobuf:"bytes,1,rep,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // Mode that requested to be set. Mode ShardMode `protobuf:"varint,2,opt,name=mode,proto3,enum=control.ShardMode" json:"mode,omitempty"` // Flag signifying whether error counter should be set to 0. ResetErrorCounter bool `protobuf:"varint,3,opt,name=resetErrorCounter,proto3" json:"resetErrorCounter,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*SetShardModeRequest_Body) ClearErrorCounter ¶
func (x *SetShardModeRequest_Body) ClearErrorCounter(reset bool)
ClearErrorCounter sets flag signifying whether error counter for shard should be cleared.
func (*SetShardModeRequest_Body) Descriptor
deprecated
func (*SetShardModeRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use SetShardModeRequest_Body.ProtoReflect.Descriptor instead.
func (*SetShardModeRequest_Body) GetMode ¶
func (x *SetShardModeRequest_Body) GetMode() ShardMode
func (*SetShardModeRequest_Body) GetResetErrorCounter ¶
func (x *SetShardModeRequest_Body) GetResetErrorCounter() bool
func (*SetShardModeRequest_Body) GetShard_ID ¶
func (x *SetShardModeRequest_Body) GetShard_ID() [][]byte
func (*SetShardModeRequest_Body) ProtoMessage ¶
func (*SetShardModeRequest_Body) ProtoMessage()
func (*SetShardModeRequest_Body) ProtoReflect ¶
func (x *SetShardModeRequest_Body) ProtoReflect() protoreflect.Message
func (*SetShardModeRequest_Body) Reset ¶
func (x *SetShardModeRequest_Body) Reset()
func (*SetShardModeRequest_Body) SetMode ¶
func (x *SetShardModeRequest_Body) SetMode(v ShardMode)
SetMode sets mode of the shard.
func (*SetShardModeRequest_Body) SetShardIDList ¶
func (x *SetShardModeRequest_Body) SetShardIDList(v [][]byte)
SetShardIDList sets shard ID whose mode is requested to be set.
func (*SetShardModeRequest_Body) StableMarshal ¶
func (x *SetShardModeRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetShardModeRequest_Body) StableSize ¶
func (x *SetShardModeRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetShardModeRequest_Body) String ¶
func (x *SetShardModeRequest_Body) String() string
type SetShardModeResponse ¶
type SetShardModeResponse struct { // Body of set shard mode response message. Body *SetShardModeResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
SetShardMode response.
func SetShardMode ¶
func SetShardMode( cli *client.Client, req *SetShardModeRequest, opts ...client.CallOption, ) (*SetShardModeResponse, error)
SetShardMode executes ControlService.SetShardMode RPC.
func (*SetShardModeResponse) Descriptor
deprecated
func (*SetShardModeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetShardModeResponse.ProtoReflect.Descriptor instead.
func (*SetShardModeResponse) GetBody ¶
func (x *SetShardModeResponse) GetBody() *SetShardModeResponse_Body
func (*SetShardModeResponse) GetSignature ¶
func (x *SetShardModeResponse) GetSignature() *Signature
func (*SetShardModeResponse) ProtoMessage ¶
func (*SetShardModeResponse) ProtoMessage()
func (*SetShardModeResponse) ProtoReflect ¶
func (x *SetShardModeResponse) ProtoReflect() protoreflect.Message
func (*SetShardModeResponse) ReadSignedData ¶
func (x *SetShardModeResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SetShardModeResponse) Reset ¶
func (x *SetShardModeResponse) Reset()
func (*SetShardModeResponse) SetBody ¶
func (x *SetShardModeResponse) SetBody(v *SetShardModeResponse_Body)
SetBody sets body of the set shard mode response.
func (*SetShardModeResponse) SetSignature ¶
func (x *SetShardModeResponse) SetSignature(sig *Signature)
func (*SetShardModeResponse) SignedDataSize ¶
func (x *SetShardModeResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SetShardModeResponse) StableMarshal ¶
func (x *SetShardModeResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetShardModeResponse) StableSize ¶
func (x *SetShardModeResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetShardModeResponse) String ¶
func (x *SetShardModeResponse) String() string
type SetShardModeResponse_Body ¶
type SetShardModeResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*SetShardModeResponse_Body) Descriptor
deprecated
func (*SetShardModeResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use SetShardModeResponse_Body.ProtoReflect.Descriptor instead.
func (*SetShardModeResponse_Body) ProtoMessage ¶
func (*SetShardModeResponse_Body) ProtoMessage()
func (*SetShardModeResponse_Body) ProtoReflect ¶
func (x *SetShardModeResponse_Body) ProtoReflect() protoreflect.Message
func (*SetShardModeResponse_Body) Reset ¶
func (x *SetShardModeResponse_Body) Reset()
func (*SetShardModeResponse_Body) StableMarshal ¶
func (x *SetShardModeResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SetShardModeResponse_Body) StableSize ¶
func (x *SetShardModeResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SetShardModeResponse_Body) String ¶
func (x *SetShardModeResponse_Body) String() string
type ShardInfo ¶
type ShardInfo struct { // ID of the shard. Shard_ID []byte `protobuf:"bytes,1,opt,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"` // Path to shard's metabase. MetabasePath string `protobuf:"bytes,2,opt,name=metabase_path,json=metabasePath,proto3" json:"metabase_path,omitempty"` // Shard's blobstor info. Blobstor []*BlobstorInfo `protobuf:"bytes,3,rep,name=blobstor,proto3" json:"blobstor,omitempty"` // Path to shard's write-cache, empty if disabled. WritecachePath string `protobuf:"bytes,4,opt,name=writecache_path,json=writecachePath,proto3" json:"writecache_path,omitempty"` // Work mode of the shard. Mode ShardMode `protobuf:"varint,5,opt,name=mode,proto3,enum=control.ShardMode" json:"mode,omitempty"` // Amount of errors occured. ErrorCount uint32 `protobuf:"varint,6,opt,name=errorCount,proto3" json:"errorCount,omitempty"` // Path to shard's pilorama storage. PiloramaPath string `protobuf:"bytes,7,opt,name=pilorama_path,json=piloramaPath,proto3" json:"pilorama_path,omitempty"` // contains filtered or unexported fields }
Shard description.
func (*ShardInfo) Descriptor
deprecated
func (*ShardInfo) GetBlobstor ¶
func (x *ShardInfo) GetBlobstor() []*BlobstorInfo
func (*ShardInfo) GetErrorCount ¶
func (*ShardInfo) GetMetabasePath ¶
func (*ShardInfo) GetPiloramaPath ¶
func (*ShardInfo) GetShard_ID ¶
func (*ShardInfo) GetWritecachePath ¶
func (*ShardInfo) ProtoMessage ¶
func (*ShardInfo) ProtoMessage()
func (*ShardInfo) ProtoReflect ¶
func (x *ShardInfo) ProtoReflect() protoreflect.Message
func (*ShardInfo) SetErrorCount ¶
SetErrorCount sets shard's error counter.
func (*ShardInfo) SetMetabasePath ¶
SetMetabasePath sets path to shard's metabase.
func (*ShardInfo) SetPiloramaPath ¶
SetPiloramaPath sets path to shard's pilorama.
func (*ShardInfo) SetWriteCachePath ¶
SetWriteCachePath sets path to shard's write-cache.
func (*ShardInfo) StableMarshal ¶
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*ShardInfo) StableSize ¶
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
type ShardMode ¶
type ShardMode int32
Work mode of the shard.
func (ShardMode) Descriptor ¶
func (ShardMode) Descriptor() protoreflect.EnumDescriptor
func (ShardMode) EnumDescriptor
deprecated
func (ShardMode) Number ¶
func (x ShardMode) Number() protoreflect.EnumNumber
func (ShardMode) Type ¶
func (ShardMode) Type() protoreflect.EnumType
type Signature ¶
type Signature struct { // Public key used for signing. Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Binary signature. Sign []byte `protobuf:"bytes,2,opt,name=sign,json=signature,proto3" json:"sign,omitempty"` // contains filtered or unexported fields }
Signature of some message.
func (*Signature) Descriptor
deprecated
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶
func (x *Signature) ProtoReflect() protoreflect.Message
func (*Signature) StableMarshal ¶
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*Signature) StableSize ¶
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
type SynchronizeTreeRequest ¶
type SynchronizeTreeRequest struct { // Body of restore shard request message. Body *SynchronizeTreeRequest_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
SynchronizeTree request.
func (*SynchronizeTreeRequest) Descriptor
deprecated
func (*SynchronizeTreeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeTreeRequest.ProtoReflect.Descriptor instead.
func (*SynchronizeTreeRequest) GetBody ¶
func (x *SynchronizeTreeRequest) GetBody() *SynchronizeTreeRequest_Body
func (*SynchronizeTreeRequest) GetSignature ¶
func (x *SynchronizeTreeRequest) GetSignature() *Signature
func (*SynchronizeTreeRequest) ProtoMessage ¶
func (*SynchronizeTreeRequest) ProtoMessage()
func (*SynchronizeTreeRequest) ProtoReflect ¶
func (x *SynchronizeTreeRequest) ProtoReflect() protoreflect.Message
func (*SynchronizeTreeRequest) ReadSignedData ¶
func (x *SynchronizeTreeRequest) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SynchronizeTreeRequest) Reset ¶
func (x *SynchronizeTreeRequest) Reset()
func (*SynchronizeTreeRequest) SetBody ¶
func (x *SynchronizeTreeRequest) SetBody(v *SynchronizeTreeRequest_Body)
SetBody sets list shards request body.
func (*SynchronizeTreeRequest) SetSignature ¶
func (x *SynchronizeTreeRequest) SetSignature(sig *Signature)
func (*SynchronizeTreeRequest) SignedDataSize ¶
func (x *SynchronizeTreeRequest) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SynchronizeTreeRequest) StableMarshal ¶
func (x *SynchronizeTreeRequest) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SynchronizeTreeRequest) StableSize ¶
func (x *SynchronizeTreeRequest) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SynchronizeTreeRequest) String ¶
func (x *SynchronizeTreeRequest) String() string
type SynchronizeTreeRequest_Body ¶
type SynchronizeTreeRequest_Body struct { ContainerId []byte `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` TreeId string `protobuf:"bytes,2,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"` // Starting height for the synchronization. Can be omitted. Height uint64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"` // contains filtered or unexported fields }
Request body structure.
func (*SynchronizeTreeRequest_Body) Descriptor
deprecated
func (*SynchronizeTreeRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeTreeRequest_Body.ProtoReflect.Descriptor instead.
func (*SynchronizeTreeRequest_Body) GetContainerId ¶
func (x *SynchronizeTreeRequest_Body) GetContainerId() []byte
func (*SynchronizeTreeRequest_Body) GetHeight ¶
func (x *SynchronizeTreeRequest_Body) GetHeight() uint64
func (*SynchronizeTreeRequest_Body) GetTreeId ¶
func (x *SynchronizeTreeRequest_Body) GetTreeId() string
func (*SynchronizeTreeRequest_Body) ProtoMessage ¶
func (*SynchronizeTreeRequest_Body) ProtoMessage()
func (*SynchronizeTreeRequest_Body) ProtoReflect ¶
func (x *SynchronizeTreeRequest_Body) ProtoReflect() protoreflect.Message
func (*SynchronizeTreeRequest_Body) Reset ¶
func (x *SynchronizeTreeRequest_Body) Reset()
func (*SynchronizeTreeRequest_Body) StableMarshal ¶
func (x *SynchronizeTreeRequest_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SynchronizeTreeRequest_Body) StableSize ¶
func (x *SynchronizeTreeRequest_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SynchronizeTreeRequest_Body) String ¶
func (x *SynchronizeTreeRequest_Body) String() string
type SynchronizeTreeResponse ¶
type SynchronizeTreeResponse struct { // Body of restore shard response message. Body *SynchronizeTreeResponse_Body `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // Body signature. Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
SynchronizeTree response.
func SynchronizeTree ¶
func SynchronizeTree(cli *client.Client, req *SynchronizeTreeRequest, opts ...client.CallOption) (*SynchronizeTreeResponse, error)
SynchronizeTree executes ControlService.SynchronizeTree RPC.
func (*SynchronizeTreeResponse) Descriptor
deprecated
func (*SynchronizeTreeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeTreeResponse.ProtoReflect.Descriptor instead.
func (*SynchronizeTreeResponse) GetBody ¶
func (x *SynchronizeTreeResponse) GetBody() *SynchronizeTreeResponse_Body
func (*SynchronizeTreeResponse) GetSignature ¶
func (x *SynchronizeTreeResponse) GetSignature() *Signature
func (*SynchronizeTreeResponse) ProtoMessage ¶
func (*SynchronizeTreeResponse) ProtoMessage()
func (*SynchronizeTreeResponse) ProtoReflect ¶
func (x *SynchronizeTreeResponse) ProtoReflect() protoreflect.Message
func (*SynchronizeTreeResponse) ReadSignedData ¶
func (x *SynchronizeTreeResponse) ReadSignedData(buf []byte) ([]byte, error)
SignedDataSize returns size of the request signed data in bytes.
Structures with the same field values have the same signed data size.
func (*SynchronizeTreeResponse) Reset ¶
func (x *SynchronizeTreeResponse) Reset()
func (*SynchronizeTreeResponse) SetBody ¶
func (x *SynchronizeTreeResponse) SetBody(v *SynchronizeTreeResponse_Body)
SetBody sets list shards response body.
func (*SynchronizeTreeResponse) SetSignature ¶
func (x *SynchronizeTreeResponse) SetSignature(sig *Signature)
func (*SynchronizeTreeResponse) SignedDataSize ¶
func (x *SynchronizeTreeResponse) SignedDataSize() int
ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same signed data.
func (*SynchronizeTreeResponse) StableMarshal ¶
func (x *SynchronizeTreeResponse) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SynchronizeTreeResponse) StableSize ¶
func (x *SynchronizeTreeResponse) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SynchronizeTreeResponse) String ¶
func (x *SynchronizeTreeResponse) String() string
type SynchronizeTreeResponse_Body ¶
type SynchronizeTreeResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*SynchronizeTreeResponse_Body) Descriptor
deprecated
func (*SynchronizeTreeResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use SynchronizeTreeResponse_Body.ProtoReflect.Descriptor instead.
func (*SynchronizeTreeResponse_Body) ProtoMessage ¶
func (*SynchronizeTreeResponse_Body) ProtoMessage()
func (*SynchronizeTreeResponse_Body) ProtoReflect ¶
func (x *SynchronizeTreeResponse_Body) ProtoReflect() protoreflect.Message
func (*SynchronizeTreeResponse_Body) Reset ¶
func (x *SynchronizeTreeResponse_Body) Reset()
func (*SynchronizeTreeResponse_Body) StableMarshal ¶
func (x *SynchronizeTreeResponse_Body) StableMarshal(buf []byte) []byte
StableMarshal marshals x in protobuf binary format with stable field order.
If buffer length is less than x.StableSize(), new buffer is allocated.
Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.
Structures with the same field values have the same binary format.
func (*SynchronizeTreeResponse_Body) StableSize ¶
func (x *SynchronizeTreeResponse_Body) StableSize() (size int)
StableSize returns the size of x in protobuf format.
Structures with the same field values have the same binary size.
func (*SynchronizeTreeResponse_Body) String ¶
func (x *SynchronizeTreeResponse_Body) String() string
type UnimplementedControlServiceServer ¶
type UnimplementedControlServiceServer struct { }
UnimplementedControlServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedControlServiceServer) DropObjects ¶
func (UnimplementedControlServiceServer) DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)
func (UnimplementedControlServiceServer) DumpShard ¶
func (UnimplementedControlServiceServer) DumpShard(context.Context, *DumpShardRequest) (*DumpShardResponse, error)
func (UnimplementedControlServiceServer) EvacuateShard ¶
func (UnimplementedControlServiceServer) EvacuateShard(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error)
func (UnimplementedControlServiceServer) FlushCache ¶
func (UnimplementedControlServiceServer) FlushCache(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error)
func (UnimplementedControlServiceServer) HealthCheck ¶
func (UnimplementedControlServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
func (UnimplementedControlServiceServer) ListShards ¶
func (UnimplementedControlServiceServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)
func (UnimplementedControlServiceServer) RestoreShard ¶
func (UnimplementedControlServiceServer) RestoreShard(context.Context, *RestoreShardRequest) (*RestoreShardResponse, error)
func (UnimplementedControlServiceServer) SetNetmapStatus ¶
func (UnimplementedControlServiceServer) SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)
func (UnimplementedControlServiceServer) SetShardMode ¶
func (UnimplementedControlServiceServer) SetShardMode(context.Context, *SetShardModeRequest) (*SetShardModeResponse, error)
func (UnimplementedControlServiceServer) SynchronizeTree ¶
func (UnimplementedControlServiceServer) SynchronizeTree(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error)
type UnsafeControlServiceServer ¶
type UnsafeControlServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.