control

Aug 20, 2024

Changes in this version

+ const ControlService_ObjectStatus_FullMethodName

type ControlServiceClient

+ ObjectStatus func(ctx context.Context, in *ObjectStatusRequest, opts ...grpc.CallOption) (*ObjectStatusResponse, error)

type ControlServiceServer

+ ObjectStatus func(context.Context, *ObjectStatusRequest) (*ObjectStatusResponse, error)

+ type ObjectStatusRequest struct

+ Body *ObjectStatusRequest_Body

+ Signature *Signature

+ func (*ObjectStatusRequest) Descriptor() ([]byte, []int)

+ func (*ObjectStatusRequest) ProtoMessage()

+ func (x *ObjectStatusRequest) GetBody() *ObjectStatusRequest_Body

+ func (x *ObjectStatusRequest) GetSignature() *Signature

+ func (x *ObjectStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ObjectStatusRequest) Reset()

+ func (x *ObjectStatusRequest) SetSignature(sig *Signature)

+ func (x *ObjectStatusRequest) SignedDataSize() int

+ func (x *ObjectStatusRequest) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusRequest) StableSize() (size int)

+ func (x *ObjectStatusRequest) String() string

+ type ObjectStatusRequest_Body struct

+ ObjectAddress string

+ func (*ObjectStatusRequest_Body) Descriptor() ([]byte, []int)

+ func (*ObjectStatusRequest_Body) ProtoMessage()

+ func (x *ObjectStatusRequest_Body) GetObjectAddress() string

+ func (x *ObjectStatusRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusRequest_Body) Reset()

+ func (x *ObjectStatusRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusRequest_Body) StableSize() (size int)

+ func (x *ObjectStatusRequest_Body) String() string

+ type ObjectStatusResponse struct

+ Body *ObjectStatusResponse_Body

+ Signature *Signature

+ func ObjectStatus(cli *client.Client, req *ObjectStatusRequest, opts ...client.CallOption) (*ObjectStatusResponse, error)

+ func (*ObjectStatusResponse) Descriptor() ([]byte, []int)

+ func (*ObjectStatusResponse) ProtoMessage()

+ func (x *ObjectStatusResponse) GetBody() *ObjectStatusResponse_Body

+ func (x *ObjectStatusResponse) GetSignature() *Signature

+ func (x *ObjectStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ObjectStatusResponse) Reset()

+ func (x *ObjectStatusResponse) SetSignature(sig *Signature)

+ func (x *ObjectStatusResponse) SignedDataSize() int

+ func (x *ObjectStatusResponse) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusResponse) StableSize() (size int)

+ func (x *ObjectStatusResponse) String() string

+ type ObjectStatusResponse_Body struct

+ Shards []*ObjectStatusResponse_Body_Shard

+ func (*ObjectStatusResponse_Body) Descriptor() ([]byte, []int)

+ func (*ObjectStatusResponse_Body) ProtoMessage()

+ func (x *ObjectStatusResponse_Body) GetShards() []*ObjectStatusResponse_Body_Shard

+ func (x *ObjectStatusResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusResponse_Body) Reset()

+ func (x *ObjectStatusResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusResponse_Body) StableSize() (size int)

+ func (x *ObjectStatusResponse_Body) String() string

+ type ObjectStatusResponse_Body_Shard struct

+ ShardId string

+ Storages []*ObjectStatusResponse_Body_Shard_Status

+ func (*ObjectStatusResponse_Body_Shard) Descriptor() ([]byte, []int)

+ func (*ObjectStatusResponse_Body_Shard) ProtoMessage()

+ func (x *ObjectStatusResponse_Body_Shard) GetShardId() string

+ func (x *ObjectStatusResponse_Body_Shard) GetStorages() []*ObjectStatusResponse_Body_Shard_Status

+ func (x *ObjectStatusResponse_Body_Shard) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusResponse_Body_Shard) Reset()

+ func (x *ObjectStatusResponse_Body_Shard) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusResponse_Body_Shard) StableSize() (size int)

+ func (x *ObjectStatusResponse_Body_Shard) String() string

+ type ObjectStatusResponse_Body_Shard_Status struct

+ Status string

+ Type string

+ func (*ObjectStatusResponse_Body_Shard_Status) Descriptor() ([]byte, []int)

+ func (*ObjectStatusResponse_Body_Shard_Status) ProtoMessage()

+ func (x *ObjectStatusResponse_Body_Shard_Status) GetStatus() string

+ func (x *ObjectStatusResponse_Body_Shard_Status) GetType() string

+ func (x *ObjectStatusResponse_Body_Shard_Status) ProtoReflect() protoreflect.Message

+ func (x *ObjectStatusResponse_Body_Shard_Status) Reset()

+ func (x *ObjectStatusResponse_Body_Shard_Status) StableMarshal(buf []byte) []byte

+ func (x *ObjectStatusResponse_Body_Shard_Status) StableSize() (size int)

+ func (x *ObjectStatusResponse_Body_Shard_Status) String() string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) ObjectStatus(context.Context, *ObjectStatusRequest) (*ObjectStatusResponse, error)

Sep 13, 2023

Changes in this version

+ const ControlService_DropObjects_FullMethodName

+ const ControlService_DumpShard_FullMethodName

+ const ControlService_EvacuateShard_FullMethodName

+ const ControlService_FlushCache_FullMethodName

+ const ControlService_HealthCheck_FullMethodName

+ const ControlService_ListShards_FullMethodName

+ const ControlService_RestoreShard_FullMethodName

+ const ControlService_SetNetmapStatus_FullMethodName

+ const ControlService_SetShardMode_FullMethodName

+ const ControlService_SynchronizeTree_FullMethodName

Oct 31, 2022

Changes in this version

type SetNetmapStatusRequest_Body

+ ForceMaintenance bool

+ func (x *SetNetmapStatusRequest_Body) GetForceMaintenance() bool

+ func (x *SetNetmapStatusRequest_Body) SetForceMaintenance()

Oct 17, 2022

Changes in this version

+ type BlobstorInfo struct

+ Path string

+ Type string

+ func (*BlobstorInfo) Descriptor() ([]byte, []int)

+ func (*BlobstorInfo) ProtoMessage()

+ func (x *BlobstorInfo) GetPath() string

+ func (x *BlobstorInfo) GetType() string

+ func (x *BlobstorInfo) ProtoReflect() protoreflect.Message

+ func (x *BlobstorInfo) Reset()

+ func (x *BlobstorInfo) StableMarshal(buf []byte) []byte

+ func (x *BlobstorInfo) StableSize() (size int)

+ func (x *BlobstorInfo) String() string

type ControlServiceClient

+ EvacuateShard func(ctx context.Context, in *EvacuateShardRequest, opts ...grpc.CallOption) (*EvacuateShardResponse, error)

+ FlushCache func(ctx context.Context, in *FlushCacheRequest, opts ...grpc.CallOption) (*FlushCacheResponse, error)

