Documentation ¶
Index ¶
- Variables
- func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)
- 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(body *Signature)
- func (x *DropObjectsRequest) SignedDataSize() 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, error)
- func (x *DropObjectsRequest_Body) StableSize() 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(v *Signature)
- func (x *DropObjectsResponse) SignedDataSize() 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, error)
- func (x *DropObjectsResponse_Body) StableSize() int
- func (x *DropObjectsResponse_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(body *Signature)
- func (x *HealthCheckRequest) SignedDataSize() 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, error)
- func (x *HealthCheckRequest_Body) StableSize() 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(v *Signature)
- func (x *HealthCheckResponse) SignedDataSize() 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, error)
- func (x *HealthCheckResponse_Body) StableSize() 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 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, error)
- func (x *Netmap) StableSize() int
- func (x *Netmap) String() string
- type NetmapSnapshotRequest
- func (*NetmapSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NetmapSnapshotRequest) GetBody() *NetmapSnapshotRequest_Body
- func (x *NetmapSnapshotRequest) GetSignature() *Signature
- func (*NetmapSnapshotRequest) ProtoMessage()
- func (x *NetmapSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *NetmapSnapshotRequest) ReadSignedData(buf []byte) ([]byte, error)
- func (x *NetmapSnapshotRequest) Reset()
- func (x *NetmapSnapshotRequest) SetBody(v *NetmapSnapshotRequest_Body)
- func (x *NetmapSnapshotRequest) SetSignature(body *Signature)
- func (x *NetmapSnapshotRequest) SignedDataSize() int
- func (x *NetmapSnapshotRequest) String() string
- type NetmapSnapshotRequest_Body
- func (*NetmapSnapshotRequest_Body) Descriptor() ([]byte, []int)deprecated
- func (*NetmapSnapshotRequest_Body) ProtoMessage()
- func (x *NetmapSnapshotRequest_Body) ProtoReflect() protoreflect.Message
- func (x *NetmapSnapshotRequest_Body) Reset()
- func (x *NetmapSnapshotRequest_Body) StableMarshal(buf []byte) ([]byte, error)
- func (x *NetmapSnapshotRequest_Body) StableSize() int
- func (x *NetmapSnapshotRequest_Body) String() string
- type NetmapSnapshotResponse
- func (*NetmapSnapshotResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NetmapSnapshotResponse) GetBody() *NetmapSnapshotResponse_Body
- func (x *NetmapSnapshotResponse) GetSignature() *Signature
- func (*NetmapSnapshotResponse) ProtoMessage()
- func (x *NetmapSnapshotResponse) ProtoReflect() protoreflect.Message
- func (x *NetmapSnapshotResponse) ReadSignedData(buf []byte) ([]byte, error)
- func (x *NetmapSnapshotResponse) Reset()
- func (x *NetmapSnapshotResponse) SetBody(v *NetmapSnapshotResponse_Body)
- func (x *NetmapSnapshotResponse) SetSignature(v *Signature)
- func (x *NetmapSnapshotResponse) SignedDataSize() int
- func (x *NetmapSnapshotResponse) String() string
- type NetmapSnapshotResponse_Body
- func (*NetmapSnapshotResponse_Body) Descriptor() ([]byte, []int)deprecated
- func (x *NetmapSnapshotResponse_Body) GetNetmap() *Netmap
- func (*NetmapSnapshotResponse_Body) ProtoMessage()
- func (x *NetmapSnapshotResponse_Body) ProtoReflect() protoreflect.Message
- func (x *NetmapSnapshotResponse_Body) Reset()
- func (x *NetmapSnapshotResponse_Body) SetNetmap(v *Netmap)
- func (x *NetmapSnapshotResponse_Body) StableMarshal(buf []byte) ([]byte, error)
- func (x *NetmapSnapshotResponse_Body) StableSize() int
- func (x *NetmapSnapshotResponse_Body) 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, error)
- func (x *NodeInfo) StableSize() 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, error)
- func (x *NodeInfo_Attribute) StableSize() int
- func (x *NodeInfo_Attribute) 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(body *Signature)
- func (x *SetNetmapStatusRequest) SignedDataSize() int
- func (x *SetNetmapStatusRequest) String() string
- type SetNetmapStatusRequest_Body
- func (*SetNetmapStatusRequest_Body) Descriptor() ([]byte, []int)deprecated
- 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) SetStatus(v NetmapStatus)
- func (x *SetNetmapStatusRequest_Body) StableMarshal(buf []byte) ([]byte, error)
- func (x *SetNetmapStatusRequest_Body) StableSize() 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(v *Signature)
- func (x *SetNetmapStatusResponse) SignedDataSize() 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, error)
- func (x *SetNetmapStatusResponse_Body) StableSize() int
- func (x *SetNetmapStatusResponse_Body) String() string
- 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) String() string
- type UnimplementedControlServiceServer
- func (UnimplementedControlServiceServer) DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)
- func (UnimplementedControlServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
- func (UnimplementedControlServiceServer) NetmapSnapshot(context.Context, *NetmapSnapshotRequest) (*NetmapSnapshotResponse, error)
- func (UnimplementedControlServiceServer) SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)
- type UnsafeControlServiceServer
Constants ¶
This section is empty.
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 ControlService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "control.ControlService", HandlerType: (*ControlServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "HealthCheck", Handler: _ControlService_HealthCheck_Handler, }, { MethodName: "NetmapSnapshot", Handler: _ControlService_NetmapSnapshot_Handler, }, { MethodName: "SetNetmapStatus", Handler: _ControlService_SetNetmapStatus_Handler, }, { MethodName: "DropObjects", Handler: _ControlService_DropObjects_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 ControlServiceClient ¶
type ControlServiceClient interface { // Performs health check of the storage node. HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) // Returns network map snapshot of the current NeoFS epoch. NetmapSnapshot(ctx context.Context, in *NetmapSnapshotRequest, opts ...grpc.CallOption) (*NetmapSnapshotResponse, 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) }
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) // Returns network map snapshot of the current NeoFS epoch. NetmapSnapshot(context.Context, *NetmapSnapshotRequest) (*NetmapSnapshotResponse, 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) }
ControlServiceServer is the server API for ControlService service. All implementations should embed UnimplementedControlServiceServer for forward compatibility
type DropObjectsRequest ¶ added in v0.16.0
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
added in
v0.16.0
func (*DropObjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsRequest.ProtoReflect.Descriptor instead.
func (*DropObjectsRequest) GetBody ¶ added in v0.16.0
func (x *DropObjectsRequest) GetBody() *DropObjectsRequest_Body
func (*DropObjectsRequest) GetSignature ¶ added in v0.16.0
func (x *DropObjectsRequest) GetSignature() *Signature
func (*DropObjectsRequest) ProtoMessage ¶ added in v0.16.0
func (*DropObjectsRequest) ProtoMessage()
func (*DropObjectsRequest) ProtoReflect ¶ added in v0.16.0
func (x *DropObjectsRequest) ProtoReflect() protoreflect.Message
func (*DropObjectsRequest) ReadSignedData ¶ added in v0.16.0
func (x *DropObjectsRequest) ReadSignedData(buf []byte) ([]byte, error)
ReadSignedData reads signed data of "Drop objects" request to buf.
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) Reset ¶ added in v0.16.0
func (x *DropObjectsRequest) Reset()
func (*DropObjectsRequest) SetBody ¶ added in v0.16.0
func (x *DropObjectsRequest) SetBody(v *DropObjectsRequest_Body)
SetBody sets body of the set "Drop objects" request.
func (*DropObjectsRequest) SetSignature ¶ added in v0.16.0
func (x *DropObjectsRequest) SetSignature(body *Signature)
SetSignature sets signature of the "Drop objects" request body.
func (*DropObjectsRequest) SignedDataSize ¶ added in v0.16.0
func (x *DropObjectsRequest) SignedDataSize() int
SignedDataSize returns binary size of the signed data of "Drop objects" request.
Structures with the same field values have the same signed data size.
func (*DropObjectsRequest) String ¶ added in v0.16.0
func (x *DropObjectsRequest) String() string
type DropObjectsRequest_Body ¶ added in v0.16.0
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
added in
v0.16.0
func (*DropObjectsRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsRequest_Body.ProtoReflect.Descriptor instead.
func (*DropObjectsRequest_Body) GetAddressList ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) GetAddressList() [][]byte
func (*DropObjectsRequest_Body) ProtoMessage ¶ added in v0.16.0
func (*DropObjectsRequest_Body) ProtoMessage()
func (*DropObjectsRequest_Body) ProtoReflect ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) ProtoReflect() protoreflect.Message
func (*DropObjectsRequest_Body) Reset ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) Reset()
func (*DropObjectsRequest_Body) SetAddressList ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) SetAddressList(v [][]byte)
SetAddressList sets list of objects to be removed in NeoFS API binary format.
func (*DropObjectsRequest_Body) StableMarshal ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) StableMarshal(buf []byte) ([]byte, error)
StableMarshal reads binary representation of "Drop objects" request body in protobuf binary format.
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 ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) StableSize() int
StableSize returns binary size of "Drop objects" response body in protobuf binary format.
Structures with the same field values have the same binary size.
func (*DropObjectsRequest_Body) String ¶ added in v0.16.0
func (x *DropObjectsRequest_Body) String() string
type DropObjectsResponse ¶ added in v0.16.0
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 ¶ added in v0.17.0
func DropObjects( cli *client.Client, req *DropObjectsRequest, opts ...client.CallOption, ) (*DropObjectsResponse, error)
DropObjects executes ControlService.DropObjects RPC.
func (*DropObjectsResponse) Descriptor
deprecated
added in
v0.16.0
func (*DropObjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsResponse.ProtoReflect.Descriptor instead.
func (*DropObjectsResponse) GetBody ¶ added in v0.16.0
func (x *DropObjectsResponse) GetBody() *DropObjectsResponse_Body
func (*DropObjectsResponse) GetSignature ¶ added in v0.16.0
func (x *DropObjectsResponse) GetSignature() *Signature
func (*DropObjectsResponse) ProtoMessage ¶ added in v0.16.0
func (*DropObjectsResponse) ProtoMessage()
func (*DropObjectsResponse) ProtoReflect ¶ added in v0.16.0
func (x *DropObjectsResponse) ProtoReflect() protoreflect.Message
func (*DropObjectsResponse) ReadSignedData ¶ added in v0.16.0
func (x *DropObjectsResponse) ReadSignedData(buf []byte) ([]byte, error)
ReadSignedData reads signed data of "Drop objects" response to buf.
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) Reset ¶ added in v0.16.0
func (x *DropObjectsResponse) Reset()
func (*DropObjectsResponse) SetBody ¶ added in v0.16.0
func (x *DropObjectsResponse) SetBody(v *DropObjectsResponse_Body)
SetBody sets set body of the "Drop objects" response.
func (*DropObjectsResponse) SetSignature ¶ added in v0.16.0
func (x *DropObjectsResponse) SetSignature(v *Signature)
SetSignature sets signature of the "Drop objects" response body.
func (*DropObjectsResponse) SignedDataSize ¶ added in v0.16.0
func (x *DropObjectsResponse) SignedDataSize() int
SignedDataSize returns binary size of the signed data of "Drop objects" response.
Structures with the same field values have the same signed data size.
func (*DropObjectsResponse) String ¶ added in v0.16.0
func (x *DropObjectsResponse) String() string
type DropObjectsResponse_Body ¶ added in v0.16.0
type DropObjectsResponse_Body struct {
// contains filtered or unexported fields
}
Response body structure.
func (*DropObjectsResponse_Body) Descriptor
deprecated
added in
v0.16.0
func (*DropObjectsResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use DropObjectsResponse_Body.ProtoReflect.Descriptor instead.
func (*DropObjectsResponse_Body) ProtoMessage ¶ added in v0.16.0
func (*DropObjectsResponse_Body) ProtoMessage()
func (*DropObjectsResponse_Body) ProtoReflect ¶ added in v0.16.0
func (x *DropObjectsResponse_Body) ProtoReflect() protoreflect.Message
func (*DropObjectsResponse_Body) Reset ¶ added in v0.16.0
func (x *DropObjectsResponse_Body) Reset()
func (*DropObjectsResponse_Body) StableMarshal ¶ added in v0.16.0
func (x *DropObjectsResponse_Body) StableMarshal(buf []byte) ([]byte, error)
StableMarshal reads binary representation of "Drop objects" response body in protobuf binary format.
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 ¶ added in v0.16.0
func (x *DropObjectsResponse_Body) StableSize() int
StableSize returns binary size of "Drop objects" response body in protobuf binary format.
Structures with the same field values have the same binary size.
func (*DropObjectsResponse_Body) String ¶ added in v0.16.0
func (x *DropObjectsResponse_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)
ReadSignedData reads signed data of health check request to buf.
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) 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(body *Signature)
SetSignature sets signature of the health check request body.
func (*HealthCheckRequest) SignedDataSize ¶
func (x *HealthCheckRequest) SignedDataSize() int
SignedDataSize returns binary size of the signed data of health check request.
Structures with the same field values have the same signed data 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, error)
StableMarshal reads binary representation of health check request body in protobuf binary format.
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() int
StableSize returns binary size of health check request body in protobuf binary 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 ¶ added in v0.17.0
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)
ReadSignedData reads signed data of health check response to buf.
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) 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(v *Signature)
SetSignature sets signature of the health check response body.
func (*HealthCheckResponse) SignedDataSize ¶
func (x *HealthCheckResponse) SignedDataSize() int
SignedDataSize returns binary size of the signed data of health check response.
Structures with the same field values have the same signed data 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, error)
StableMarshal reads binary representation of health check response body in protobuf binary format.
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() int
StableSize returns binary size of health check response body in protobuf binary 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 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 reads binary representation of netmap in protobuf binary format.
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 binary size of netmap in protobuf binary format.
Structures with the same field values have the same binary size.
type NetmapSnapshotRequest ¶
type NetmapSnapshotRequest struct { // Body of get netmap snapshot request message. Body *NetmapSnapshotRequest_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 }
Get netmap snapshot request.
func (*NetmapSnapshotRequest) Descriptor
deprecated
func (*NetmapSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use NetmapSnapshotRequest.ProtoReflect.Descriptor instead.
func (*NetmapSnapshotRequest) GetBody ¶
func (x *NetmapSnapshotRequest) GetBody() *NetmapSnapshotRequest_Body
func (*NetmapSnapshotRequest) GetSignature ¶
func (x *NetmapSnapshotRequest) GetSignature() *Signature
func (*NetmapSnapshotRequest) ProtoMessage ¶
func (*NetmapSnapshotRequest) ProtoMessage()
func (*NetmapSnapshotRequest) ProtoReflect ¶
func (x *NetmapSnapshotRequest) ProtoReflect() protoreflect.Message
func (*NetmapSnapshotRequest) ReadSignedData ¶
func (x *NetmapSnapshotRequest) ReadSignedData(buf []byte) ([]byte, error)
ReadSignedData reads signed data of netmap snapshot request to buf.
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 (*NetmapSnapshotRequest) Reset ¶
func (x *NetmapSnapshotRequest) Reset()
func (*NetmapSnapshotRequest) SetBody ¶
func (x *NetmapSnapshotRequest) SetBody(v *NetmapSnapshotRequest_Body)
SetBody sets get netmap snapshot request body.
func (*NetmapSnapshotRequest) SetSignature ¶
func (x *NetmapSnapshotRequest) SetSignature(body *Signature)
SetSignature sets signature of the netmap snapshot request body.
func (*NetmapSnapshotRequest) SignedDataSize ¶
func (x *NetmapSnapshotRequest) SignedDataSize() int
SignedDataSize returns binary size of the signed data of netmap snapshot request.
Structures with the same field values have the same signed data size.
func (*NetmapSnapshotRequest) String ¶
func (x *NetmapSnapshotRequest) String() string
type NetmapSnapshotRequest_Body ¶
type NetmapSnapshotRequest_Body struct {
// contains filtered or unexported fields
}
Get netmap snapshot request body.
func (*NetmapSnapshotRequest_Body) Descriptor
deprecated
func (*NetmapSnapshotRequest_Body) Descriptor() ([]byte, []int)
Deprecated: Use NetmapSnapshotRequest_Body.ProtoReflect.Descriptor instead.
func (*NetmapSnapshotRequest_Body) ProtoMessage ¶
func (*NetmapSnapshotRequest_Body) ProtoMessage()
func (*NetmapSnapshotRequest_Body) ProtoReflect ¶
func (x *NetmapSnapshotRequest_Body) ProtoReflect() protoreflect.Message
func (*NetmapSnapshotRequest_Body) Reset ¶
func (x *NetmapSnapshotRequest_Body) Reset()
func (*NetmapSnapshotRequest_Body) StableMarshal ¶
func (x *NetmapSnapshotRequest_Body) StableMarshal(buf []byte) ([]byte, error)
StableMarshal reads binary representation of netmap snapshot request body in protobuf binary format.
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 (*NetmapSnapshotRequest_Body) StableSize ¶
func (x *NetmapSnapshotRequest_Body) StableSize() int
StableSize returns binary size of netmap snapshot request body in protobuf binary format.
Structures with the same field values have the same binary size.
func (*NetmapSnapshotRequest_Body) String ¶
func (x *NetmapSnapshotRequest_Body) String() string
type NetmapSnapshotResponse ¶
type NetmapSnapshotResponse struct { // Body of get netmap snapshot response message. Body *NetmapSnapshotResponse_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 }
Get netmap snapshot request.
func NetmapSnapshot ¶ added in v0.17.0
func NetmapSnapshot( cli *client.Client, req *NetmapSnapshotRequest, opts ...client.CallOption, ) (*NetmapSnapshotResponse, error)
NetmapSnapshot executes ControlService.NetmapSnapshot RPC.
func (*NetmapSnapshotResponse) Descriptor
deprecated
func (*NetmapSnapshotResponse) Descriptor() ([]byte, []int)
Deprecated: Use NetmapSnapshotResponse.ProtoReflect.Descriptor instead.
func (*NetmapSnapshotResponse) GetBody ¶
func (x *NetmapSnapshotResponse) GetBody() *NetmapSnapshotResponse_Body
func (*NetmapSnapshotResponse) GetSignature ¶
func (x *NetmapSnapshotResponse) GetSignature() *Signature
func (*NetmapSnapshotResponse) ProtoMessage ¶
func (*NetmapSnapshotResponse) ProtoMessage()
func (*NetmapSnapshotResponse) ProtoReflect ¶
func (x *NetmapSnapshotResponse) ProtoReflect() protoreflect.Message
func (*NetmapSnapshotResponse) ReadSignedData ¶
func (x *NetmapSnapshotResponse) ReadSignedData(buf []byte) ([]byte, error)
ReadSignedData reads signed data of netmap snapshot response to buf.
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 (*NetmapSnapshotResponse) Reset ¶
func (x *NetmapSnapshotResponse) Reset()
func (*NetmapSnapshotResponse) SetBody ¶
func (x *NetmapSnapshotResponse) SetBody(v *NetmapSnapshotResponse_Body)
SetBody sets get netmap snapshot response body.
func (*NetmapSnapshotResponse) SetSignature ¶
func (x *NetmapSnapshotResponse) SetSignature(v *Signature)
SetSignature sets signature of the get netmap snapshot response body.
func (*NetmapSnapshotResponse) SignedDataSize ¶
func (x *NetmapSnapshotResponse) SignedDataSize() int
SignedDataSize returns binary size of the signed data of netmap snapshot response.
Structures with the same field values have the same signed data size.
func (*NetmapSnapshotResponse) String ¶
func (x *NetmapSnapshotResponse) String() string
type NetmapSnapshotResponse_Body ¶
type NetmapSnapshotResponse_Body struct { // Structure of the requested network map. Netmap *Netmap `protobuf:"bytes,1,opt,name=netmap,proto3" json:"netmap,omitempty"` // contains filtered or unexported fields }
Get netmap snapshot response body
func (*NetmapSnapshotResponse_Body) Descriptor
deprecated
func (*NetmapSnapshotResponse_Body) Descriptor() ([]byte, []int)
Deprecated: Use NetmapSnapshotResponse_Body.ProtoReflect.Descriptor instead.
func (*NetmapSnapshotResponse_Body) GetNetmap ¶
func (x *NetmapSnapshotResponse_Body) GetNetmap() *Netmap
func (*NetmapSnapshotResponse_Body) ProtoMessage ¶
func (*NetmapSnapshotResponse_Body) ProtoMessage()
func (*NetmapSnapshotResponse_Body) ProtoReflect ¶
func (x *NetmapSnapshotResponse_Body) ProtoReflect() protoreflect.Message
func (*NetmapSnapshotResponse_Body) Reset ¶
func (x *NetmapSnapshotResponse_Body) Reset()
func (*NetmapSnapshotResponse_Body) SetNetmap ¶
func (x *NetmapSnapshotResponse_Body) SetNetmap(v *Netmap)
SetNetmap sets structure of the current network map.
func (*NetmapSnapshotResponse_Body) StableMarshal ¶
func (x *NetmapSnapshotResponse_Body) StableMarshal(buf []byte) ([]byte, error)
StableMarshal reads binary representation of netmap snapshot response body in protobuf binary format.
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 (*NetmapSnapshotResponse_Body) StableSize ¶
func (x *NetmapSnapshotResponse_Body) StableSize() int
StableSize returns binary size of netmap snapshot response body in protobuf binary format.
Structures with the same field values have the same binary size.
func (*NetmapSnapshotResponse_Body) String ¶
func (x *NetmapSnapshotResponse_Body) String() string
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 ¶ added in v0.22.0
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 ¶ added in v0.22.0
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 reads binary representation of node information in protobuf binary format.
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 binary size of node information in protobuf binary 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.
- Subnet \ String ID of Node's storage subnet. There can be only one subnet served by the Storage Node.
- 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, error)
StableMarshal reads binary representation of node attribute in protobuf binary format.
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() int
StableSize returns binary size of node attribute in protobuf binary format.
Structures with the same field values have the same binary size.
func (*NodeInfo_Attribute) String ¶
func (x *NodeInfo_Attribute) 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)
ReadSignedData reads signed data of set netmap status request to buf.
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) 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(body *Signature)
SetSignature sets signature of the set netmap status request body.
func (*SetNetmapStatusRequest) SignedDataSize ¶
func (x *SetNetmapStatusRequest) SignedDataSize() int
SignedDataSize returns binary size of the signed data of set netmap status request.
Structures with the same field values have the same signed data size.
func (*SetNetmapStatusRequest) String ¶
func (x *SetNetmapStatusRequest) String() string
type SetNetmapStatusRequest_Body ¶
type SetNetmapStatusRequest_Body struct { // New storage node status in NeoFS network map. Status NetmapStatus `protobuf:"varint,1,opt,name=status,proto3,enum=control.NetmapStatus" json:"status,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) 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) 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, error)
StableMarshal reads binary representation of set netmap status request body in protobuf binary format.
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() int
StableSize returns binary size of health check response body in protobuf binary 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 ¶ added in v0.17.0
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)
ReadSignedData reads signed data of set netmap status response to buf.
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) 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(v *Signature)
SetSignature sets signature of the set netmap status response body.
func (*SetNetmapStatusResponse) SignedDataSize ¶
func (x *SetNetmapStatusResponse) SignedDataSize() int
SignedDataSize returns binary size of the signed data of set netmap status response.
Structures with the same field values have the same signed data 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, error)
StableMarshal reads binary representation of set netmap status response body in protobuf binary format.
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() int
StableSize returns binary size of set netmap status response body in protobuf binary format.
Structures with the same field values have the same binary size.
func (*SetNetmapStatusResponse_Body) String ¶
func (x *SetNetmapStatusResponse_Body) String() string
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
type UnimplementedControlServiceServer ¶
type UnimplementedControlServiceServer struct { }
UnimplementedControlServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedControlServiceServer) DropObjects ¶ added in v0.16.0
func (UnimplementedControlServiceServer) DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)
func (UnimplementedControlServiceServer) HealthCheck ¶
func (UnimplementedControlServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
func (UnimplementedControlServiceServer) NetmapSnapshot ¶
func (UnimplementedControlServiceServer) NetmapSnapshot(context.Context, *NetmapSnapshotRequest) (*NetmapSnapshotResponse, error)
func (UnimplementedControlServiceServer) SetNetmapStatus ¶
func (UnimplementedControlServiceServer) SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)
type UnsafeControlServiceServer ¶ added in v0.26.0
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.