control

package
v0.0.0-...-79ba347 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 1, 2023 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
var File_pkg_services_control_service_proto protoreflect.FileDescriptor
View Source 
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 FrostFS 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 FrostFS 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 FrostFS 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 FrostFS 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 FrostFS 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 FrostFS 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) Descriptor() ([]byte, []int)

Deprecated: Use Netmap.ProtoReflect.Descriptor instead.

func (*Netmap) GetEpoch 

func (x *Netmap) GetEpoch() uint64

func (*Netmap) GetNodes 

func (x *Netmap) GetNodes() []*NodeInfo

func (*Netmap) MarshalJSON 

func (x *Netmap) MarshalJSON() ([]byte, error)

func (*Netmap) ProtoMessage 

func (*Netmap) ProtoMessage()

func (*Netmap) ProtoReflect 

func (x *Netmap) ProtoReflect() protoreflect.Message

func (*Netmap) Reset 

func (x *Netmap) Reset()

func (*Netmap) SetEpoch 

func (x *Netmap) SetEpoch(v uint64)

SetEpoch sets revision number of the network map.

func (*Netmap) SetNodes 

func (x *Netmap) SetNodes(v []*NodeInfo)

SetNodes sets nodes presented in network.

func (*Netmap) StableMarshal 

func (x *Netmap) 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 (*Netmap) StableSize 

func (x *Netmap) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*Netmap) String 

func (x *Netmap) String() string

type NetmapStatus 

type NetmapStatus int32

Status of the storage node in the FrostFS 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 FrostFS 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 FrostFS 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 FrostFS node.
	State NetmapStatus `protobuf:"varint,4,opt,name=state,proto3,enum=control.NetmapStatus" json:"state,omitempty"`
	// contains filtered or unexported fields
}

FrostFS node description.

func (*NodeInfo) Descriptor deprecated 

func (*NodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAddresses 

func (x *NodeInfo) GetAddresses() []string

func (*NodeInfo) GetAttributes 

func (x *NodeInfo) GetAttributes() []*NodeInfo_Attribute

func (*NodeInfo) GetPublicKey 

func (x *NodeInfo) GetPublicKey() []byte

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) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) SetAddresses 

func (x *NodeInfo) SetAddresses(v []string)

SetAddresses sets ways to connect to a node.

func (*NodeInfo) SetAttributes 

func (x *NodeInfo) SetAttributes(v []*NodeInfo_Attribute)

SetAttributes sets attributes of the FrostFS Storage Node.

func (*NodeInfo) SetPublicKey 

func (x *NodeInfo) SetPublicKey(v []byte)

SetPublicKey sets public key of the FrostFS node in a binary format.

func (*NodeInfo) SetState 

func (x *NodeInfo) SetState(v NetmapStatus)

SetState sets state of the FrostFS node.

func (*NodeInfo) StableMarshal 

func (x *NodeInfo) 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) StableSize 

func (x *NodeInfo) 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) String 

func (x *NodeInfo) String() string

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 FrostFS 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 FrostFS 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 FrostFS 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 FrostFS 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) Descriptor() ([]byte, []int)

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetBlobstor 

func (x *ShardInfo) GetBlobstor() []*BlobstorInfo

func (*ShardInfo) GetErrorCount 

func (x *ShardInfo) GetErrorCount() uint32

func (*ShardInfo) GetMetabasePath 

func (x *ShardInfo) GetMetabasePath() string

func (*ShardInfo) GetMode 

func (x *ShardInfo) GetMode() ShardMode

func (*ShardInfo) GetPiloramaPath 

func (x *ShardInfo) GetPiloramaPath() string

func (*ShardInfo) GetShard_ID 

func (x *ShardInfo) GetShard_ID() []byte

func (*ShardInfo) GetWritecachePath 

func (x *ShardInfo) GetWritecachePath() string

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect 

func (x *ShardInfo) ProtoReflect() protoreflect.Message

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) SetErrorCount 

func (x *ShardInfo) SetErrorCount(count uint32)

SetErrorCount sets shard's error counter.

func (*ShardInfo) SetID 

func (x *ShardInfo) SetID(v []byte)

SetID sets identificator of the shard.

func (*ShardInfo) SetMetabasePath 

func (x *ShardInfo) SetMetabasePath(v string)

SetMetabasePath sets path to shard's metabase.

func (*ShardInfo) SetMode 

func (x *ShardInfo) SetMode(v ShardMode)

SetMode sets path to shard's work mode.

func (*ShardInfo) SetPiloramaPath 

func (x *ShardInfo) SetPiloramaPath(v string)

SetPiloramaPath sets path to shard's pilorama.

func (*ShardInfo) SetWriteCachePath 

func (x *ShardInfo) SetWriteCachePath(v string)

SetWriteCachePath sets path to shard's write-cache.

func (*ShardInfo) StableMarshal 

func (x *ShardInfo) 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 (*ShardInfo) StableSize 

func (x *ShardInfo) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*ShardInfo) String 

func (x *ShardInfo) String() string

type ShardMode 

type ShardMode int32

Work mode of the shard. 

const (
	// Undefined mode, default value.
	ShardMode_SHARD_MODE_UNDEFINED ShardMode = 0
	// Read-write.
	ShardMode_READ_WRITE ShardMode = 1
	// Read-only.
	ShardMode_READ_ONLY ShardMode = 2
	// Degraded.
	ShardMode_DEGRADED ShardMode = 3
	// DegradedReadOnly.
	ShardMode_DEGRADED_READ_ONLY ShardMode = 4
)

func (ShardMode) Descriptor 

func (ShardMode) Descriptor() protoreflect.EnumDescriptor

func (ShardMode) Enum 

func (x ShardMode) Enum() *ShardMode

func (ShardMode) EnumDescriptor deprecated 

func (ShardMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ShardMode.Descriptor instead.

func (ShardMode) Number 

func (x ShardMode) Number() protoreflect.EnumNumber

func (ShardMode) String 

func (x ShardMode) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetKey 

func (x *Signature) GetKey() []byte

func (*Signature) GetSign 

func (x *Signature) GetSign() []byte

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect 

func (x *Signature) ProtoReflect() protoreflect.Message

func (*Signature) Reset 

func (x *Signature) Reset()

func (*Signature) SetKey 

func (x *Signature) SetKey(v []byte)

SetKey sets public key used for signing.

func (*Signature) SetSign 

func (x *Signature) SetSign(v []byte)

SetSign sets binary signature.

func (*Signature) StableMarshal 

func (x *Signature) 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 (*Signature) StableSize 

func (x *Signature) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*Signature) String 

func (x *Signature) String() string

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.

Source Files

View all Source files

Directories

Path Synopsis
ir
server

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.