type ControlServiceServer

+ EvacuateShard func(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error)

+ FlushCache func(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error)

+ type EvacuateShardRequest struct

+ Body *EvacuateShardRequest_Body

+ Signature *Signature

+ func (*EvacuateShardRequest) Descriptor() ([]byte, []int)

+ func (*EvacuateShardRequest) ProtoMessage()

+ func (x *EvacuateShardRequest) GetBody() *EvacuateShardRequest_Body

+ func (x *EvacuateShardRequest) GetSignature() *Signature

+ func (x *EvacuateShardRequest) ProtoReflect() protoreflect.Message

+ func (x *EvacuateShardRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *EvacuateShardRequest) Reset()

+ func (x *EvacuateShardRequest) SetSignature(sig *Signature)

+ func (x *EvacuateShardRequest) SignedDataSize() int

+ func (x *EvacuateShardRequest) StableMarshal(buf []byte) []byte

+ func (x *EvacuateShardRequest) StableSize() (size int)

+ func (x *EvacuateShardRequest) String() string

+ type EvacuateShardRequest_Body struct

+ IgnoreErrors bool

+ Shard_ID [][]byte

+ func (*EvacuateShardRequest_Body) Descriptor() ([]byte, []int)

+ func (*EvacuateShardRequest_Body) ProtoMessage()

+ func (x *EvacuateShardRequest_Body) GetIgnoreErrors() bool

+ func (x *EvacuateShardRequest_Body) GetShard_ID() [][]byte

+ func (x *EvacuateShardRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *EvacuateShardRequest_Body) Reset()

+ func (x *EvacuateShardRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *EvacuateShardRequest_Body) StableSize() (size int)

+ func (x *EvacuateShardRequest_Body) String() string

+ type EvacuateShardResponse struct

+ Body *EvacuateShardResponse_Body

+ Signature *Signature

+ func EvacuateShard(cli *client.Client, req *EvacuateShardRequest, opts ...client.CallOption) (*EvacuateShardResponse, error)

+ func (*EvacuateShardResponse) Descriptor() ([]byte, []int)

+ func (*EvacuateShardResponse) ProtoMessage()

+ func (x *EvacuateShardResponse) GetBody() *EvacuateShardResponse_Body

+ func (x *EvacuateShardResponse) GetSignature() *Signature

+ func (x *EvacuateShardResponse) ProtoReflect() protoreflect.Message

+ func (x *EvacuateShardResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *EvacuateShardResponse) Reset()

+ func (x *EvacuateShardResponse) SetSignature(sig *Signature)

+ func (x *EvacuateShardResponse) SignedDataSize() int

+ func (x *EvacuateShardResponse) StableMarshal(buf []byte) []byte

+ func (x *EvacuateShardResponse) StableSize() (size int)

+ func (x *EvacuateShardResponse) String() string

+ type EvacuateShardResponse_Body struct

+ Count uint32

+ func (*EvacuateShardResponse_Body) Descriptor() ([]byte, []int)

+ func (*EvacuateShardResponse_Body) ProtoMessage()

+ func (x *EvacuateShardResponse_Body) GetCount() uint32

+ func (x *EvacuateShardResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *EvacuateShardResponse_Body) Reset()

+ func (x *EvacuateShardResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *EvacuateShardResponse_Body) StableSize() (size int)

+ func (x *EvacuateShardResponse_Body) String() string

+ type FlushCacheRequest struct

+ Body *FlushCacheRequest_Body

+ Signature *Signature

+ func (*FlushCacheRequest) Descriptor() ([]byte, []int)

+ func (*FlushCacheRequest) ProtoMessage()

+ func (x *FlushCacheRequest) GetBody() *FlushCacheRequest_Body

+ func (x *FlushCacheRequest) GetSignature() *Signature

+ func (x *FlushCacheRequest) ProtoReflect() protoreflect.Message

+ func (x *FlushCacheRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *FlushCacheRequest) Reset()

+ func (x *FlushCacheRequest) SetSignature(sig *Signature)

+ func (x *FlushCacheRequest) SignedDataSize() int

+ func (x *FlushCacheRequest) StableMarshal(buf []byte) []byte

+ func (x *FlushCacheRequest) StableSize() (size int)

+ func (x *FlushCacheRequest) String() string

+ type FlushCacheRequest_Body struct

+ Shard_ID [][]byte

+ func (*FlushCacheRequest_Body) Descriptor() ([]byte, []int)

+ func (*FlushCacheRequest_Body) ProtoMessage()

+ func (x *FlushCacheRequest_Body) GetShard_ID() [][]byte

+ func (x *FlushCacheRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *FlushCacheRequest_Body) Reset()

+ func (x *FlushCacheRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *FlushCacheRequest_Body) StableSize() (size int)

+ func (x *FlushCacheRequest_Body) String() string

+ type FlushCacheResponse struct

+ Body *FlushCacheResponse_Body

+ Signature *Signature

+ func FlushCache(cli *client.Client, req *FlushCacheRequest, opts ...client.CallOption) (*FlushCacheResponse, error)

+ func (*FlushCacheResponse) Descriptor() ([]byte, []int)

+ func (*FlushCacheResponse) ProtoMessage()

+ func (x *FlushCacheResponse) GetBody() *FlushCacheResponse_Body

+ func (x *FlushCacheResponse) GetSignature() *Signature

+ func (x *FlushCacheResponse) ProtoReflect() protoreflect.Message

+ func (x *FlushCacheResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *FlushCacheResponse) Reset()

+ func (x *FlushCacheResponse) SetSignature(sig *Signature)

+ func (x *FlushCacheResponse) SignedDataSize() int

+ func (x *FlushCacheResponse) StableMarshal(buf []byte) []byte

+ func (x *FlushCacheResponse) StableSize() (size int)

+ func (x *FlushCacheResponse) String() string

+ type FlushCacheResponse_Body struct

+ func (*FlushCacheResponse_Body) Descriptor() ([]byte, []int)

+ func (*FlushCacheResponse_Body) ProtoMessage()

+ func (x *FlushCacheResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *FlushCacheResponse_Body) Reset()

+ func (x *FlushCacheResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *FlushCacheResponse_Body) StableSize() (size int)

+ func (x *FlushCacheResponse_Body) String() string

type SetShardModeRequest_Body

+ func (x *SetShardModeRequest_Body) SetShardIDList(v [][]byte)

type ShardInfo

+ Blobstor []*BlobstorInfo

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

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) EvacuateShard(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error)

+ func (UnimplementedControlServiceServer) FlushCache(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error)

Jul 25, 2022

Changes in this version

type ControlServiceClient

+ SynchronizeTree func(ctx context.Context, in *SynchronizeTreeRequest, opts ...grpc.CallOption) (*SynchronizeTreeResponse, error)

type ControlServiceServer

+ SynchronizeTree func(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error)

type ShardInfo

+ PiloramaPath string

+ func (x *ShardInfo) GetPiloramaPath() string

+ func (x *ShardInfo) SetPiloramaPath(v string)

type ShardMode

+ const ShardMode_DEGRADED_READ_ONLY

+ type SynchronizeTreeRequest struct

+ Body *SynchronizeTreeRequest_Body

+ Signature *Signature

+ func (*SynchronizeTreeRequest) Descriptor() ([]byte, []int)

+ func (*SynchronizeTreeRequest) ProtoMessage()

+ func (x *SynchronizeTreeRequest) GetBody() *SynchronizeTreeRequest_Body

+ func (x *SynchronizeTreeRequest) GetSignature() *Signature

+ func (x *SynchronizeTreeRequest) ProtoReflect() protoreflect.Message

+ func (x *SynchronizeTreeRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SynchronizeTreeRequest) Reset()

+ func (x *SynchronizeTreeRequest) SetBody(v *SynchronizeTreeRequest_Body)

+ func (x *SynchronizeTreeRequest) SetSignature(sig *Signature)

+ func (x *SynchronizeTreeRequest) SignedDataSize() int

+ func (x *SynchronizeTreeRequest) StableMarshal(buf []byte) []byte

+ func (x *SynchronizeTreeRequest) StableSize() (size int)

+ func (x *SynchronizeTreeRequest) String() string

+ type SynchronizeTreeRequest_Body struct

+ ContainerId []byte

+ Height uint64

+ TreeId string

+ func (*SynchronizeTreeRequest_Body) Descriptor() ([]byte, []int)

+ func (*SynchronizeTreeRequest_Body) ProtoMessage()

+ func (x *SynchronizeTreeRequest_Body) GetContainerId() []byte

+ func (x *SynchronizeTreeRequest_Body) GetHeight() uint64

+ func (x *SynchronizeTreeRequest_Body) GetTreeId() string

+ func (x *SynchronizeTreeRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *SynchronizeTreeRequest_Body) Reset()

+ func (x *SynchronizeTreeRequest_Body) StableMarshal(buf []byte) []byte

+ func (x *SynchronizeTreeRequest_Body) StableSize() (size int)

+ func (x *SynchronizeTreeRequest_Body) String() string

+ type SynchronizeTreeResponse struct

+ Body *SynchronizeTreeResponse_Body

+ Signature *Signature

+ func SynchronizeTree(cli *client.Client, req *SynchronizeTreeRequest, opts ...client.CallOption) (*SynchronizeTreeResponse, error)

+ func (*SynchronizeTreeResponse) Descriptor() ([]byte, []int)

+ func (*SynchronizeTreeResponse) ProtoMessage()

+ func (x *SynchronizeTreeResponse) GetBody() *SynchronizeTreeResponse_Body

+ func (x *SynchronizeTreeResponse) GetSignature() *Signature

+ func (x *SynchronizeTreeResponse) ProtoReflect() protoreflect.Message

+ func (x *SynchronizeTreeResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SynchronizeTreeResponse) Reset()

+ func (x *SynchronizeTreeResponse) SetBody(v *SynchronizeTreeResponse_Body)

+ func (x *SynchronizeTreeResponse) SetSignature(sig *Signature)

+ func (x *SynchronizeTreeResponse) SignedDataSize() int

+ func (x *SynchronizeTreeResponse) StableMarshal(buf []byte) []byte

+ func (x *SynchronizeTreeResponse) StableSize() (size int)

+ func (x *SynchronizeTreeResponse) String() string

+ type SynchronizeTreeResponse_Body struct

+ func (*SynchronizeTreeResponse_Body) Descriptor() ([]byte, []int)

+ func (*SynchronizeTreeResponse_Body) ProtoMessage()

+ func (x *SynchronizeTreeResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *SynchronizeTreeResponse_Body) Reset()

+ func (x *SynchronizeTreeResponse_Body) StableMarshal(buf []byte) []byte

+ func (x *SynchronizeTreeResponse_Body) StableSize() (size int)

+ func (x *SynchronizeTreeResponse_Body) String() string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) SynchronizeTree(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error)

Jul 8, 2022

Changes in this version

type DropObjectsRequest

+ func (x *DropObjectsRequest) StableMarshal(buf []byte) []byte

+ func (x *DropObjectsRequest) StableSize() (size int)

type DropObjectsResponse

+ func (x *DropObjectsResponse) StableMarshal(buf []byte) []byte

+ func (x *DropObjectsResponse) StableSize() (size int)

type DumpShardRequest

+ func (x *DumpShardRequest) StableMarshal(buf []byte) []byte

+ func (x *DumpShardRequest) StableSize() (size int)

type DumpShardResponse

+ func (x *DumpShardResponse) StableMarshal(buf []byte) []byte

+ func (x *DumpShardResponse) StableSize() (size int)

type HealthCheckRequest

+ func (x *HealthCheckRequest) StableMarshal(buf []byte) []byte

+ func (x *HealthCheckRequest) StableSize() (size int)

type HealthCheckResponse

+ func (x *HealthCheckResponse) StableMarshal(buf []byte) []byte

+ func (x *HealthCheckResponse) StableSize() (size int)

type ListShardsRequest

+ func (x *ListShardsRequest) StableMarshal(buf []byte) []byte

+ func (x *ListShardsRequest) StableSize() (size int)

type ListShardsResponse

+ func (x *ListShardsResponse) StableMarshal(buf []byte) []byte

+ func (x *ListShardsResponse) StableSize() (size int)

type NetmapSnapshotRequest

+ func (x *NetmapSnapshotRequest) StableMarshal(buf []byte) []byte

+ func (x *NetmapSnapshotRequest) StableSize() (size int)

type NetmapSnapshotResponse

+ func (x *NetmapSnapshotResponse) StableMarshal(buf []byte) []byte

+ func (x *NetmapSnapshotResponse) StableSize() (size int)

type RestoreShardRequest

+ func (x *RestoreShardRequest) StableMarshal(buf []byte) []byte

+ func (x *RestoreShardRequest) StableSize() (size int)

type RestoreShardResponse

+ func (x *RestoreShardResponse) StableMarshal(buf []byte) []byte

+ func (x *RestoreShardResponse) StableSize() (size int)

type SetNetmapStatusRequest

+ func (x *SetNetmapStatusRequest) StableMarshal(buf []byte) []byte

+ func (x *SetNetmapStatusRequest) StableSize() (size int)

type SetNetmapStatusResponse

+ func (x *SetNetmapStatusResponse) StableMarshal(buf []byte) []byte

+ func (x *SetNetmapStatusResponse) StableSize() (size int)

type SetShardModeRequest

+ func (x *SetShardModeRequest) StableMarshal(buf []byte) []byte

+ func (x *SetShardModeRequest) StableSize() (size int)

type SetShardModeResponse

+ func (x *SetShardModeResponse) StableMarshal(buf []byte) []byte

+ func (x *SetShardModeResponse) StableSize() (size int)

type Signature

+ func (x *Signature) StableMarshal(buf []byte) []byte

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

Apr 29, 2022

Changes in this version

type SetShardModeRequest_Body

+ ResetErrorCounter bool

+ func (x *SetShardModeRequest_Body) ClearErrorCounter(reset bool)

+ func (x *SetShardModeRequest_Body) GetResetErrorCounter() bool

type ShardInfo

+ ErrorCount uint32

+ func (x *ShardInfo) GetErrorCount() uint32

+ func (x *ShardInfo) SetErrorCount(count uint32)

type ShardMode

+ const ShardMode_DEGRADED

Jan 31, 2022

Changes in this version

type ControlServiceClient

+ DumpShard func(ctx context.Context, in *DumpShardRequest, opts ...grpc.CallOption) (*DumpShardResponse, error)

+ RestoreShard func(ctx context.Context, in *RestoreShardRequest, opts ...grpc.CallOption) (*RestoreShardResponse, error)

type ControlServiceServer

+ DumpShard func(context.Context, *DumpShardRequest) (*DumpShardResponse, error)

+ RestoreShard func(context.Context, *RestoreShardRequest) (*RestoreShardResponse, error)

+ type DumpShardRequest struct

+ Body *DumpShardRequest_Body

+ Signature *Signature

+ func (*DumpShardRequest) Descriptor() ([]byte, []int)

+ func (*DumpShardRequest) ProtoMessage()

+ func (x *DumpShardRequest) GetBody() *DumpShardRequest_Body

+ func (x *DumpShardRequest) GetSignature() *Signature

+ func (x *DumpShardRequest) ProtoReflect() protoreflect.Message

+ func (x *DumpShardRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *DumpShardRequest) Reset()

+ func (x *DumpShardRequest) SetBody(v *DumpShardRequest_Body)

+ func (x *DumpShardRequest) SetSignature(v *Signature)

+ func (x *DumpShardRequest) SignedDataSize() int

+ func (x *DumpShardRequest) String() string

+ type DumpShardRequest_Body struct

+ Filepath string

+ IgnoreErrors bool

+ Shard_ID []byte

+ func (*DumpShardRequest_Body) Descriptor() ([]byte, []int)

+ func (*DumpShardRequest_Body) ProtoMessage()

+ func (x *DumpShardRequest_Body) GetFilepath() string

+ func (x *DumpShardRequest_Body) GetIgnoreErrors() bool

+ func (x *DumpShardRequest_Body) GetShard_ID() []byte

+ func (x *DumpShardRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *DumpShardRequest_Body) Reset()

+ func (x *DumpShardRequest_Body) SetFilepath(p string)

+ func (x *DumpShardRequest_Body) SetIgnoreErrors(ignore bool)

+ func (x *DumpShardRequest_Body) SetShardID(id []byte)

+ func (x *DumpShardRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *DumpShardRequest_Body) StableSize() int

+ func (x *DumpShardRequest_Body) String() string

+ type DumpShardResponse struct

+ Body *DumpShardResponse_Body

+ Signature *Signature

+ func DumpShard(cli *client.Client, req *DumpShardRequest, opts ...client.CallOption) (*DumpShardResponse, error)

+ func (*DumpShardResponse) Descriptor() ([]byte, []int)

+ func (*DumpShardResponse) ProtoMessage()

+ func (x *DumpShardResponse) GetBody() *DumpShardResponse_Body

+ func (x *DumpShardResponse) GetSignature() *Signature

+ func (x *DumpShardResponse) ProtoReflect() protoreflect.Message

+ func (x *DumpShardResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *DumpShardResponse) Reset()

+ func (x *DumpShardResponse) SetBody(v *DumpShardResponse_Body)

+ func (x *DumpShardResponse) SetSignature(v *Signature)

+ func (x *DumpShardResponse) SignedDataSize() int

+ func (x *DumpShardResponse) String() string

+ type DumpShardResponse_Body struct

+ func (*DumpShardResponse_Body) Descriptor() ([]byte, []int)

+ func (*DumpShardResponse_Body) ProtoMessage()

+ func (x *DumpShardResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *DumpShardResponse_Body) Reset()

+ func (x *DumpShardResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *DumpShardResponse_Body) StableSize() int

+ func (x *DumpShardResponse_Body) String() string

+ type RestoreShardRequest struct

+ Body *RestoreShardRequest_Body

+ Signature *Signature

+ func (*RestoreShardRequest) Descriptor() ([]byte, []int)

+ func (*RestoreShardRequest) ProtoMessage()

+ func (x *RestoreShardRequest) GetBody() *RestoreShardRequest_Body

+ func (x *RestoreShardRequest) GetSignature() *Signature

+ func (x *RestoreShardRequest) ProtoReflect() protoreflect.Message

+ func (x *RestoreShardRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *RestoreShardRequest) Reset()

+ func (x *RestoreShardRequest) SetBody(v *RestoreShardRequest_Body)

+ func (x *RestoreShardRequest) SetSignature(v *Signature)

+ func (x *RestoreShardRequest) SignedDataSize() int

+ func (x *RestoreShardRequest) String() string

+ type RestoreShardRequest_Body struct

+ Filepath string

+ IgnoreErrors bool

+ Shard_ID []byte

+ func (*RestoreShardRequest_Body) Descriptor() ([]byte, []int)

+ func (*RestoreShardRequest_Body) ProtoMessage()

+ func (x *RestoreShardRequest_Body) GetFilepath() string

+ func (x *RestoreShardRequest_Body) GetIgnoreErrors() bool

+ func (x *RestoreShardRequest_Body) GetShard_ID() []byte

+ func (x *RestoreShardRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *RestoreShardRequest_Body) Reset()

+ func (x *RestoreShardRequest_Body) SetFilepath(p string)

+ func (x *RestoreShardRequest_Body) SetIgnoreErrors(ignore bool)

+ func (x *RestoreShardRequest_Body) SetShardID(id []byte)

+ func (x *RestoreShardRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *RestoreShardRequest_Body) StableSize() int

+ func (x *RestoreShardRequest_Body) String() string

+ type RestoreShardResponse struct

+ Body *RestoreShardResponse_Body

+ Signature *Signature

+ func RestoreShard(cli *client.Client, req *RestoreShardRequest, opts ...client.CallOption) (*RestoreShardResponse, error)

+ func (*RestoreShardResponse) Descriptor() ([]byte, []int)

+ func (*RestoreShardResponse) ProtoMessage()

+ func (x *RestoreShardResponse) GetBody() *RestoreShardResponse_Body

+ func (x *RestoreShardResponse) GetSignature() *Signature

+ func (x *RestoreShardResponse) ProtoReflect() protoreflect.Message

+ func (x *RestoreShardResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *RestoreShardResponse) Reset()

+ func (x *RestoreShardResponse) SetBody(v *RestoreShardResponse_Body)

+ func (x *RestoreShardResponse) SetSignature(v *Signature)

+ func (x *RestoreShardResponse) SignedDataSize() int

+ func (x *RestoreShardResponse) String() string

+ type RestoreShardResponse_Body struct

+ func (*RestoreShardResponse_Body) Descriptor() ([]byte, []int)

+ func (*RestoreShardResponse_Body) ProtoMessage()

+ func (x *RestoreShardResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *RestoreShardResponse_Body) Reset()

+ func (x *RestoreShardResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *RestoreShardResponse_Body) StableSize() int

+ func (x *RestoreShardResponse_Body) String() string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) DumpShard(context.Context, *DumpShardRequest) (*DumpShardResponse, error)

+ func (UnimplementedControlServiceServer) RestoreShard(context.Context, *RestoreShardRequest) (*RestoreShardResponse, error)

Dec 30, 2021

Changes in this version

type ControlServiceClient

+ SetShardMode func(ctx context.Context, in *SetShardModeRequest, opts ...grpc.CallOption) (*SetShardModeResponse, error)

type ControlServiceServer

+ SetShardMode func(context.Context, *SetShardModeRequest) (*SetShardModeResponse, error)

+ type SetShardModeRequest struct

+ Body *SetShardModeRequest_Body

+ Signature *Signature

+ func (*SetShardModeRequest) Descriptor() ([]byte, []int)

+ func (*SetShardModeRequest) ProtoMessage()

+ func (x *SetShardModeRequest) GetBody() *SetShardModeRequest_Body

+ func (x *SetShardModeRequest) GetSignature() *Signature

+ func (x *SetShardModeRequest) ProtoReflect() protoreflect.Message

+ func (x *SetShardModeRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SetShardModeRequest) Reset()

+ func (x *SetShardModeRequest) SetBody(v *SetShardModeRequest_Body)

+ func (x *SetShardModeRequest) SetSignature(v *Signature)

+ func (x *SetShardModeRequest) SignedDataSize() int

+ func (x *SetShardModeRequest) String() string

+ type SetShardModeRequest_Body struct

+ Mode ShardMode

+ Shard_ID []byte

+ func (*SetShardModeRequest_Body) Descriptor() ([]byte, []int)

+ func (*SetShardModeRequest_Body) ProtoMessage()

+ func (x *SetShardModeRequest_Body) GetMode() ShardMode

+ func (x *SetShardModeRequest_Body) GetShard_ID() []byte

+ func (x *SetShardModeRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *SetShardModeRequest_Body) Reset()

+ func (x *SetShardModeRequest_Body) SetMode(v ShardMode)

+ func (x *SetShardModeRequest_Body) SetShardID(v []byte)

+ func (x *SetShardModeRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *SetShardModeRequest_Body) StableSize() int

+ func (x *SetShardModeRequest_Body) String() string

+ type SetShardModeResponse struct

+ Body *SetShardModeResponse_Body

+ Signature *Signature

+ func SetShardMode(cli *client.Client, req *SetShardModeRequest, opts ...client.CallOption) (*SetShardModeResponse, error)

+ func (*SetShardModeResponse) Descriptor() ([]byte, []int)

+ func (*SetShardModeResponse) ProtoMessage()

+ func (x *SetShardModeResponse) GetBody() *SetShardModeResponse_Body

+ func (x *SetShardModeResponse) GetSignature() *Signature

+ func (x *SetShardModeResponse) ProtoReflect() protoreflect.Message

+ func (x *SetShardModeResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SetShardModeResponse) Reset()

+ func (x *SetShardModeResponse) SetBody(v *SetShardModeResponse_Body)

+ func (x *SetShardModeResponse) SetSignature(v *Signature)

+ func (x *SetShardModeResponse) SignedDataSize() int

+ func (x *SetShardModeResponse) String() string

+ type SetShardModeResponse_Body struct

+ func (*SetShardModeResponse_Body) Descriptor() ([]byte, []int)

+ func (*SetShardModeResponse_Body) ProtoMessage()

+ func (x *SetShardModeResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *SetShardModeResponse_Body) Reset()

+ func (x *SetShardModeResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *SetShardModeResponse_Body) StableSize() int

+ func (x *SetShardModeResponse_Body) String() string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) SetShardMode(context.Context, *SetShardModeRequest) (*SetShardModeResponse, error)

Dec 28, 2021

Changes in this version

+ var ShardMode_name = map[int32]string

+ var ShardMode_value = map[string]int32

type ControlServiceClient

+ ListShards func(ctx context.Context, in *ListShardsRequest, opts ...grpc.CallOption) (*ListShardsResponse, error)

type ControlServiceServer

+ ListShards func(context.Context, *ListShardsRequest) (*ListShardsResponse, error)

+ type ListShardsRequest struct

+ Body *ListShardsRequest_Body

+ Signature *Signature

+ func (*ListShardsRequest) Descriptor() ([]byte, []int)

+ func (*ListShardsRequest) ProtoMessage()

+ func (x *ListShardsRequest) GetBody() *ListShardsRequest_Body

+ func (x *ListShardsRequest) GetSignature() *Signature

+ func (x *ListShardsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListShardsRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ListShardsRequest) Reset()

+ func (x *ListShardsRequest) SetBody(v *ListShardsRequest_Body)

+ func (x *ListShardsRequest) SetSignature(body *Signature)

+ func (x *ListShardsRequest) SignedDataSize() int

+ func (x *ListShardsRequest) String() string

+ type ListShardsRequest_Body struct

+ func (*ListShardsRequest_Body) Descriptor() ([]byte, []int)

+ func (*ListShardsRequest_Body) ProtoMessage()

+ func (x *ListShardsRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *ListShardsRequest_Body) Reset()

+ func (x *ListShardsRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *ListShardsRequest_Body) StableSize() int

+ func (x *ListShardsRequest_Body) String() string

+ type ListShardsResponse struct

+ Body *ListShardsResponse_Body

+ Signature *Signature

+ func ListShards(cli *client.Client, req *ListShardsRequest, opts ...client.CallOption) (*ListShardsResponse, error)

+ func (*ListShardsResponse) Descriptor() ([]byte, []int)

+ func (*ListShardsResponse) ProtoMessage()

+ func (x *ListShardsResponse) GetBody() *ListShardsResponse_Body

+ func (x *ListShardsResponse) GetSignature() *Signature

+ func (x *ListShardsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListShardsResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *ListShardsResponse) Reset()

+ func (x *ListShardsResponse) SetBody(v *ListShardsResponse_Body)

+ func (x *ListShardsResponse) SetSignature(v *Signature)

+ func (x *ListShardsResponse) SignedDataSize() int

+ func (x *ListShardsResponse) String() string

+ type ListShardsResponse_Body struct

+ Shards []*ShardInfo

+ func (*ListShardsResponse_Body) Descriptor() ([]byte, []int)

+ func (*ListShardsResponse_Body) ProtoMessage()

+ func (x *ListShardsResponse_Body) GetShards() []*ShardInfo

+ func (x *ListShardsResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *ListShardsResponse_Body) Reset()

+ func (x *ListShardsResponse_Body) SetShards(v []*ShardInfo)

+ func (x *ListShardsResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *ListShardsResponse_Body) StableSize() int

+ func (x *ListShardsResponse_Body) String() string

+ type ShardInfo struct

+ BlobstorPath string

+ MetabasePath string

+ Mode ShardMode

+ Shard_ID []byte

+ WritecachePath string

+ func (*ShardInfo) Descriptor() ([]byte, []int)

+ func (*ShardInfo) ProtoMessage()

+ func (x *ShardInfo) GetBlobstorPath() string

+ func (x *ShardInfo) GetMetabasePath() string

+ func (x *ShardInfo) GetMode() ShardMode

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

+ func (x *ShardInfo) GetWritecachePath() string

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

+ func (x *ShardInfo) Reset()

+ func (x *ShardInfo) SetBlobstorPath(v string)

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

+ func (x *ShardInfo) SetMetabasePath(v string)

+ func (x *ShardInfo) SetMode(v ShardMode)

+ func (x *ShardInfo) SetWriteCachePath(v string)

+ func (x *ShardInfo) StableMarshal(buf []byte) ([]byte, error)

+ func (x *ShardInfo) StableSize() int

+ func (x *ShardInfo) String() string

+ type ShardMode int32

+ const ShardMode_READ_ONLY

+ const ShardMode_READ_WRITE

+ const ShardMode_SHARD_MODE_UNDEFINED

+ func (ShardMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (ShardMode) Type() protoreflect.EnumType

+ func (x ShardMode) Enum() *ShardMode

+ func (x ShardMode) Number() protoreflect.EnumNumber

+ func (x ShardMode) String() string

type UnimplementedControlServiceServer

+ func (UnimplementedControlServiceServer) ListShards(context.Context, *ListShardsRequest) (*ListShardsResponse, error)

Dec 9, 2021

Changes in this version

type NetmapStatus

+ const NetmapStatus_MAINTENANCE

Oct 19, 2021

Changes in this version

+ var ControlService_ServiceDesc = grpc.ServiceDesc

+ type UnsafeControlServiceServer interface

Jun 29, 2021

Changes in this version

type NodeInfo

+ Addresses []string

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

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

Mar 22, 2021

Changes in this version

type DropObjectsResponse

+ func DropObjects(cli *client.Client, req *DropObjectsRequest, opts ...client.CallOption) (*DropObjectsResponse, error)

type HealthCheckResponse

+ func HealthCheck(cli *client.Client, req *HealthCheckRequest, opts ...client.CallOption) (*HealthCheckResponse, error)

type NetmapSnapshotResponse

+ func NetmapSnapshot(cli *client.Client, req *NetmapSnapshotRequest, opts ...client.CallOption) (*NetmapSnapshotResponse, error)

type SetNetmapStatusResponse

+ func SetNetmapStatus(cli *client.Client, req *SetNetmapStatusRequest, opts ...client.CallOption) (*SetNetmapStatusResponse, error)

Feb 26, 2021

Changes in this version

type ControlServiceClient

+ DropObjects func(ctx context.Context, in *DropObjectsRequest, opts ...grpc.CallOption) (*DropObjectsResponse, error)

type ControlServiceServer

+ DropObjects func(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)

+ type DropObjectsRequest struct

+ Body *DropObjectsRequest_Body

+ Signature *Signature

+ func (*DropObjectsRequest) Descriptor() ([]byte, []int)

+ func (*DropObjectsRequest) ProtoMessage()

+ func (x *DropObjectsRequest) GetBody() *DropObjectsRequest_Body

+ func (x *DropObjectsRequest) GetSignature() *Signature

+ func (x *DropObjectsRequest) ProtoReflect() protoreflect.Message

+ func (x *DropObjectsRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *DropObjectsRequest) Reset()

+ func (x *DropObjectsRequest) SetBody(v *DropObjectsRequest_Body)

+ func (x *DropObjectsRequest) SetSignature(body *Signature)

+ func (x *DropObjectsRequest) SignedDataSize() int

+ func (x *DropObjectsRequest) String() string

+ type DropObjectsRequest_Body struct

+ AddressList [][]byte

+ func (*DropObjectsRequest_Body) Descriptor() ([]byte, []int)

+ func (*DropObjectsRequest_Body) ProtoMessage()

+ func (x *DropObjectsRequest_Body) GetAddressList() [][]byte

+ func (x *DropObjectsRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *DropObjectsRequest_Body) Reset()

+ func (x *DropObjectsRequest_Body) SetAddressList(v [][]byte)

+ func (x *DropObjectsRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *DropObjectsRequest_Body) StableSize() int

+ func (x *DropObjectsRequest_Body) String() string

+ type DropObjectsResponse struct

+ Body *DropObjectsResponse_Body

+ Signature *Signature

+ func (*DropObjectsResponse) Descriptor() ([]byte, []int)

+ func (*DropObjectsResponse) ProtoMessage()

+ func (x *DropObjectsResponse) GetBody() *DropObjectsResponse_Body

+ func (x *DropObjectsResponse) GetSignature() *Signature

+ func (x *DropObjectsResponse) ProtoReflect() protoreflect.Message

+ func (x *DropObjectsResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *DropObjectsResponse) Reset()

+ func (x *DropObjectsResponse) SetBody(v *DropObjectsResponse_Body)

+ func (x *DropObjectsResponse) SetSignature(v *Signature)

+ func (x *DropObjectsResponse) SignedDataSize() int

+ func (x *DropObjectsResponse) String() string

+ type DropObjectsResponse_Body struct

+ func (*DropObjectsResponse_Body) Descriptor() ([]byte, []int)

+ func (*DropObjectsResponse_Body) ProtoMessage()

+ func (x *DropObjectsResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *DropObjectsResponse_Body) Reset()

+ func (x *DropObjectsResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *DropObjectsResponse_Body) StableSize() int

+ func (x *DropObjectsResponse_Body) String() string

type UnimplementedControlServiceServer

+ func (*UnimplementedControlServiceServer) DropObjects(context.Context, *DropObjectsRequest) (*DropObjectsResponse, error)

Jan 15, 2021

Changes in this version

+ var File_pkg_services_control_service_proto protoreflect.FileDescriptor

+ var File_pkg_services_control_types_proto protoreflect.FileDescriptor

+ var HealthStatus_name = map[int32]string

+ var HealthStatus_value = map[string]int32

+ var NetmapStatus_name = map[int32]string

+ var NetmapStatus_value = map[string]int32

+ func RegisterControlServiceServer(s *grpc.Server, srv ControlServiceServer)

+ type ControlServiceClient interface

+ HealthCheck func(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)

+ NetmapSnapshot func(ctx context.Context, in *NetmapSnapshotRequest, opts ...grpc.CallOption) (*NetmapSnapshotResponse, error)

+ SetNetmapStatus func(ctx context.Context, in *SetNetmapStatusRequest, opts ...grpc.CallOption) (*SetNetmapStatusResponse, error)

+ func NewControlServiceClient(cc grpc.ClientConnInterface) ControlServiceClient

+ type ControlServiceServer interface

+ HealthCheck func(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

+ NetmapSnapshot func(context.Context, *NetmapSnapshotRequest) (*NetmapSnapshotResponse, error)

+ SetNetmapStatus func(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)

+ type HealthCheckRequest struct

+ Body *HealthCheckRequest_Body

+ Signature *Signature

+ func (*HealthCheckRequest) Descriptor() ([]byte, []int)

+ func (*HealthCheckRequest) ProtoMessage()

+ func (x *HealthCheckRequest) GetBody() *HealthCheckRequest_Body

+ func (x *HealthCheckRequest) GetSignature() *Signature

+ func (x *HealthCheckRequest) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *HealthCheckRequest) Reset()

+ func (x *HealthCheckRequest) SetBody(v *HealthCheckRequest_Body)

+ func (x *HealthCheckRequest) SetSignature(body *Signature)

+ func (x *HealthCheckRequest) SignedDataSize() int

+ func (x *HealthCheckRequest) String() string

+ type HealthCheckRequest_Body struct

+ func (*HealthCheckRequest_Body) Descriptor() ([]byte, []int)

+ func (*HealthCheckRequest_Body) ProtoMessage()

+ func (x *HealthCheckRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckRequest_Body) Reset()

+ func (x *HealthCheckRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *HealthCheckRequest_Body) StableSize() int

+ func (x *HealthCheckRequest_Body) String() string

+ type HealthCheckResponse struct

+ Body *HealthCheckResponse_Body

+ Signature *Signature

+ func (*HealthCheckResponse) Descriptor() ([]byte, []int)

+ func (*HealthCheckResponse) ProtoMessage()

+ func (x *HealthCheckResponse) GetBody() *HealthCheckResponse_Body

+ func (x *HealthCheckResponse) GetSignature() *Signature

+ func (x *HealthCheckResponse) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *HealthCheckResponse) Reset()

+ func (x *HealthCheckResponse) SetBody(v *HealthCheckResponse_Body)

+ func (x *HealthCheckResponse) SetSignature(v *Signature)

+ func (x *HealthCheckResponse) SignedDataSize() int

+ func (x *HealthCheckResponse) String() string

+ type HealthCheckResponse_Body struct

+ HealthStatus HealthStatus

+ NetmapStatus NetmapStatus

+ func (*HealthCheckResponse_Body) Descriptor() ([]byte, []int)

+ func (*HealthCheckResponse_Body) ProtoMessage()

+ func (x *HealthCheckResponse_Body) GetHealthStatus() HealthStatus

+ func (x *HealthCheckResponse_Body) GetNetmapStatus() NetmapStatus

+ func (x *HealthCheckResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *HealthCheckResponse_Body) Reset()

+ func (x *HealthCheckResponse_Body) SetHealthStatus(v HealthStatus)

+ func (x *HealthCheckResponse_Body) SetNetmapStatus(v NetmapStatus)

+ func (x *HealthCheckResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *HealthCheckResponse_Body) StableSize() int

+ func (x *HealthCheckResponse_Body) String() string

+ type HealthStatus int32

+ const HealthStatus_HEALTH_STATUS_UNDEFINED

+ const HealthStatus_READY

+ const HealthStatus_SHUTTING_DOWN

+ const HealthStatus_STARTING

+ func (HealthStatus) Descriptor() protoreflect.EnumDescriptor

+ func (HealthStatus) EnumDescriptor() ([]byte, []int)

+ func (HealthStatus) Type() protoreflect.EnumType

+ func (x HealthStatus) Enum() *HealthStatus

+ func (x HealthStatus) Number() protoreflect.EnumNumber

+ func (x HealthStatus) String() string

+ type Netmap struct

+ Epoch uint64

+ Nodes []*NodeInfo

+ func (*Netmap) Descriptor() ([]byte, []int)

+ func (*Netmap) ProtoMessage()

+ func (x *Netmap) GetEpoch() uint64

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

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

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

+ func (x *Netmap) Reset()

+ func (x *Netmap) SetEpoch(v uint64)

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

+ func (x *Netmap) StableMarshal(buf []byte) ([]byte, error)

+ func (x *Netmap) StableSize() int

+ func (x *Netmap) String() string

+ type NetmapSnapshotRequest struct

+ Body *NetmapSnapshotRequest_Body

+ Signature *Signature

+ func (*NetmapSnapshotRequest) Descriptor() ([]byte, []int)

+ func (*NetmapSnapshotRequest) ProtoMessage()

+ func (x *NetmapSnapshotRequest) GetBody() *NetmapSnapshotRequest_Body

+ func (x *NetmapSnapshotRequest) GetSignature() *Signature

+ func (x *NetmapSnapshotRequest) ProtoReflect() protoreflect.Message

+ func (x *NetmapSnapshotRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *NetmapSnapshotRequest) Reset()

+ func (x *NetmapSnapshotRequest) SetBody(v *NetmapSnapshotRequest_Body)

+ func (x *NetmapSnapshotRequest) SetSignature(body *Signature)

+ func (x *NetmapSnapshotRequest) SignedDataSize() int

+ func (x *NetmapSnapshotRequest) String() string

+ type NetmapSnapshotRequest_Body struct

+ func (*NetmapSnapshotRequest_Body) Descriptor() ([]byte, []int)

+ func (*NetmapSnapshotRequest_Body) ProtoMessage()

+ func (x *NetmapSnapshotRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *NetmapSnapshotRequest_Body) Reset()

+ func (x *NetmapSnapshotRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *NetmapSnapshotRequest_Body) StableSize() int

+ func (x *NetmapSnapshotRequest_Body) String() string

+ type NetmapSnapshotResponse struct

+ Body *NetmapSnapshotResponse_Body

+ Signature *Signature

+ func (*NetmapSnapshotResponse) Descriptor() ([]byte, []int)

+ func (*NetmapSnapshotResponse) ProtoMessage()

+ func (x *NetmapSnapshotResponse) GetBody() *NetmapSnapshotResponse_Body

+ func (x *NetmapSnapshotResponse) GetSignature() *Signature

+ func (x *NetmapSnapshotResponse) ProtoReflect() protoreflect.Message

+ func (x *NetmapSnapshotResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *NetmapSnapshotResponse) Reset()

+ func (x *NetmapSnapshotResponse) SetBody(v *NetmapSnapshotResponse_Body)

+ func (x *NetmapSnapshotResponse) SetSignature(v *Signature)

+ func (x *NetmapSnapshotResponse) SignedDataSize() int

+ func (x *NetmapSnapshotResponse) String() string

+ type NetmapSnapshotResponse_Body struct

+ Netmap *Netmap

+ func (*NetmapSnapshotResponse_Body) Descriptor() ([]byte, []int)

+ func (*NetmapSnapshotResponse_Body) ProtoMessage()

+ func (x *NetmapSnapshotResponse_Body) GetNetmap() *Netmap

+ func (x *NetmapSnapshotResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *NetmapSnapshotResponse_Body) Reset()

+ func (x *NetmapSnapshotResponse_Body) SetNetmap(v *Netmap)

+ func (x *NetmapSnapshotResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *NetmapSnapshotResponse_Body) StableSize() int

+ func (x *NetmapSnapshotResponse_Body) String() string

+ type NetmapStatus int32

+ const NetmapStatus_OFFLINE

+ const NetmapStatus_ONLINE

+ const NetmapStatus_STATUS_UNDEFINED

+ func (NetmapStatus) Descriptor() protoreflect.EnumDescriptor

+ func (NetmapStatus) EnumDescriptor() ([]byte, []int)

+ func (NetmapStatus) Type() protoreflect.EnumType

+ func (x NetmapStatus) Enum() *NetmapStatus

+ func (x NetmapStatus) Number() protoreflect.EnumNumber

+ func (x NetmapStatus) String() string

+ type NodeInfo struct

+ Address string

+ Attributes []*NodeInfo_Attribute

+ PublicKey []byte

+ State NetmapStatus

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

+ func (*NodeInfo) ProtoMessage()

+ func (x *NodeInfo) GetAddress() string

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

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

+ func (x *NodeInfo) GetState() NetmapStatus

+ func (x *NodeInfo) ProtoReflect() protoreflect.Message

+ func (x *NodeInfo) Reset()

+ func (x *NodeInfo) SetAddress(v string)

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

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

+ func (x *NodeInfo) SetState(v NetmapStatus)

+ func (x *NodeInfo) StableMarshal(buf []byte) ([]byte, error)

+ func (x *NodeInfo) StableSize() int

+ func (x *NodeInfo) String() string

+ type NodeInfo_Attribute struct

+ Key string

+ Parents []string

+ Value string

+ func (*NodeInfo_Attribute) Descriptor() ([]byte, []int)

+ func (*NodeInfo_Attribute) ProtoMessage()

+ func (x *NodeInfo_Attribute) GetKey() string

+ func (x *NodeInfo_Attribute) GetParents() []string

+ func (x *NodeInfo_Attribute) GetValue() string

+ func (x *NodeInfo_Attribute) ProtoReflect() protoreflect.Message

+ func (x *NodeInfo_Attribute) Reset()

+ func (x *NodeInfo_Attribute) SetKey(v string)

+ func (x *NodeInfo_Attribute) SetParents(v []string)

+ func (x *NodeInfo_Attribute) SetValue(v string)

+ func (x *NodeInfo_Attribute) StableMarshal(buf []byte) ([]byte, error)

+ func (x *NodeInfo_Attribute) StableSize() int

+ func (x *NodeInfo_Attribute) String() string

+ type SetNetmapStatusRequest struct

+ Body *SetNetmapStatusRequest_Body

+ Signature *Signature

+ func (*SetNetmapStatusRequest) Descriptor() ([]byte, []int)

+ func (*SetNetmapStatusRequest) ProtoMessage()

+ func (x *SetNetmapStatusRequest) GetBody() *SetNetmapStatusRequest_Body

+ func (x *SetNetmapStatusRequest) GetSignature() *Signature

+ func (x *SetNetmapStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *SetNetmapStatusRequest) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SetNetmapStatusRequest) Reset()

+ func (x *SetNetmapStatusRequest) SetBody(v *SetNetmapStatusRequest_Body)

+ func (x *SetNetmapStatusRequest) SetSignature(body *Signature)

+ func (x *SetNetmapStatusRequest) SignedDataSize() int

+ func (x *SetNetmapStatusRequest) String() string

+ type SetNetmapStatusRequest_Body struct

+ Status NetmapStatus

+ func (*SetNetmapStatusRequest_Body) Descriptor() ([]byte, []int)

+ func (*SetNetmapStatusRequest_Body) ProtoMessage()

+ func (x *SetNetmapStatusRequest_Body) GetStatus() NetmapStatus

+ func (x *SetNetmapStatusRequest_Body) ProtoReflect() protoreflect.Message

+ func (x *SetNetmapStatusRequest_Body) Reset()

+ func (x *SetNetmapStatusRequest_Body) SetStatus(v NetmapStatus)

+ func (x *SetNetmapStatusRequest_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *SetNetmapStatusRequest_Body) StableSize() int

+ func (x *SetNetmapStatusRequest_Body) String() string

+ type SetNetmapStatusResponse struct

+ Body *SetNetmapStatusResponse_Body

+ Signature *Signature

+ func (*SetNetmapStatusResponse) Descriptor() ([]byte, []int)

+ func (*SetNetmapStatusResponse) ProtoMessage()

+ func (x *SetNetmapStatusResponse) GetBody() *SetNetmapStatusResponse_Body

+ func (x *SetNetmapStatusResponse) GetSignature() *Signature

+ func (x *SetNetmapStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *SetNetmapStatusResponse) ReadSignedData(buf []byte) ([]byte, error)

+ func (x *SetNetmapStatusResponse) Reset()

+ func (x *SetNetmapStatusResponse) SetBody(v *SetNetmapStatusResponse_Body)

+ func (x *SetNetmapStatusResponse) SetSignature(v *Signature)

+ func (x *SetNetmapStatusResponse) SignedDataSize() int

+ func (x *SetNetmapStatusResponse) String() string

+ type SetNetmapStatusResponse_Body struct

+ func (*SetNetmapStatusResponse_Body) Descriptor() ([]byte, []int)

+ func (*SetNetmapStatusResponse_Body) ProtoMessage()

+ func (x *SetNetmapStatusResponse_Body) ProtoReflect() protoreflect.Message

+ func (x *SetNetmapStatusResponse_Body) Reset()

+ func (x *SetNetmapStatusResponse_Body) StableMarshal(buf []byte) ([]byte, error)

+ func (x *SetNetmapStatusResponse_Body) StableSize() int

+ func (x *SetNetmapStatusResponse_Body) String() string

+ type Signature struct

+ Key []byte

+ Sign []byte

+ func (*Signature) Descriptor() ([]byte, []int)

+ func (*Signature) ProtoMessage()

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

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

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

+ func (x *Signature) Reset()

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

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

+ func (x *Signature) String() string

+ type UnimplementedControlServiceServer struct

+ func (*UnimplementedControlServiceServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

+ func (*UnimplementedControlServiceServer) NetmapSnapshot(context.Context, *NetmapSnapshotRequest) (*NetmapSnapshotResponse, error)

+ func (*UnimplementedControlServiceServer) SetNetmapStatus(context.Context, *SetNetmapStatusRequest) (*SetNetmapStatusResponse, error)