control

package
v0.38.6 Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ControlService_HealthCheck_FullMethodName                       = "/control.ControlService/HealthCheck"
	ControlService_SetNetmapStatus_FullMethodName                   = "/control.ControlService/SetNetmapStatus"
	ControlService_DropObjects_FullMethodName                       = "/control.ControlService/DropObjects"
	ControlService_ListShards_FullMethodName                        = "/control.ControlService/ListShards"
	ControlService_SetShardMode_FullMethodName                      = "/control.ControlService/SetShardMode"
	ControlService_SynchronizeTree_FullMethodName                   = "/control.ControlService/SynchronizeTree"
	ControlService_EvacuateShard_FullMethodName                     = "/control.ControlService/EvacuateShard"
	ControlService_StartShardEvacuation_FullMethodName              = "/control.ControlService/StartShardEvacuation"
	ControlService_GetShardEvacuationStatus_FullMethodName          = "/control.ControlService/GetShardEvacuationStatus"
	ControlService_ResetShardEvacuationStatus_FullMethodName        = "/control.ControlService/ResetShardEvacuationStatus"
	ControlService_StopShardEvacuation_FullMethodName               = "/control.ControlService/StopShardEvacuation"
	ControlService_FlushCache_FullMethodName                        = "/control.ControlService/FlushCache"
	ControlService_Doctor_FullMethodName                            = "/control.ControlService/Doctor"
	ControlService_AddChainLocalOverride_FullMethodName             = "/control.ControlService/AddChainLocalOverride"
	ControlService_GetChainLocalOverride_FullMethodName             = "/control.ControlService/GetChainLocalOverride"
	ControlService_ListChainLocalOverrides_FullMethodName           = "/control.ControlService/ListChainLocalOverrides"
	ControlService_RemoveChainLocalOverride_FullMethodName          = "/control.ControlService/RemoveChainLocalOverride"
	ControlService_RemoveChainLocalOverridesByTarget_FullMethodName = "/control.ControlService/RemoveChainLocalOverridesByTarget"
	ControlService_ListTargetsLocalOverrides_FullMethodName         = "/control.ControlService/ListTargetsLocalOverrides"
	ControlService_SealWriteCache_FullMethodName                    = "/control.ControlService/SealWriteCache"
	ControlService_DetachShards_FullMethodName                      = "/control.ControlService/DetachShards"
)

Variables

View Source
var (
	StartShardEvacuationRequest_Body_Scope_name = map[int32]string{
		0: "NONE",
		1: "OBJECTS",
		2: "TREES",
	}
	StartShardEvacuationRequest_Body_Scope_value = map[string]int32{
		"NONE":    0,
		"OBJECTS": 1,
		"TREES":   2,
	}
)

Enum value maps for StartShardEvacuationRequest_Body_Scope.

View Source
var (
	GetShardEvacuationStatusResponse_Body_Status_name = map[int32]string{
		0: "EVACUATE_SHARD_STATUS_UNDEFINED",
		1: "RUNNING",
		2: "COMPLETED",
	}
	GetShardEvacuationStatusResponse_Body_Status_value = map[string]int32{
		"EVACUATE_SHARD_STATUS_UNDEFINED": 0,
		"RUNNING":                         1,
		"COMPLETED":                       2,
	}
)

Enum value maps for GetShardEvacuationStatusResponse_Body_Status.

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",
		4: "RECONFIGURING",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNDEFINED": 0,
		"STARTING":                1,
		"READY":                   2,
		"SHUTTING_DOWN":           3,
		"RECONFIGURING":           4,
	}
)

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 (
	ChainTarget_TargetType_name = map[int32]string{
		0: "UNDEFINED",
		1: "NAMESPACE",
		2: "CONTAINER",
		3: "USER",
		4: "GROUP",
	}
	ChainTarget_TargetType_value = map[string]int32{
		"UNDEFINED": 0,
		"NAMESPACE": 1,
		"CONTAINER": 2,
		"USER":      3,
		"GROUP":     4,
	}
)

Enum value maps for ChainTarget_TargetType.

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: "SynchronizeTree",
			Handler:    _ControlService_SynchronizeTree_Handler,
		},
		{
			MethodName: "EvacuateShard",
			Handler:    _ControlService_EvacuateShard_Handler,
		},
		{
			MethodName: "StartShardEvacuation",
			Handler:    _ControlService_StartShardEvacuation_Handler,
		},
		{
			MethodName: "GetShardEvacuationStatus",
			Handler:    _ControlService_GetShardEvacuationStatus_Handler,
		},
		{
			MethodName: "ResetShardEvacuationStatus",
			Handler:    _ControlService_ResetShardEvacuationStatus_Handler,
		},
		{
			MethodName: "StopShardEvacuation",
			Handler:    _ControlService_StopShardEvacuation_Handler,
		},
		{
			MethodName: "FlushCache",
			Handler:    _ControlService_FlushCache_Handler,
		},
		{
			MethodName: "Doctor",
			Handler:    _ControlService_Doctor_Handler,
		},
		{
			MethodName: "AddChainLocalOverride",
			Handler:    _ControlService_AddChainLocalOverride_Handler,
		},
		{
			MethodName: "GetChainLocalOverride",
			Handler:    _ControlService_GetChainLocalOverride_Handler,
		},
		{
			MethodName: "ListChainLocalOverrides",
			Handler:    _ControlService_ListChainLocalOverrides_Handler,
		},
		{
			MethodName: "RemoveChainLocalOverride",
			Handler:    _ControlService_RemoveChainLocalOverride_Handler,
		},
		{
			MethodName: "RemoveChainLocalOverridesByTarget",
			Handler:    _ControlService_RemoveChainLocalOverridesByTarget_Handler,
		},
		{
			MethodName: "ListTargetsLocalOverrides",
			Handler:    _ControlService_ListTargetsLocalOverrides_Handler,
		},
		{
			MethodName: "SealWriteCache",
			Handler:    _ControlService_SealWriteCache_Handler,
		},
		{
			MethodName: "DetachShards",
			Handler:    _ControlService_DetachShards_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 AddChainLocalOverrideRequest added in v0.38.0

type AddChainLocalOverrideRequest struct {
	Body      *AddChainLocalOverrideRequest_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
}

AddChainLocalOverride request.

func (*AddChainLocalOverrideRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use AddChainLocalOverrideRequest.ProtoReflect.Descriptor instead.

func (*AddChainLocalOverrideRequest) GetBody added in v0.38.0

func (*AddChainLocalOverrideRequest) GetSignature added in v0.38.0

func (x *AddChainLocalOverrideRequest) GetSignature() *Signature

func (*AddChainLocalOverrideRequest) ProtoMessage added in v0.38.0

func (*AddChainLocalOverrideRequest) ProtoMessage()

func (*AddChainLocalOverrideRequest) ProtoReflect added in v0.38.0

func (*AddChainLocalOverrideRequest) ReadSignedData added in v0.38.0

func (x *AddChainLocalOverrideRequest) 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 (*AddChainLocalOverrideRequest) Reset added in v0.38.0

func (x *AddChainLocalOverrideRequest) Reset()

func (*AddChainLocalOverrideRequest) SetSignature added in v0.38.0

func (x *AddChainLocalOverrideRequest) SetSignature(sig *Signature)

func (*AddChainLocalOverrideRequest) SignedDataSize added in v0.38.0

func (x *AddChainLocalOverrideRequest) 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 (*AddChainLocalOverrideRequest) StableMarshal added in v0.38.0

func (x *AddChainLocalOverrideRequest) 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 (*AddChainLocalOverrideRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*AddChainLocalOverrideRequest) String added in v0.38.0

type AddChainLocalOverrideRequest_Body added in v0.38.0

type AddChainLocalOverrideRequest_Body struct {

	// Target for which the overrides are applied.
	Target *ChainTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// Serialized rule chain. If chain ID is left empty
	// in the chain, then it will be generated and returned
	// in the response.
	Chain []byte `protobuf:"bytes,2,opt,name=chain,proto3" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

func (*AddChainLocalOverrideRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use AddChainLocalOverrideRequest_Body.ProtoReflect.Descriptor instead.

func (*AddChainLocalOverrideRequest_Body) GetChain added in v0.38.0

func (x *AddChainLocalOverrideRequest_Body) GetChain() []byte

func (*AddChainLocalOverrideRequest_Body) GetTarget added in v0.38.0

func (*AddChainLocalOverrideRequest_Body) ProtoMessage added in v0.38.0

func (*AddChainLocalOverrideRequest_Body) ProtoMessage()

func (*AddChainLocalOverrideRequest_Body) ProtoReflect added in v0.38.0

func (*AddChainLocalOverrideRequest_Body) Reset added in v0.38.0

func (*AddChainLocalOverrideRequest_Body) StableMarshal added in v0.38.0

func (x *AddChainLocalOverrideRequest_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 (*AddChainLocalOverrideRequest_Body) StableSize added in v0.38.0

func (x *AddChainLocalOverrideRequest_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 (*AddChainLocalOverrideRequest_Body) String added in v0.38.0

type AddChainLocalOverrideResponse added in v0.38.0

type AddChainLocalOverrideResponse struct {
	Body      *AddChainLocalOverrideResponse_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
}

AddChainLocalOverride response.

func AddChainLocalOverride added in v0.38.0

func AddChainLocalOverride(cli *client.Client, req *AddChainLocalOverrideRequest, opts ...client.CallOption) (*AddChainLocalOverrideResponse, error)

AddChainLocalOverride executes ControlService.AddChainLocalOverride RPC.

func (*AddChainLocalOverrideResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use AddChainLocalOverrideResponse.ProtoReflect.Descriptor instead.

func (*AddChainLocalOverrideResponse) GetBody added in v0.38.0

func (*AddChainLocalOverrideResponse) GetSignature added in v0.38.0

func (x *AddChainLocalOverrideResponse) GetSignature() *Signature

func (*AddChainLocalOverrideResponse) ProtoMessage added in v0.38.0

func (*AddChainLocalOverrideResponse) ProtoMessage()

func (*AddChainLocalOverrideResponse) ProtoReflect added in v0.38.0

func (*AddChainLocalOverrideResponse) ReadSignedData added in v0.38.0

func (x *AddChainLocalOverrideResponse) 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 (*AddChainLocalOverrideResponse) Reset added in v0.38.0

func (x *AddChainLocalOverrideResponse) Reset()

func (*AddChainLocalOverrideResponse) SetSignature added in v0.38.0

func (x *AddChainLocalOverrideResponse) SetSignature(sig *Signature)

func (*AddChainLocalOverrideResponse) SignedDataSize added in v0.38.0

func (x *AddChainLocalOverrideResponse) 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 (*AddChainLocalOverrideResponse) StableMarshal added in v0.38.0

func (x *AddChainLocalOverrideResponse) 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 (*AddChainLocalOverrideResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*AddChainLocalOverrideResponse) String added in v0.38.0

type AddChainLocalOverrideResponse_Body added in v0.38.0

type AddChainLocalOverrideResponse_Body struct {

	// Chain ID assigned for the added rule chain.
	// If chain ID is left empty in the request, then
	// it will be generated.
	ChainId []byte `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddChainLocalOverrideResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use AddChainLocalOverrideResponse_Body.ProtoReflect.Descriptor instead.

func (*AddChainLocalOverrideResponse_Body) GetChainId added in v0.38.0

func (x *AddChainLocalOverrideResponse_Body) GetChainId() []byte

func (*AddChainLocalOverrideResponse_Body) ProtoMessage added in v0.38.0

func (*AddChainLocalOverrideResponse_Body) ProtoMessage()

func (*AddChainLocalOverrideResponse_Body) ProtoReflect added in v0.38.0

func (*AddChainLocalOverrideResponse_Body) Reset added in v0.38.0

func (*AddChainLocalOverrideResponse_Body) StableMarshal added in v0.38.0

func (x *AddChainLocalOverrideResponse_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 (*AddChainLocalOverrideResponse_Body) StableSize added in v0.38.0

func (x *AddChainLocalOverrideResponse_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 (*AddChainLocalOverrideResponse_Body) String added in v0.38.0

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 ChainTarget added in v0.38.0

type ChainTarget struct {
	Type ChainTarget_TargetType `protobuf:"varint,1,opt,name=type,proto3,enum=control.ChainTarget_TargetType" json:"type,omitempty"`
	Name string                 `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

ChainTarget is an object to which local overrides are applied.

func (*ChainTarget) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ChainTarget.ProtoReflect.Descriptor instead.

func (*ChainTarget) GetName added in v0.38.0

func (x *ChainTarget) GetName() string

func (*ChainTarget) GetType added in v0.38.0

func (x *ChainTarget) GetType() ChainTarget_TargetType

func (*ChainTarget) ProtoMessage added in v0.38.0

func (*ChainTarget) ProtoMessage()

func (*ChainTarget) ProtoReflect added in v0.38.0

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

func (*ChainTarget) Reset added in v0.38.0

func (x *ChainTarget) Reset()

func (*ChainTarget) StableMarshal added in v0.38.0

func (x *ChainTarget) 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 (*ChainTarget) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ChainTarget) String added in v0.38.0

func (x *ChainTarget) String() string

type ChainTarget_TargetType added in v0.38.0

type ChainTarget_TargetType int32
const (
	ChainTarget_UNDEFINED ChainTarget_TargetType = 0
	ChainTarget_NAMESPACE ChainTarget_TargetType = 1
	ChainTarget_CONTAINER ChainTarget_TargetType = 2
	ChainTarget_USER      ChainTarget_TargetType = 3
	ChainTarget_GROUP     ChainTarget_TargetType = 4
)

func (ChainTarget_TargetType) Descriptor added in v0.38.0

func (ChainTarget_TargetType) Enum added in v0.38.0

func (ChainTarget_TargetType) EnumDescriptor deprecated added in v0.38.0

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

Deprecated: Use ChainTarget_TargetType.Descriptor instead.

func (ChainTarget_TargetType) Number added in v0.38.0

func (ChainTarget_TargetType) String added in v0.38.0

func (x ChainTarget_TargetType) String() string

func (ChainTarget_TargetType) Type added in v0.38.0

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)
	// 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.
	// Deprecated: Use
	// StartShardEvacuation/GetShardEvacuationStatus/StopShardEvacuation
	EvacuateShard(ctx context.Context, in *EvacuateShardRequest, opts ...grpc.CallOption) (*EvacuateShardResponse, error)
	// StartShardEvacuation starts moving all data from one shard to the others.
	StartShardEvacuation(ctx context.Context, in *StartShardEvacuationRequest, opts ...grpc.CallOption) (*StartShardEvacuationResponse, error)
	// GetShardEvacuationStatus returns evacuation status.
	GetShardEvacuationStatus(ctx context.Context, in *GetShardEvacuationStatusRequest, opts ...grpc.CallOption) (*GetShardEvacuationStatusResponse, error)
	// ResetShardEvacuationStatus resets evacuation status if there is no running
	// evacuation process.
	ResetShardEvacuationStatus(ctx context.Context, in *ResetShardEvacuationStatusRequest, opts ...grpc.CallOption) (*ResetShardEvacuationStatusResponse, error)
	// StopShardEvacuation stops moving all data from one shard to the others.
	StopShardEvacuation(ctx context.Context, in *StopShardEvacuationRequest, opts ...grpc.CallOption) (*StopShardEvacuationResponse, error)
	// FlushCache moves all data from one shard to the others.
	FlushCache(ctx context.Context, in *FlushCacheRequest, opts ...grpc.CallOption) (*FlushCacheResponse, error)
	// Doctor performs storage restructuring operations on engine.
	Doctor(ctx context.Context, in *DoctorRequest, opts ...grpc.CallOption) (*DoctorResponse, error)
	// Add local access policy engine overrides to a node.
	AddChainLocalOverride(ctx context.Context, in *AddChainLocalOverrideRequest, opts ...grpc.CallOption) (*AddChainLocalOverrideResponse, error)
	// Get local access policy engine overrides stored in the node by chain id.
	GetChainLocalOverride(ctx context.Context, in *GetChainLocalOverrideRequest, opts ...grpc.CallOption) (*GetChainLocalOverrideResponse, error)
	// List local access policy engine overrides stored in the node by container
	// id.
	ListChainLocalOverrides(ctx context.Context, in *ListChainLocalOverridesRequest, opts ...grpc.CallOption) (*ListChainLocalOverridesResponse, error)
	// Remove local access policy engine overrides stored in the node by chaind
	// id.
	RemoveChainLocalOverride(ctx context.Context, in *RemoveChainLocalOverrideRequest, opts ...grpc.CallOption) (*RemoveChainLocalOverrideResponse, error)
	// Remove local access policy engine overrides stored in the node by chaind
	// id.
	RemoveChainLocalOverridesByTarget(ctx context.Context, in *RemoveChainLocalOverridesByTargetRequest, opts ...grpc.CallOption) (*RemoveChainLocalOverridesByTargetResponse, error)
	// List targets of the local APE overrides stored in the node.
	ListTargetsLocalOverrides(ctx context.Context, in *ListTargetsLocalOverridesRequest, opts ...grpc.CallOption) (*ListTargetsLocalOverridesResponse, error)
	// Flush objects from write-cache and move it to degraded read only mode.
	SealWriteCache(ctx context.Context, in *SealWriteCacheRequest, opts ...grpc.CallOption) (*SealWriteCacheResponse, error)
	// DetachShards detaches and closes shards.
	DetachShards(ctx context.Context, in *DetachShardsRequest, opts ...grpc.CallOption) (*DetachShardsResponse, 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.

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)
	// Synchronizes all log operations for the specified tree.
	SynchronizeTree(context.Context, *SynchronizeTreeRequest) (*SynchronizeTreeResponse, error)
	// EvacuateShard moves all data from one shard to the others.
	// Deprecated: Use
	// StartShardEvacuation/GetShardEvacuationStatus/StopShardEvacuation
	EvacuateShard(context.Context, *EvacuateShardRequest) (*EvacuateShardResponse, error)
	// StartShardEvacuation starts moving all data from one shard to the others.
	StartShardEvacuation(context.Context, *StartShardEvacuationRequest) (*StartShardEvacuationResponse, error)
	// GetShardEvacuationStatus returns evacuation status.
	GetShardEvacuationStatus(context.Context, *GetShardEvacuationStatusRequest) (*GetShardEvacuationStatusResponse, error)
	// ResetShardEvacuationStatus resets evacuation status if there is no running
	// evacuation process.
	ResetShardEvacuationStatus(context.Context, *ResetShardEvacuationStatusRequest) (*ResetShardEvacuationStatusResponse, error)
	// StopShardEvacuation stops moving all data from one shard to the others.
	StopShardEvacuation(context.Context, *StopShardEvacuationRequest) (*StopShardEvacuationResponse, error)
	// FlushCache moves all data from one shard to the others.
	FlushCache(context.Context, *FlushCacheRequest) (*FlushCacheResponse, error)
	// Doctor performs storage restructuring operations on engine.
	Doctor(context.Context, *DoctorRequest) (*DoctorResponse, error)
	// Add local access policy engine overrides to a node.
	AddChainLocalOverride(context.Context, *AddChainLocalOverrideRequest) (*AddChainLocalOverrideResponse, error)
	// Get local access policy engine overrides stored in the node by chain id.
	GetChainLocalOverride(context.Context, *GetChainLocalOverrideRequest) (*GetChainLocalOverrideResponse, error)
	// List local access policy engine overrides stored in the node by container
	// id.
	ListChainLocalOverrides(context.Context, *ListChainLocalOverridesRequest) (*ListChainLocalOverridesResponse, error)
	// Remove local access policy engine overrides stored in the node by chaind
	// id.
	RemoveChainLocalOverride(context.Context, *RemoveChainLocalOverrideRequest) (*RemoveChainLocalOverrideResponse, error)
	// Remove local access policy engine overrides stored in the node by chaind
	// id.
	RemoveChainLocalOverridesByTarget(context.Context, *RemoveChainLocalOverridesByTargetRequest) (*RemoveChainLocalOverridesByTargetResponse, error)
	// List targets of the local APE overrides stored in the node.
	ListTargetsLocalOverrides(context.Context, *ListTargetsLocalOverridesRequest) (*ListTargetsLocalOverridesResponse, error)
	// Flush objects from write-cache and move it to degraded read only mode.
	SealWriteCache(context.Context, *SealWriteCacheRequest) (*SealWriteCacheResponse, error)
	// DetachShards detaches and closes shards.
	DetachShards(context.Context, *DetachShardsRequest) (*DetachShardsResponse, error)
}

ControlServiceServer is the server API for ControlService service. All implementations should embed UnimplementedControlServiceServer for forward compatibility

type DetachShardsRequest added in v0.38.0

type DetachShardsRequest struct {
	Body      *DetachShardsRequest_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
}

func (*DetachShardsRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use DetachShardsRequest.ProtoReflect.Descriptor instead.

func (*DetachShardsRequest) GetBody added in v0.38.0

func (*DetachShardsRequest) GetSignature added in v0.38.0

func (x *DetachShardsRequest) GetSignature() *Signature

func (*DetachShardsRequest) ProtoMessage added in v0.38.0

func (*DetachShardsRequest) ProtoMessage()

func (*DetachShardsRequest) ProtoReflect added in v0.38.0

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

func (*DetachShardsRequest) ReadSignedData added in v0.38.0

func (x *DetachShardsRequest) 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 (*DetachShardsRequest) Reset added in v0.38.0

func (x *DetachShardsRequest) Reset()

func (*DetachShardsRequest) SetSignature added in v0.38.0

func (x *DetachShardsRequest) SetSignature(sig *Signature)

func (*DetachShardsRequest) SignedDataSize added in v0.38.0

func (x *DetachShardsRequest) 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 (*DetachShardsRequest) StableMarshal added in v0.38.0

func (x *DetachShardsRequest) 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 (*DetachShardsRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*DetachShardsRequest) String added in v0.38.0

func (x *DetachShardsRequest) String() string

type DetachShardsRequest_Body added in v0.38.0

type DetachShardsRequest_Body struct {
	Shard_ID [][]byte `protobuf:"bytes,1,rep,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DetachShardsRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use DetachShardsRequest_Body.ProtoReflect.Descriptor instead.

func (*DetachShardsRequest_Body) GetShard_ID added in v0.38.0

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

func (*DetachShardsRequest_Body) ProtoMessage added in v0.38.0

func (*DetachShardsRequest_Body) ProtoMessage()

func (*DetachShardsRequest_Body) ProtoReflect added in v0.38.0

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

func (*DetachShardsRequest_Body) Reset added in v0.38.0

func (x *DetachShardsRequest_Body) Reset()

func (*DetachShardsRequest_Body) StableMarshal added in v0.38.0

func (x *DetachShardsRequest_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 (*DetachShardsRequest_Body) StableSize added in v0.38.0

func (x *DetachShardsRequest_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 (*DetachShardsRequest_Body) String added in v0.38.0

func (x *DetachShardsRequest_Body) String() string

type DetachShardsResponse added in v0.38.0

type DetachShardsResponse struct {
	Body      *DetachShardsResponse_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
}

func DetachShards added in v0.38.0

func DetachShards(
	cli *client.Client,
	req *DetachShardsRequest,
	opts ...client.CallOption,
) (*DetachShardsResponse, error)

DetachShards executes ControlService.DetachShards RPC.

func (*DetachShardsResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use DetachShardsResponse.ProtoReflect.Descriptor instead.

func (*DetachShardsResponse) GetBody added in v0.38.0

func (*DetachShardsResponse) GetSignature added in v0.38.0

func (x *DetachShardsResponse) GetSignature() *Signature

func (*DetachShardsResponse) ProtoMessage added in v0.38.0

func (*DetachShardsResponse) ProtoMessage()

func (*DetachShardsResponse) ProtoReflect added in v0.38.0

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

func (*DetachShardsResponse) ReadSignedData added in v0.38.0

func (x *DetachShardsResponse) 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 (*DetachShardsResponse) Reset added in v0.38.0

func (x *DetachShardsResponse) Reset()

func (*DetachShardsResponse) SetSignature added in v0.38.0

func (x *DetachShardsResponse) SetSignature(sig *Signature)

func (*DetachShardsResponse) SignedDataSize added in v0.38.0

func (x *DetachShardsResponse) 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 (*DetachShardsResponse) StableMarshal added in v0.38.0

func (x *DetachShardsResponse) 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 (*DetachShardsResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*DetachShardsResponse) String added in v0.38.0

func (x *DetachShardsResponse) String() string

type DetachShardsResponse_Body added in v0.38.0

type DetachShardsResponse_Body struct {
	// contains filtered or unexported fields
}

func (*DetachShardsResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use DetachShardsResponse_Body.ProtoReflect.Descriptor instead.

func (*DetachShardsResponse_Body) ProtoMessage added in v0.38.0

func (*DetachShardsResponse_Body) ProtoMessage()

func (*DetachShardsResponse_Body) ProtoReflect added in v0.38.0

func (*DetachShardsResponse_Body) Reset added in v0.38.0

func (x *DetachShardsResponse_Body) Reset()

func (*DetachShardsResponse_Body) StableMarshal added in v0.38.0

func (x *DetachShardsResponse_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 (*DetachShardsResponse_Body) StableSize added in v0.38.0

func (x *DetachShardsResponse_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 (*DetachShardsResponse_Body) String added in v0.38.0

func (x *DetachShardsResponse_Body) String() string

type DoctorRequest

type DoctorRequest struct {
	Body      *DoctorRequest_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
}

Doctor request.

func (*DoctorRequest) Descriptor deprecated

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

Deprecated: Use DoctorRequest.ProtoReflect.Descriptor instead.

func (*DoctorRequest) GetBody

func (x *DoctorRequest) GetBody() *DoctorRequest_Body

func (*DoctorRequest) GetSignature

func (x *DoctorRequest) GetSignature() *Signature

func (*DoctorRequest) ProtoMessage

func (*DoctorRequest) ProtoMessage()

func (*DoctorRequest) ProtoReflect

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

func (*DoctorRequest) ReadSignedData

func (x *DoctorRequest) 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 (*DoctorRequest) Reset

func (x *DoctorRequest) Reset()

func (*DoctorRequest) SetSignature

func (x *DoctorRequest) SetSignature(sig *Signature)

func (*DoctorRequest) SignedDataSize

func (x *DoctorRequest) 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 (*DoctorRequest) StableMarshal

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

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

StableSize returns the size of x in protobuf format.

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

func (*DoctorRequest) String

func (x *DoctorRequest) String() string

type DoctorRequest_Body

type DoctorRequest_Body struct {

	// Number of threads to use for the operation.
	Concurrency uint32 `protobuf:"varint,1,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// Flag to search engine for duplicate objects and leave only one copy.
	RemoveDuplicates bool `protobuf:"varint,2,opt,name=remove_duplicates,json=removeDuplicates,proto3" json:"remove_duplicates,omitempty"`
	// contains filtered or unexported fields
}

Request body structure.

func (*DoctorRequest_Body) Descriptor deprecated

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

Deprecated: Use DoctorRequest_Body.ProtoReflect.Descriptor instead.

func (*DoctorRequest_Body) GetConcurrency

func (x *DoctorRequest_Body) GetConcurrency() uint32

func (*DoctorRequest_Body) GetRemoveDuplicates

func (x *DoctorRequest_Body) GetRemoveDuplicates() bool

func (*DoctorRequest_Body) ProtoMessage

func (*DoctorRequest_Body) ProtoMessage()

func (*DoctorRequest_Body) ProtoReflect

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

func (*DoctorRequest_Body) Reset

func (x *DoctorRequest_Body) Reset()

func (*DoctorRequest_Body) StableMarshal

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

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

func (x *DoctorRequest_Body) String() string

type DoctorResponse

type DoctorResponse struct {
	Body      *DoctorResponse_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
}

Doctor response.

func Doctor

func Doctor(cli *client.Client, req *DoctorRequest, opts ...client.CallOption) (*DoctorResponse, error)

Doctor executes ControlService.Doctor RPC.

func (*DoctorResponse) Descriptor deprecated

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

Deprecated: Use DoctorResponse.ProtoReflect.Descriptor instead.

func (*DoctorResponse) GetBody

func (x *DoctorResponse) GetBody() *DoctorResponse_Body

func (*DoctorResponse) GetSignature

func (x *DoctorResponse) GetSignature() *Signature

func (*DoctorResponse) ProtoMessage

func (*DoctorResponse) ProtoMessage()

func (*DoctorResponse) ProtoReflect

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

func (*DoctorResponse) ReadSignedData

func (x *DoctorResponse) 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 (*DoctorResponse) Reset

func (x *DoctorResponse) Reset()

func (*DoctorResponse) SetSignature

func (x *DoctorResponse) SetSignature(sig *Signature)

func (*DoctorResponse) SignedDataSize

func (x *DoctorResponse) 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 (*DoctorResponse) StableMarshal

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

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

StableSize returns the size of x in protobuf format.

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

func (*DoctorResponse) String

func (x *DoctorResponse) String() string

type DoctorResponse_Body

type DoctorResponse_Body struct {
	// contains filtered or unexported fields
}

Response body structure.

func (*DoctorResponse_Body) Descriptor deprecated

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

Deprecated: Use DoctorResponse_Body.ProtoReflect.Descriptor instead.

func (*DoctorResponse_Body) ProtoMessage

func (*DoctorResponse_Body) ProtoMessage()

func (*DoctorResponse_Body) ProtoReflect

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

func (*DoctorResponse_Body) Reset

func (x *DoctorResponse_Body) Reset()

func (*DoctorResponse_Body) StableMarshal

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

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

func (x *DoctorResponse_Body) String() string

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 (*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

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 (*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

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 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 (*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 (*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 (*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 (*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 (*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"`
	// If true, then writecache will be left in read-only mode after flush
	// completed.
	Seal bool `protobuf:"varint,2,opt,name=seal,proto3" json:"seal,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) GetSeal added in v0.38.0

func (x *FlushCacheRequest_Body) GetSeal() bool

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 (*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 GetChainLocalOverrideRequest added in v0.38.0

type GetChainLocalOverrideRequest struct {
	Body      *GetChainLocalOverrideRequest_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
}

GetChainLocalOverride request.

func (*GetChainLocalOverrideRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use GetChainLocalOverrideRequest.ProtoReflect.Descriptor instead.

func (*GetChainLocalOverrideRequest) GetBody added in v0.38.0

func (*GetChainLocalOverrideRequest) GetSignature added in v0.38.0

func (x *GetChainLocalOverrideRequest) GetSignature() *Signature

func (*GetChainLocalOverrideRequest) ProtoMessage added in v0.38.0

func (*GetChainLocalOverrideRequest) ProtoMessage()

func (*GetChainLocalOverrideRequest) ProtoReflect added in v0.38.0

func (*GetChainLocalOverrideRequest) ReadSignedData added in v0.38.0

func (x *GetChainLocalOverrideRequest) 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 (*GetChainLocalOverrideRequest) Reset added in v0.38.0

func (x *GetChainLocalOverrideRequest) Reset()

func (*GetChainLocalOverrideRequest) SetSignature added in v0.38.0

func (x *GetChainLocalOverrideRequest) SetSignature(sig *Signature)

func (*GetChainLocalOverrideRequest) SignedDataSize added in v0.38.0

func (x *GetChainLocalOverrideRequest) 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 (*GetChainLocalOverrideRequest) StableMarshal added in v0.38.0

func (x *GetChainLocalOverrideRequest) 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 (*GetChainLocalOverrideRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*GetChainLocalOverrideRequest) String added in v0.38.0

type GetChainLocalOverrideRequest_Body added in v0.38.0

type GetChainLocalOverrideRequest_Body struct {

	// Target for which the overrides are applied.
	Target *ChainTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// Chain ID assigned for the added rule chain.
	ChainId []byte `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChainLocalOverrideRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use GetChainLocalOverrideRequest_Body.ProtoReflect.Descriptor instead.

func (*GetChainLocalOverrideRequest_Body) GetChainId added in v0.38.0

func (x *GetChainLocalOverrideRequest_Body) GetChainId() []byte

func (*GetChainLocalOverrideRequest_Body) GetTarget added in v0.38.0

func (*GetChainLocalOverrideRequest_Body) ProtoMessage added in v0.38.0

func (*GetChainLocalOverrideRequest_Body) ProtoMessage()

func (*GetChainLocalOverrideRequest_Body) ProtoReflect added in v0.38.0

func (*GetChainLocalOverrideRequest_Body) Reset added in v0.38.0

func (*GetChainLocalOverrideRequest_Body) StableMarshal added in v0.38.0

func (x *GetChainLocalOverrideRequest_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 (*GetChainLocalOverrideRequest_Body) StableSize added in v0.38.0

func (x *GetChainLocalOverrideRequest_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 (*GetChainLocalOverrideRequest_Body) String added in v0.38.0

type GetChainLocalOverrideResponse added in v0.38.0

type GetChainLocalOverrideResponse struct {
	Body      *GetChainLocalOverrideResponse_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
}

GetChainLocalOverride response.

func GetChainLocalOverride added in v0.38.0

func GetChainLocalOverride(cli *client.Client, req *GetChainLocalOverrideRequest, opts ...client.CallOption) (*GetChainLocalOverrideResponse, error)

RemoveChainLocalOverride executes ControlService.RemoveChainLocalOverride RPC.

func (*GetChainLocalOverrideResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use GetChainLocalOverrideResponse.ProtoReflect.Descriptor instead.

func (*GetChainLocalOverrideResponse) GetBody added in v0.38.0

func (*GetChainLocalOverrideResponse) GetSignature added in v0.38.0

func (x *GetChainLocalOverrideResponse) GetSignature() *Signature

func (*GetChainLocalOverrideResponse) ProtoMessage added in v0.38.0

func (*GetChainLocalOverrideResponse) ProtoMessage()

func (*GetChainLocalOverrideResponse) ProtoReflect added in v0.38.0

func (*GetChainLocalOverrideResponse) ReadSignedData added in v0.38.0

func (x *GetChainLocalOverrideResponse) 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 (*GetChainLocalOverrideResponse) Reset added in v0.38.0

func (x *GetChainLocalOverrideResponse) Reset()

func (*GetChainLocalOverrideResponse) SetSignature added in v0.38.0

func (x *GetChainLocalOverrideResponse) SetSignature(sig *Signature)

func (*GetChainLocalOverrideResponse) SignedDataSize added in v0.38.0

func (x *GetChainLocalOverrideResponse) 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 (*GetChainLocalOverrideResponse) StableMarshal added in v0.38.0

func (x *GetChainLocalOverrideResponse) 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 (*GetChainLocalOverrideResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*GetChainLocalOverrideResponse) String added in v0.38.0

type GetChainLocalOverrideResponse_Body added in v0.38.0

type GetChainLocalOverrideResponse_Body struct {

	// Serialized rule chain.
	Chain []byte `protobuf:"bytes,1,opt,name=chain,proto3" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

func (*GetChainLocalOverrideResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use GetChainLocalOverrideResponse_Body.ProtoReflect.Descriptor instead.

func (*GetChainLocalOverrideResponse_Body) GetChain added in v0.38.0

func (x *GetChainLocalOverrideResponse_Body) GetChain() []byte

func (*GetChainLocalOverrideResponse_Body) ProtoMessage added in v0.38.0

func (*GetChainLocalOverrideResponse_Body) ProtoMessage()

func (*GetChainLocalOverrideResponse_Body) ProtoReflect added in v0.38.0

func (*GetChainLocalOverrideResponse_Body) Reset added in v0.38.0

func (*GetChainLocalOverrideResponse_Body) StableMarshal added in v0.38.0

func (x *GetChainLocalOverrideResponse_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 (*GetChainLocalOverrideResponse_Body) StableSize added in v0.38.0

func (x *GetChainLocalOverrideResponse_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 (*GetChainLocalOverrideResponse_Body) String added in v0.38.0

type GetShardEvacuationStatusRequest added in v0.37.0

type GetShardEvacuationStatusRequest struct {
	Body      *GetShardEvacuationStatusRequest_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
}

GetShardEvacuationStatus request.

func (*GetShardEvacuationStatusRequest) Descriptor deprecated added in v0.37.0

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

Deprecated: Use GetShardEvacuationStatusRequest.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusRequest) GetBody added in v0.37.0

func (*GetShardEvacuationStatusRequest) GetSignature added in v0.37.0

func (x *GetShardEvacuationStatusRequest) GetSignature() *Signature

func (*GetShardEvacuationStatusRequest) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusRequest) ProtoMessage()

func (*GetShardEvacuationStatusRequest) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusRequest) ReadSignedData added in v0.37.0

func (x *GetShardEvacuationStatusRequest) 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 (*GetShardEvacuationStatusRequest) Reset added in v0.37.0

func (*GetShardEvacuationStatusRequest) SetSignature added in v0.37.0

func (x *GetShardEvacuationStatusRequest) SetSignature(sig *Signature)

func (*GetShardEvacuationStatusRequest) SignedDataSize added in v0.37.0

func (x *GetShardEvacuationStatusRequest) 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 (*GetShardEvacuationStatusRequest) StableMarshal added in v0.37.0

func (x *GetShardEvacuationStatusRequest) 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 (*GetShardEvacuationStatusRequest) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*GetShardEvacuationStatusRequest) String added in v0.37.0

type GetShardEvacuationStatusRequest_Body added in v0.37.0

type GetShardEvacuationStatusRequest_Body struct {
	// contains filtered or unexported fields
}

Request body structure.

func (*GetShardEvacuationStatusRequest_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use GetShardEvacuationStatusRequest_Body.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusRequest_Body) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusRequest_Body) ProtoMessage()

func (*GetShardEvacuationStatusRequest_Body) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusRequest_Body) Reset added in v0.37.0

func (*GetShardEvacuationStatusRequest_Body) StableMarshal added in v0.37.0

func (x *GetShardEvacuationStatusRequest_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 (*GetShardEvacuationStatusRequest_Body) StableSize added in v0.37.0

func (x *GetShardEvacuationStatusRequest_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 (*GetShardEvacuationStatusRequest_Body) String added in v0.37.0

type GetShardEvacuationStatusResponse added in v0.37.0

type GetShardEvacuationStatusResponse struct {
	Body      *GetShardEvacuationStatusResponse_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
}

GetShardEvacuationStatus response.

func GetShardEvacuationStatus added in v0.37.0

GetShardEvacuationStatus executes ControlService.GetShardEvacuationStatus RPC.

func (*GetShardEvacuationStatusResponse) Descriptor deprecated added in v0.37.0

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

Deprecated: Use GetShardEvacuationStatusResponse.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusResponse) GetBody added in v0.37.0

func (*GetShardEvacuationStatusResponse) GetSignature added in v0.37.0

func (x *GetShardEvacuationStatusResponse) GetSignature() *Signature

func (*GetShardEvacuationStatusResponse) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusResponse) ProtoMessage()

func (*GetShardEvacuationStatusResponse) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusResponse) ReadSignedData added in v0.37.0

func (x *GetShardEvacuationStatusResponse) 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 (*GetShardEvacuationStatusResponse) Reset added in v0.37.0

func (*GetShardEvacuationStatusResponse) SetSignature added in v0.37.0

func (x *GetShardEvacuationStatusResponse) SetSignature(sig *Signature)

func (*GetShardEvacuationStatusResponse) SignedDataSize added in v0.37.0

func (x *GetShardEvacuationStatusResponse) 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 (*GetShardEvacuationStatusResponse) StableMarshal added in v0.37.0

func (x *GetShardEvacuationStatusResponse) 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 (*GetShardEvacuationStatusResponse) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*GetShardEvacuationStatusResponse) String added in v0.37.0

type GetShardEvacuationStatusResponse_Body added in v0.37.0

type GetShardEvacuationStatusResponse_Body struct {

	// Total objects to evacuate count. The value is approximate, so evacuated +
	// failed + skipped == total is not guaranteed after completion.
	TotalObjects uint64 `protobuf:"varint,1,opt,name=total_objects,json=totalObjects,proto3" json:"total_objects,omitempty"`
	// Evacuated objects count.
	EvacuatedObjects uint64 `protobuf:"varint,2,opt,name=evacuated_objects,json=evacuatedObjects,proto3" json:"evacuated_objects,omitempty"`
	// Failed objects count.
	FailedObjects uint64 `protobuf:"varint,3,opt,name=failed_objects,json=failedObjects,proto3" json:"failed_objects,omitempty"`
	// Shard IDs.
	Shard_ID [][]byte `protobuf:"bytes,4,rep,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"`
	// Evacuation process status.
	Status GetShardEvacuationStatusResponse_Body_Status `protobuf:"varint,5,opt,name=status,proto3,enum=control.GetShardEvacuationStatusResponse_Body_Status" json:"status,omitempty"`
	// Evacuation process duration.
	Duration *GetShardEvacuationStatusResponse_Body_Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Evacuation process started at timestamp.
	StartedAt *GetShardEvacuationStatusResponse_Body_UnixTimestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Error message if evacuation failed.
	ErrorMessage string `protobuf:"bytes,8,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// Skipped objects count.
	SkippedObjects uint64 `protobuf:"varint,9,opt,name=skipped_objects,json=skippedObjects,proto3" json:"skipped_objects,omitempty"`
	// Total trees to evacuate count.
	TotalTrees uint64 `protobuf:"varint,10,opt,name=total_trees,json=totalTrees,proto3" json:"total_trees,omitempty"`
	// Evacuated trees count.
	EvacuatedTrees uint64 `protobuf:"varint,11,opt,name=evacuated_trees,json=evacuatedTrees,proto3" json:"evacuated_trees,omitempty"`
	// Failed trees count.
	FailedTrees uint64 `protobuf:"varint,12,opt,name=failed_trees,json=failedTrees,proto3" json:"failed_trees,omitempty"`
	// contains filtered or unexported fields
}

Response body structure.

func (*GetShardEvacuationStatusResponse_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use GetShardEvacuationStatusResponse_Body.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusResponse_Body) GetDuration added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) GetErrorMessage added in v0.37.0

func (x *GetShardEvacuationStatusResponse_Body) GetErrorMessage() string

func (*GetShardEvacuationStatusResponse_Body) GetEvacuatedObjects added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetEvacuatedObjects() uint64

func (*GetShardEvacuationStatusResponse_Body) GetEvacuatedTrees added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetEvacuatedTrees() uint64

func (*GetShardEvacuationStatusResponse_Body) GetFailedObjects added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetFailedObjects() uint64

func (*GetShardEvacuationStatusResponse_Body) GetFailedTrees added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetFailedTrees() uint64

func (*GetShardEvacuationStatusResponse_Body) GetShard_ID added in v0.37.0

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

func (*GetShardEvacuationStatusResponse_Body) GetSkippedObjects added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetSkippedObjects() uint64

func (*GetShardEvacuationStatusResponse_Body) GetStartedAt added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) GetStatus added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) GetTotalObjects added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetTotalObjects() uint64

func (*GetShardEvacuationStatusResponse_Body) GetTotalTrees added in v0.38.0

func (x *GetShardEvacuationStatusResponse_Body) GetTotalTrees() uint64

func (*GetShardEvacuationStatusResponse_Body) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) ProtoMessage()

func (*GetShardEvacuationStatusResponse_Body) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) Reset added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body) StableMarshal added in v0.37.0

func (x *GetShardEvacuationStatusResponse_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 (*GetShardEvacuationStatusResponse_Body) StableSize added in v0.37.0

func (x *GetShardEvacuationStatusResponse_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 (*GetShardEvacuationStatusResponse_Body) String added in v0.37.0

type GetShardEvacuationStatusResponse_Body_Duration added in v0.37.0

type GetShardEvacuationStatusResponse_Body_Duration struct {
	Seconds int64 `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
	// contains filtered or unexported fields
}

Duration in seconds.

func (*GetShardEvacuationStatusResponse_Body_Duration) Descriptor deprecated added in v0.37.0

Deprecated: Use GetShardEvacuationStatusResponse_Body_Duration.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusResponse_Body_Duration) GetSeconds added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_Duration) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_Duration) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_Duration) Reset added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_Duration) StableMarshal added in v0.37.0

func (x *GetShardEvacuationStatusResponse_Body_Duration) 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 (*GetShardEvacuationStatusResponse_Body_Duration) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*GetShardEvacuationStatusResponse_Body_Duration) String added in v0.37.0

type GetShardEvacuationStatusResponse_Body_Status added in v0.37.0

type GetShardEvacuationStatusResponse_Body_Status int32

Evacuate status enum.

const (
	GetShardEvacuationStatusResponse_Body_EVACUATE_SHARD_STATUS_UNDEFINED GetShardEvacuationStatusResponse_Body_Status = 0
	GetShardEvacuationStatusResponse_Body_RUNNING                         GetShardEvacuationStatusResponse_Body_Status = 1
	GetShardEvacuationStatusResponse_Body_COMPLETED                       GetShardEvacuationStatusResponse_Body_Status = 2
)

func (GetShardEvacuationStatusResponse_Body_Status) Descriptor added in v0.37.0

func (GetShardEvacuationStatusResponse_Body_Status) Enum added in v0.37.0

func (GetShardEvacuationStatusResponse_Body_Status) EnumDescriptor deprecated added in v0.37.0

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

Deprecated: Use GetShardEvacuationStatusResponse_Body_Status.Descriptor instead.

func (GetShardEvacuationStatusResponse_Body_Status) Number added in v0.37.0

func (GetShardEvacuationStatusResponse_Body_Status) String added in v0.37.0

func (GetShardEvacuationStatusResponse_Body_Status) Type added in v0.37.0

type GetShardEvacuationStatusResponse_Body_UnixTimestamp added in v0.37.0

type GetShardEvacuationStatusResponse_Body_UnixTimestamp struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Unix timestamp value.

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) Descriptor deprecated added in v0.37.0

Deprecated: Use GetShardEvacuationStatusResponse_Body_UnixTimestamp.ProtoReflect.Descriptor instead.

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) GetValue added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) ProtoMessage added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) ProtoReflect added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) Reset added in v0.37.0

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) StableMarshal added in v0.37.0

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 (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) StableSize added in v0.37.0

StableSize returns the size of x in protobuf format.

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

func (*GetShardEvacuationStatusResponse_Body_UnixTimestamp) String added in v0.37.0

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 (*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

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 (*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

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
	// Storage node application is reconfiguring.
	HealthStatus_RECONFIGURING HealthStatus = 4
)

func (HealthStatus) Descriptor

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 (HealthStatus) String

func (x HealthStatus) String() string

func (HealthStatus) Type

type ListChainLocalOverridesRequest added in v0.38.0

type ListChainLocalOverridesRequest struct {
	Body      *ListChainLocalOverridesRequest_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
}

ListChainLocalOverrides request.

func (*ListChainLocalOverridesRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListChainLocalOverridesRequest.ProtoReflect.Descriptor instead.

func (*ListChainLocalOverridesRequest) GetBody added in v0.38.0

func (*ListChainLocalOverridesRequest) GetSignature added in v0.38.0

func (x *ListChainLocalOverridesRequest) GetSignature() *Signature

func (*ListChainLocalOverridesRequest) ProtoMessage added in v0.38.0

func (*ListChainLocalOverridesRequest) ProtoMessage()

func (*ListChainLocalOverridesRequest) ProtoReflect added in v0.38.0

func (*ListChainLocalOverridesRequest) ReadSignedData added in v0.38.0

func (x *ListChainLocalOverridesRequest) 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 (*ListChainLocalOverridesRequest) Reset added in v0.38.0

func (x *ListChainLocalOverridesRequest) Reset()

func (*ListChainLocalOverridesRequest) SetSignature added in v0.38.0

func (x *ListChainLocalOverridesRequest) SetSignature(sig *Signature)

func (*ListChainLocalOverridesRequest) SignedDataSize added in v0.38.0

func (x *ListChainLocalOverridesRequest) 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 (*ListChainLocalOverridesRequest) StableMarshal added in v0.38.0

func (x *ListChainLocalOverridesRequest) 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 (*ListChainLocalOverridesRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ListChainLocalOverridesRequest) String added in v0.38.0

type ListChainLocalOverridesRequest_Body added in v0.38.0

type ListChainLocalOverridesRequest_Body struct {

	// Target for which the overrides are applied.
	Target *ChainTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChainLocalOverridesRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListChainLocalOverridesRequest_Body.ProtoReflect.Descriptor instead.

func (*ListChainLocalOverridesRequest_Body) GetTarget added in v0.38.0

func (*ListChainLocalOverridesRequest_Body) ProtoMessage added in v0.38.0

func (*ListChainLocalOverridesRequest_Body) ProtoMessage()

func (*ListChainLocalOverridesRequest_Body) ProtoReflect added in v0.38.0

func (*ListChainLocalOverridesRequest_Body) Reset added in v0.38.0

func (*ListChainLocalOverridesRequest_Body) StableMarshal added in v0.38.0

func (x *ListChainLocalOverridesRequest_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 (*ListChainLocalOverridesRequest_Body) StableSize added in v0.38.0

func (x *ListChainLocalOverridesRequest_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 (*ListChainLocalOverridesRequest_Body) String added in v0.38.0

type ListChainLocalOverridesResponse added in v0.38.0

type ListChainLocalOverridesResponse struct {
	Body      *ListChainLocalOverridesResponse_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
}

ListChainLocalOverrides response.

func ListChainLocalOverrides added in v0.38.0

ListChainLocalOverrides executes ControlService.ListChainLocalOverrides RPC.

func (*ListChainLocalOverridesResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListChainLocalOverridesResponse.ProtoReflect.Descriptor instead.

func (*ListChainLocalOverridesResponse) GetBody added in v0.38.0

func (*ListChainLocalOverridesResponse) GetSignature added in v0.38.0

func (x *ListChainLocalOverridesResponse) GetSignature() *Signature

func (*ListChainLocalOverridesResponse) ProtoMessage added in v0.38.0

func (*ListChainLocalOverridesResponse) ProtoMessage()

func (*ListChainLocalOverridesResponse) ProtoReflect added in v0.38.0

func (*ListChainLocalOverridesResponse) ReadSignedData added in v0.38.0

func (x *ListChainLocalOverridesResponse) 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 (*ListChainLocalOverridesResponse) Reset added in v0.38.0

func (*ListChainLocalOverridesResponse) SetSignature added in v0.38.0

func (x *ListChainLocalOverridesResponse) SetSignature(sig *Signature)

func (*ListChainLocalOverridesResponse) SignedDataSize added in v0.38.0

func (x *ListChainLocalOverridesResponse) 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 (*ListChainLocalOverridesResponse) StableMarshal added in v0.38.0

func (x *ListChainLocalOverridesResponse) 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 (*ListChainLocalOverridesResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ListChainLocalOverridesResponse) String added in v0.38.0

type ListChainLocalOverridesResponse_Body added in v0.38.0

type ListChainLocalOverridesResponse_Body struct {

	// The list of serialized rule chain.
	Chains [][]byte `protobuf:"bytes,1,rep,name=chains,proto3" json:"chains,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChainLocalOverridesResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListChainLocalOverridesResponse_Body.ProtoReflect.Descriptor instead.

func (*ListChainLocalOverridesResponse_Body) GetChains added in v0.38.0

func (x *ListChainLocalOverridesResponse_Body) GetChains() [][]byte

func (*ListChainLocalOverridesResponse_Body) ProtoMessage added in v0.38.0

func (*ListChainLocalOverridesResponse_Body) ProtoMessage()

func (*ListChainLocalOverridesResponse_Body) ProtoReflect added in v0.38.0

func (*ListChainLocalOverridesResponse_Body) Reset added in v0.38.0

func (*ListChainLocalOverridesResponse_Body) StableMarshal added in v0.38.0

func (x *ListChainLocalOverridesResponse_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 (*ListChainLocalOverridesResponse_Body) StableSize added in v0.38.0

func (x *ListChainLocalOverridesResponse_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 (*ListChainLocalOverridesResponse_Body) String added in v0.38.0

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 (*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

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 (*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

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 ListTargetsLocalOverridesRequest added in v0.38.0

type ListTargetsLocalOverridesRequest struct {
	Body      *ListTargetsLocalOverridesRequest_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
}

ListTargetsLocalOverrides request.

func (*ListTargetsLocalOverridesRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListTargetsLocalOverridesRequest.ProtoReflect.Descriptor instead.

func (*ListTargetsLocalOverridesRequest) GetBody added in v0.38.0

func (*ListTargetsLocalOverridesRequest) GetSignature added in v0.38.0

func (x *ListTargetsLocalOverridesRequest) GetSignature() *Signature

func (*ListTargetsLocalOverridesRequest) ProtoMessage added in v0.38.0

func (*ListTargetsLocalOverridesRequest) ProtoMessage()

func (*ListTargetsLocalOverridesRequest) ProtoReflect added in v0.38.0

func (*ListTargetsLocalOverridesRequest) ReadSignedData added in v0.38.0

func (x *ListTargetsLocalOverridesRequest) 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 (*ListTargetsLocalOverridesRequest) Reset added in v0.38.0

func (*ListTargetsLocalOverridesRequest) SetSignature added in v0.38.0

func (x *ListTargetsLocalOverridesRequest) SetSignature(sig *Signature)

func (*ListTargetsLocalOverridesRequest) SignedDataSize added in v0.38.0

func (x *ListTargetsLocalOverridesRequest) 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 (*ListTargetsLocalOverridesRequest) StableMarshal added in v0.38.0

func (x *ListTargetsLocalOverridesRequest) 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 (*ListTargetsLocalOverridesRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ListTargetsLocalOverridesRequest) String added in v0.38.0

type ListTargetsLocalOverridesRequest_Body added in v0.38.0

type ListTargetsLocalOverridesRequest_Body struct {

	// Target for which the overrides are applied.
	ChainName string `protobuf:"bytes,1,opt,name=chainName,proto3" json:"chainName,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTargetsLocalOverridesRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListTargetsLocalOverridesRequest_Body.ProtoReflect.Descriptor instead.

func (*ListTargetsLocalOverridesRequest_Body) GetChainName added in v0.38.0

func (*ListTargetsLocalOverridesRequest_Body) ProtoMessage added in v0.38.0

func (*ListTargetsLocalOverridesRequest_Body) ProtoMessage()

func (*ListTargetsLocalOverridesRequest_Body) ProtoReflect added in v0.38.0

func (*ListTargetsLocalOverridesRequest_Body) Reset added in v0.38.0

func (*ListTargetsLocalOverridesRequest_Body) StableMarshal added in v0.38.0

func (x *ListTargetsLocalOverridesRequest_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 (*ListTargetsLocalOverridesRequest_Body) StableSize added in v0.38.0

func (x *ListTargetsLocalOverridesRequest_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 (*ListTargetsLocalOverridesRequest_Body) String added in v0.38.0

type ListTargetsLocalOverridesResponse added in v0.38.0

type ListTargetsLocalOverridesResponse struct {
	Body      *ListTargetsLocalOverridesResponse_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
}

ListTargetsLocalOverrides response.

func ListTargetsLocalOverrides added in v0.38.0

ListTargetsLocalOverrides executes ControlService.ListTargetsLocalOverrides RPC.

func (*ListTargetsLocalOverridesResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListTargetsLocalOverridesResponse.ProtoReflect.Descriptor instead.

func (*ListTargetsLocalOverridesResponse) GetBody added in v0.38.0

func (*ListTargetsLocalOverridesResponse) GetSignature added in v0.38.0

func (x *ListTargetsLocalOverridesResponse) GetSignature() *Signature

func (*ListTargetsLocalOverridesResponse) ProtoMessage added in v0.38.0

func (*ListTargetsLocalOverridesResponse) ProtoMessage()

func (*ListTargetsLocalOverridesResponse) ProtoReflect added in v0.38.0

func (*ListTargetsLocalOverridesResponse) ReadSignedData added in v0.38.0

func (x *ListTargetsLocalOverridesResponse) 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 (*ListTargetsLocalOverridesResponse) Reset added in v0.38.0

func (*ListTargetsLocalOverridesResponse) SetSignature added in v0.38.0

func (x *ListTargetsLocalOverridesResponse) SetSignature(sig *Signature)

func (*ListTargetsLocalOverridesResponse) SignedDataSize added in v0.38.0

func (x *ListTargetsLocalOverridesResponse) 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 (*ListTargetsLocalOverridesResponse) StableMarshal added in v0.38.0

func (x *ListTargetsLocalOverridesResponse) 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 (*ListTargetsLocalOverridesResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ListTargetsLocalOverridesResponse) String added in v0.38.0

type ListTargetsLocalOverridesResponse_Body added in v0.38.0

type ListTargetsLocalOverridesResponse_Body struct {

	// The list of chain targets.
	Targets []*ChainTarget `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTargetsLocalOverridesResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ListTargetsLocalOverridesResponse_Body.ProtoReflect.Descriptor instead.

func (*ListTargetsLocalOverridesResponse_Body) GetTargets added in v0.38.0

func (*ListTargetsLocalOverridesResponse_Body) ProtoMessage added in v0.38.0

func (*ListTargetsLocalOverridesResponse_Body) ProtoReflect added in v0.38.0

func (*ListTargetsLocalOverridesResponse_Body) Reset added in v0.38.0

func (*ListTargetsLocalOverridesResponse_Body) StableMarshal added in v0.38.0

func (x *ListTargetsLocalOverridesResponse_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 (*ListTargetsLocalOverridesResponse_Body) StableSize added in v0.38.0

func (x *ListTargetsLocalOverridesResponse_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 (*ListTargetsLocalOverridesResponse_Body) String added in v0.38.0

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

func (x NetmapStatus) Enum() *NetmapStatus

func (NetmapStatus) EnumDescriptor deprecated

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

Deprecated: Use NetmapStatus.Descriptor instead.

func (NetmapStatus) Number

func (NetmapStatus) String

func (x NetmapStatus) String() string

func (NetmapStatus) Type

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.
  • 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 RemoveChainLocalOverrideRequest added in v0.38.0

type RemoveChainLocalOverrideRequest struct {
	Body      *RemoveChainLocalOverrideRequest_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
}

func (*RemoveChainLocalOverrideRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverrideRequest.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverrideRequest) GetBody added in v0.38.0

func (*RemoveChainLocalOverrideRequest) GetSignature added in v0.38.0

func (x *RemoveChainLocalOverrideRequest) GetSignature() *Signature

func (*RemoveChainLocalOverrideRequest) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverrideRequest) ProtoMessage()

func (*RemoveChainLocalOverrideRequest) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverrideRequest) ReadSignedData added in v0.38.0

func (x *RemoveChainLocalOverrideRequest) 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 (*RemoveChainLocalOverrideRequest) Reset added in v0.38.0

func (*RemoveChainLocalOverrideRequest) SetSignature added in v0.38.0

func (x *RemoveChainLocalOverrideRequest) SetSignature(sig *Signature)

func (*RemoveChainLocalOverrideRequest) SignedDataSize added in v0.38.0

func (x *RemoveChainLocalOverrideRequest) 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 (*RemoveChainLocalOverrideRequest) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverrideRequest) 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 (*RemoveChainLocalOverrideRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveChainLocalOverrideRequest) String added in v0.38.0

type RemoveChainLocalOverrideRequest_Body added in v0.38.0

type RemoveChainLocalOverrideRequest_Body struct {

	// Target for which the overrides are applied.
	Target *ChainTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// Chain ID assigned for the added rule chain.
	ChainId []byte `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveChainLocalOverrideRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverrideRequest_Body.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverrideRequest_Body) GetChainId added in v0.38.0

func (x *RemoveChainLocalOverrideRequest_Body) GetChainId() []byte

func (*RemoveChainLocalOverrideRequest_Body) GetTarget added in v0.38.0

func (*RemoveChainLocalOverrideRequest_Body) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverrideRequest_Body) ProtoMessage()

func (*RemoveChainLocalOverrideRequest_Body) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverrideRequest_Body) Reset added in v0.38.0

func (*RemoveChainLocalOverrideRequest_Body) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverrideRequest_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 (*RemoveChainLocalOverrideRequest_Body) StableSize added in v0.38.0

func (x *RemoveChainLocalOverrideRequest_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 (*RemoveChainLocalOverrideRequest_Body) String added in v0.38.0

type RemoveChainLocalOverrideResponse added in v0.38.0

type RemoveChainLocalOverrideResponse struct {
	Body      *RemoveChainLocalOverrideResponse_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
}

func RemoveChainLocalOverride added in v0.38.0

RemoveChainLocalOverride executes ControlService.RemoveChainLocalOverride RPC.

func (*RemoveChainLocalOverrideResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverrideResponse.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverrideResponse) GetBody added in v0.38.0

func (*RemoveChainLocalOverrideResponse) GetSignature added in v0.38.0

func (x *RemoveChainLocalOverrideResponse) GetSignature() *Signature

func (*RemoveChainLocalOverrideResponse) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverrideResponse) ProtoMessage()

func (*RemoveChainLocalOverrideResponse) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverrideResponse) ReadSignedData added in v0.38.0

func (x *RemoveChainLocalOverrideResponse) 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 (*RemoveChainLocalOverrideResponse) Reset added in v0.38.0

func (*RemoveChainLocalOverrideResponse) SetSignature added in v0.38.0

func (x *RemoveChainLocalOverrideResponse) SetSignature(sig *Signature)

func (*RemoveChainLocalOverrideResponse) SignedDataSize added in v0.38.0

func (x *RemoveChainLocalOverrideResponse) 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 (*RemoveChainLocalOverrideResponse) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverrideResponse) 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 (*RemoveChainLocalOverrideResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveChainLocalOverrideResponse) String added in v0.38.0

type RemoveChainLocalOverrideResponse_Body added in v0.38.0

type RemoveChainLocalOverrideResponse_Body struct {
	// contains filtered or unexported fields
}

func (*RemoveChainLocalOverrideResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverrideResponse_Body.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverrideResponse_Body) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverrideResponse_Body) ProtoMessage()

func (*RemoveChainLocalOverrideResponse_Body) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverrideResponse_Body) Reset added in v0.38.0

func (*RemoveChainLocalOverrideResponse_Body) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverrideResponse_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 (*RemoveChainLocalOverrideResponse_Body) StableSize added in v0.38.0

func (x *RemoveChainLocalOverrideResponse_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 (*RemoveChainLocalOverrideResponse_Body) String added in v0.38.0

type RemoveChainLocalOverridesByTargetRequest added in v0.38.0

type RemoveChainLocalOverridesByTargetRequest struct {
	Body      *RemoveChainLocalOverridesByTargetRequest_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
}

func (*RemoveChainLocalOverridesByTargetRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverridesByTargetRequest.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverridesByTargetRequest) GetBody added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) GetSignature added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) ReadSignedData added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetRequest) 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 (*RemoveChainLocalOverridesByTargetRequest) Reset added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) SetSignature added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest) SignedDataSize added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetRequest) 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 (*RemoveChainLocalOverridesByTargetRequest) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetRequest) 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 (*RemoveChainLocalOverridesByTargetRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveChainLocalOverridesByTargetRequest) String added in v0.38.0

type RemoveChainLocalOverridesByTargetRequest_Body added in v0.38.0

type RemoveChainLocalOverridesByTargetRequest_Body struct {

	// Target for which the overrides are applied.
	Target *ChainTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveChainLocalOverridesByTargetRequest_Body) Descriptor deprecated added in v0.38.0

Deprecated: Use RemoveChainLocalOverridesByTargetRequest_Body.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverridesByTargetRequest_Body) GetTarget added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest_Body) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest_Body) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest_Body) Reset added in v0.38.0

func (*RemoveChainLocalOverridesByTargetRequest_Body) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetRequest_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 (*RemoveChainLocalOverridesByTargetRequest_Body) StableSize added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetRequest_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 (*RemoveChainLocalOverridesByTargetRequest_Body) String added in v0.38.0

type RemoveChainLocalOverridesByTargetResponse added in v0.38.0

type RemoveChainLocalOverridesByTargetResponse struct {
	Body      *RemoveChainLocalOverridesByTargetResponse_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
}

func RemoveChainLocalOverridesByTarget added in v0.38.0

RemoveChainLocalOverridesByTarget executes ControlService.RemoveChainLocalOverridesByTarget RPC.

func (*RemoveChainLocalOverridesByTargetResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use RemoveChainLocalOverridesByTargetResponse.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverridesByTargetResponse) GetBody added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) GetSignature added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) ReadSignedData added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetResponse) 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 (*RemoveChainLocalOverridesByTargetResponse) Reset added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) SetSignature added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse) SignedDataSize added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetResponse) 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 (*RemoveChainLocalOverridesByTargetResponse) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetResponse) 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 (*RemoveChainLocalOverridesByTargetResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*RemoveChainLocalOverridesByTargetResponse) String added in v0.38.0

type RemoveChainLocalOverridesByTargetResponse_Body added in v0.38.0

type RemoveChainLocalOverridesByTargetResponse_Body struct {
	// contains filtered or unexported fields
}

func (*RemoveChainLocalOverridesByTargetResponse_Body) Descriptor deprecated added in v0.38.0

Deprecated: Use RemoveChainLocalOverridesByTargetResponse_Body.ProtoReflect.Descriptor instead.

func (*RemoveChainLocalOverridesByTargetResponse_Body) ProtoMessage added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse_Body) ProtoReflect added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse_Body) Reset added in v0.38.0

func (*RemoveChainLocalOverridesByTargetResponse_Body) StableMarshal added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetResponse_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 (*RemoveChainLocalOverridesByTargetResponse_Body) StableSize added in v0.38.0

func (x *RemoveChainLocalOverridesByTargetResponse_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 (*RemoveChainLocalOverridesByTargetResponse_Body) String added in v0.38.0

type ResetShardEvacuationStatusRequest added in v0.38.0

type ResetShardEvacuationStatusRequest struct {
	Body      *ResetShardEvacuationStatusRequest_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
}

ResetShardEvacuationStatus request.

func (*ResetShardEvacuationStatusRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ResetShardEvacuationStatusRequest.ProtoReflect.Descriptor instead.

func (*ResetShardEvacuationStatusRequest) GetBody added in v0.38.0

func (*ResetShardEvacuationStatusRequest) GetSignature added in v0.38.0

func (x *ResetShardEvacuationStatusRequest) GetSignature() *Signature

func (*ResetShardEvacuationStatusRequest) ProtoMessage added in v0.38.0

func (*ResetShardEvacuationStatusRequest) ProtoMessage()

func (*ResetShardEvacuationStatusRequest) ProtoReflect added in v0.38.0

func (*ResetShardEvacuationStatusRequest) ReadSignedData added in v0.38.0

func (x *ResetShardEvacuationStatusRequest) 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 (*ResetShardEvacuationStatusRequest) Reset added in v0.38.0

func (*ResetShardEvacuationStatusRequest) SetSignature added in v0.38.0

func (x *ResetShardEvacuationStatusRequest) SetSignature(sig *Signature)

func (*ResetShardEvacuationStatusRequest) SignedDataSize added in v0.38.0

func (x *ResetShardEvacuationStatusRequest) 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 (*ResetShardEvacuationStatusRequest) StableMarshal added in v0.38.0

func (x *ResetShardEvacuationStatusRequest) 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 (*ResetShardEvacuationStatusRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ResetShardEvacuationStatusRequest) String added in v0.38.0

type ResetShardEvacuationStatusRequest_Body added in v0.38.0

type ResetShardEvacuationStatusRequest_Body struct {
	// contains filtered or unexported fields
}

func (*ResetShardEvacuationStatusRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ResetShardEvacuationStatusRequest_Body.ProtoReflect.Descriptor instead.

func (*ResetShardEvacuationStatusRequest_Body) ProtoMessage added in v0.38.0

func (*ResetShardEvacuationStatusRequest_Body) ProtoReflect added in v0.38.0

func (*ResetShardEvacuationStatusRequest_Body) Reset added in v0.38.0

func (*ResetShardEvacuationStatusRequest_Body) StableMarshal added in v0.38.0

func (x *ResetShardEvacuationStatusRequest_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 (*ResetShardEvacuationStatusRequest_Body) StableSize added in v0.38.0

func (x *ResetShardEvacuationStatusRequest_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 (*ResetShardEvacuationStatusRequest_Body) String added in v0.38.0

type ResetShardEvacuationStatusResponse added in v0.38.0

type ResetShardEvacuationStatusResponse struct {
	Body      *ResetShardEvacuationStatusResponse_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
}

ResetShardEvacuationStatus response.

func ResetShardEvacuationStatus added in v0.38.0

ResetShardEvacuationStatus executes ControlService.ResetShardEvacuationStatus RPC.

func (*ResetShardEvacuationStatusResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ResetShardEvacuationStatusResponse.ProtoReflect.Descriptor instead.

func (*ResetShardEvacuationStatusResponse) GetBody added in v0.38.0

func (*ResetShardEvacuationStatusResponse) GetSignature added in v0.38.0

func (x *ResetShardEvacuationStatusResponse) GetSignature() *Signature

func (*ResetShardEvacuationStatusResponse) ProtoMessage added in v0.38.0

func (*ResetShardEvacuationStatusResponse) ProtoMessage()

func (*ResetShardEvacuationStatusResponse) ProtoReflect added in v0.38.0

func (*ResetShardEvacuationStatusResponse) ReadSignedData added in v0.38.0

func (x *ResetShardEvacuationStatusResponse) 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 (*ResetShardEvacuationStatusResponse) Reset added in v0.38.0

func (*ResetShardEvacuationStatusResponse) SetSignature added in v0.38.0

func (x *ResetShardEvacuationStatusResponse) SetSignature(sig *Signature)

func (*ResetShardEvacuationStatusResponse) SignedDataSize added in v0.38.0

func (x *ResetShardEvacuationStatusResponse) 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 (*ResetShardEvacuationStatusResponse) StableMarshal added in v0.38.0

func (x *ResetShardEvacuationStatusResponse) 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 (*ResetShardEvacuationStatusResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*ResetShardEvacuationStatusResponse) String added in v0.38.0

type ResetShardEvacuationStatusResponse_Body added in v0.38.0

type ResetShardEvacuationStatusResponse_Body struct {
	// contains filtered or unexported fields
}

func (*ResetShardEvacuationStatusResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use ResetShardEvacuationStatusResponse_Body.ProtoReflect.Descriptor instead.

func (*ResetShardEvacuationStatusResponse_Body) ProtoMessage added in v0.38.0

func (*ResetShardEvacuationStatusResponse_Body) ProtoReflect added in v0.38.0

func (*ResetShardEvacuationStatusResponse_Body) Reset added in v0.38.0

func (*ResetShardEvacuationStatusResponse_Body) StableMarshal added in v0.38.0

func (x *ResetShardEvacuationStatusResponse_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 (*ResetShardEvacuationStatusResponse_Body) StableSize added in v0.38.0

func (x *ResetShardEvacuationStatusResponse_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 (*ResetShardEvacuationStatusResponse_Body) String added in v0.38.0

type SealWriteCacheRequest added in v0.38.0

type SealWriteCacheRequest struct {
	Body      *SealWriteCacheRequest_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
}

func (*SealWriteCacheRequest) Descriptor deprecated added in v0.38.0

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

Deprecated: Use SealWriteCacheRequest.ProtoReflect.Descriptor instead.

func (*SealWriteCacheRequest) GetBody added in v0.38.0

func (*SealWriteCacheRequest) GetSignature added in v0.38.0

func (x *SealWriteCacheRequest) GetSignature() *Signature

func (*SealWriteCacheRequest) ProtoMessage added in v0.38.0

func (*SealWriteCacheRequest) ProtoMessage()

func (*SealWriteCacheRequest) ProtoReflect added in v0.38.0

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

func (*SealWriteCacheRequest) ReadSignedData added in v0.38.0

func (x *SealWriteCacheRequest) 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 (*SealWriteCacheRequest) Reset added in v0.38.0

func (x *SealWriteCacheRequest) Reset()

func (*SealWriteCacheRequest) SetSignature added in v0.38.0

func (x *SealWriteCacheRequest) SetSignature(sig *Signature)

func (*SealWriteCacheRequest) SignedDataSize added in v0.38.0

func (x *SealWriteCacheRequest) 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 (*SealWriteCacheRequest) StableMarshal added in v0.38.0

func (x *SealWriteCacheRequest) 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 (*SealWriteCacheRequest) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*SealWriteCacheRequest) String added in v0.38.0

func (x *SealWriteCacheRequest) String() string

type SealWriteCacheRequest_Body added in v0.38.0

type SealWriteCacheRequest_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 (*SealWriteCacheRequest_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use SealWriteCacheRequest_Body.ProtoReflect.Descriptor instead.

func (*SealWriteCacheRequest_Body) GetIgnoreErrors added in v0.38.0

func (x *SealWriteCacheRequest_Body) GetIgnoreErrors() bool

func (*SealWriteCacheRequest_Body) GetShard_ID added in v0.38.0

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

func (*SealWriteCacheRequest_Body) ProtoMessage added in v0.38.0

func (*SealWriteCacheRequest_Body) ProtoMessage()

func (*SealWriteCacheRequest_Body) ProtoReflect added in v0.38.0

func (*SealWriteCacheRequest_Body) Reset added in v0.38.0

func (x *SealWriteCacheRequest_Body) Reset()

func (*SealWriteCacheRequest_Body) StableMarshal added in v0.38.0

func (x *SealWriteCacheRequest_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 (*SealWriteCacheRequest_Body) StableSize added in v0.38.0

func (x *SealWriteCacheRequest_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 (*SealWriteCacheRequest_Body) String added in v0.38.0

func (x *SealWriteCacheRequest_Body) String() string

type SealWriteCacheResponse added in v0.38.0

type SealWriteCacheResponse struct {
	Body      *SealWriteCacheResponse_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
}

func SealWriteCache added in v0.38.0

func SealWriteCache(cli *client.Client, req *SealWriteCacheRequest, opts ...client.CallOption) (*SealWriteCacheResponse, error)

SealWriteCache executes ControlService.SealWriteCache RPC.

func (*SealWriteCacheResponse) Descriptor deprecated added in v0.38.0

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

Deprecated: Use SealWriteCacheResponse.ProtoReflect.Descriptor instead.

func (*SealWriteCacheResponse) GetBody added in v0.38.0

func (*SealWriteCacheResponse) GetSignature added in v0.38.0

func (x *SealWriteCacheResponse) GetSignature() *Signature

func (*SealWriteCacheResponse) ProtoMessage added in v0.38.0

func (*SealWriteCacheResponse) ProtoMessage()

func (*SealWriteCacheResponse) ProtoReflect added in v0.38.0

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

func (*SealWriteCacheResponse) ReadSignedData added in v0.38.0

func (x *SealWriteCacheResponse) 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 (*SealWriteCacheResponse) Reset added in v0.38.0

func (x *SealWriteCacheResponse) Reset()

func (*SealWriteCacheResponse) SetSignature added in v0.38.0

func (x *SealWriteCacheResponse) SetSignature(sig *Signature)

func (*SealWriteCacheResponse) SignedDataSize added in v0.38.0

func (x *SealWriteCacheResponse) 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 (*SealWriteCacheResponse) StableMarshal added in v0.38.0

func (x *SealWriteCacheResponse) 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 (*SealWriteCacheResponse) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*SealWriteCacheResponse) String added in v0.38.0

func (x *SealWriteCacheResponse) String() string

type SealWriteCacheResponse_Body added in v0.38.0

type SealWriteCacheResponse_Body struct {
	Results []*SealWriteCacheResponse_Body_Status `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*SealWriteCacheResponse_Body) Descriptor deprecated added in v0.38.0

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

Deprecated: Use SealWriteCacheResponse_Body.ProtoReflect.Descriptor instead.

func (*SealWriteCacheResponse_Body) GetResults added in v0.38.0

func (*SealWriteCacheResponse_Body) ProtoMessage added in v0.38.0

func (*SealWriteCacheResponse_Body) ProtoMessage()

func (*SealWriteCacheResponse_Body) ProtoReflect added in v0.38.0

func (*SealWriteCacheResponse_Body) Reset added in v0.38.0

func (x *SealWriteCacheResponse_Body) Reset()

func (*SealWriteCacheResponse_Body) StableMarshal added in v0.38.0

func (x *SealWriteCacheResponse_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 (*SealWriteCacheResponse_Body) StableSize added in v0.38.0

func (x *SealWriteCacheResponse_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 (*SealWriteCacheResponse_Body) String added in v0.38.0

func (x *SealWriteCacheResponse_Body) String() string

type SealWriteCacheResponse_Body_Status added in v0.38.0

type SealWriteCacheResponse_Body_Status struct {
	Shard_ID []byte `protobuf:"bytes,1,opt,name=shard_ID,json=shardID,proto3" json:"shard_ID,omitempty"`
	Success  bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error    string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SealWriteCacheResponse_Body_Status) Descriptor deprecated added in v0.38.0

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

Deprecated: Use SealWriteCacheResponse_Body_Status.ProtoReflect.Descriptor instead.

func (*SealWriteCacheResponse_Body_Status) GetError added in v0.38.0

func (*SealWriteCacheResponse_Body_Status) GetShard_ID added in v0.38.0

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

func (*SealWriteCacheResponse_Body_Status) GetSuccess added in v0.38.0

func (x *SealWriteCacheResponse_Body_Status) GetSuccess() bool

func (*SealWriteCacheResponse_Body_Status) ProtoMessage added in v0.38.0

func (*SealWriteCacheResponse_Body_Status) ProtoMessage()

func (*SealWriteCacheResponse_Body_Status) ProtoReflect added in v0.38.0

func (*SealWriteCacheResponse_Body_Status) Reset added in v0.38.0

func (*SealWriteCacheResponse_Body_Status) StableMarshal added in v0.38.0

func (x *SealWriteCacheResponse_Body_Status) 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 (*SealWriteCacheResponse_Body_Status) StableSize added in v0.38.0

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

StableSize returns the size of x in protobuf format.

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

func (*SealWriteCacheResponse_Body_Status) String added in v0.38.0

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 (*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

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 (*SetNetmapStatusRequest_Body) ProtoMessage

func (*SetNetmapStatusRequest_Body) ProtoMessage()

func (*SetNetmapStatusRequest_Body) ProtoReflect

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 (*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

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 (*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

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 (*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

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 (*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

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 (*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

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 StartShardEvacuationRequest added in v0.37.0

type StartShardEvacuationRequest struct {
	Body      *StartShardEvacuationRequest_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
}

StartShardEvacuation request.

func (*StartShardEvacuationRequest) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StartShardEvacuationRequest.ProtoReflect.Descriptor instead.

func (*StartShardEvacuationRequest) GetBody added in v0.37.0

func (*StartShardEvacuationRequest) GetSignature added in v0.37.0

func (x *StartShardEvacuationRequest) GetSignature() *Signature

func (*StartShardEvacuationRequest) ProtoMessage added in v0.37.0

func (*StartShardEvacuationRequest) ProtoMessage()

func (*StartShardEvacuationRequest) ProtoReflect added in v0.37.0

func (*StartShardEvacuationRequest) ReadSignedData added in v0.37.0

func (x *StartShardEvacuationRequest) 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 (*StartShardEvacuationRequest) Reset added in v0.37.0

func (x *StartShardEvacuationRequest) Reset()

func (*StartShardEvacuationRequest) SetSignature added in v0.37.0

func (x *StartShardEvacuationRequest) SetSignature(sig *Signature)

func (*StartShardEvacuationRequest) SignedDataSize added in v0.37.0

func (x *StartShardEvacuationRequest) 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 (*StartShardEvacuationRequest) StableMarshal added in v0.37.0

func (x *StartShardEvacuationRequest) 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 (*StartShardEvacuationRequest) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*StartShardEvacuationRequest) String added in v0.37.0

func (x *StartShardEvacuationRequest) String() string

type StartShardEvacuationRequest_Body added in v0.37.0

type StartShardEvacuationRequest_Body struct {

	// IDs of the shards.
	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"`
	// Evacuation scope.
	Scope uint32 `protobuf:"varint,3,opt,name=scope,proto3" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

Request body structure.

func (*StartShardEvacuationRequest_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StartShardEvacuationRequest_Body.ProtoReflect.Descriptor instead.

func (*StartShardEvacuationRequest_Body) GetIgnoreErrors added in v0.37.0

func (x *StartShardEvacuationRequest_Body) GetIgnoreErrors() bool

func (*StartShardEvacuationRequest_Body) GetScope added in v0.38.0

func (*StartShardEvacuationRequest_Body) GetShard_ID added in v0.37.0

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

func (*StartShardEvacuationRequest_Body) ProtoMessage added in v0.37.0

func (*StartShardEvacuationRequest_Body) ProtoMessage()

func (*StartShardEvacuationRequest_Body) ProtoReflect added in v0.37.0

func (*StartShardEvacuationRequest_Body) Reset added in v0.37.0

func (*StartShardEvacuationRequest_Body) StableMarshal added in v0.37.0

func (x *StartShardEvacuationRequest_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 (*StartShardEvacuationRequest_Body) StableSize added in v0.37.0

func (x *StartShardEvacuationRequest_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 (*StartShardEvacuationRequest_Body) String added in v0.37.0

type StartShardEvacuationRequest_Body_Scope added in v0.38.0

type StartShardEvacuationRequest_Body_Scope int32
const (
	StartShardEvacuationRequest_Body_NONE    StartShardEvacuationRequest_Body_Scope = 0
	StartShardEvacuationRequest_Body_OBJECTS StartShardEvacuationRequest_Body_Scope = 1
	StartShardEvacuationRequest_Body_TREES   StartShardEvacuationRequest_Body_Scope = 2
)

func (StartShardEvacuationRequest_Body_Scope) Descriptor added in v0.38.0

func (StartShardEvacuationRequest_Body_Scope) Enum added in v0.38.0

func (StartShardEvacuationRequest_Body_Scope) EnumDescriptor deprecated added in v0.38.0

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

Deprecated: Use StartShardEvacuationRequest_Body_Scope.Descriptor instead.

func (StartShardEvacuationRequest_Body_Scope) Number added in v0.38.0

func (StartShardEvacuationRequest_Body_Scope) String added in v0.38.0

func (StartShardEvacuationRequest_Body_Scope) Type added in v0.38.0

type StartShardEvacuationResponse added in v0.37.0

type StartShardEvacuationResponse struct {
	Body      *StartShardEvacuationResponse_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
}

StartShardEvacuation response.

func StartShardEvacuation added in v0.37.0

func StartShardEvacuation(cli *client.Client, req *StartShardEvacuationRequest, opts ...client.CallOption) (*StartShardEvacuationResponse, error)

StartShardEvacuation executes ControlService.StartShardEvacuation RPC.

func (*StartShardEvacuationResponse) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StartShardEvacuationResponse.ProtoReflect.Descriptor instead.

func (*StartShardEvacuationResponse) GetBody added in v0.37.0

func (*StartShardEvacuationResponse) GetSignature added in v0.37.0

func (x *StartShardEvacuationResponse) GetSignature() *Signature

func (*StartShardEvacuationResponse) ProtoMessage added in v0.37.0

func (*StartShardEvacuationResponse) ProtoMessage()

func (*StartShardEvacuationResponse) ProtoReflect added in v0.37.0

func (*StartShardEvacuationResponse) ReadSignedData added in v0.37.0

func (x *StartShardEvacuationResponse) 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 (*StartShardEvacuationResponse) Reset added in v0.37.0

func (x *StartShardEvacuationResponse) Reset()

func (*StartShardEvacuationResponse) SetSignature added in v0.37.0

func (x *StartShardEvacuationResponse) SetSignature(sig *Signature)

func (*StartShardEvacuationResponse) SignedDataSize added in v0.37.0

func (x *StartShardEvacuationResponse) 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 (*StartShardEvacuationResponse) StableMarshal added in v0.37.0

func (x *StartShardEvacuationResponse) 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 (*StartShardEvacuationResponse) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*StartShardEvacuationResponse) String added in v0.37.0

type StartShardEvacuationResponse_Body added in v0.37.0

type StartShardEvacuationResponse_Body struct {
	// contains filtered or unexported fields
}

Response body structure.

func (*StartShardEvacuationResponse_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StartShardEvacuationResponse_Body.ProtoReflect.Descriptor instead.

func (*StartShardEvacuationResponse_Body) ProtoMessage added in v0.37.0

func (*StartShardEvacuationResponse_Body) ProtoMessage()

func (*StartShardEvacuationResponse_Body) ProtoReflect added in v0.37.0

func (*StartShardEvacuationResponse_Body) Reset added in v0.37.0

func (*StartShardEvacuationResponse_Body) StableMarshal added in v0.37.0

func (x *StartShardEvacuationResponse_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 (*StartShardEvacuationResponse_Body) StableSize added in v0.37.0

func (x *StartShardEvacuationResponse_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 (*StartShardEvacuationResponse_Body) String added in v0.37.0

type StopShardEvacuationRequest added in v0.37.0

type StopShardEvacuationRequest struct {
	Body      *StopShardEvacuationRequest_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
}

StopShardEvacuation request.

func (*StopShardEvacuationRequest) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StopShardEvacuationRequest.ProtoReflect.Descriptor instead.

func (*StopShardEvacuationRequest) GetBody added in v0.37.0

func (*StopShardEvacuationRequest) GetSignature added in v0.37.0

func (x *StopShardEvacuationRequest) GetSignature() *Signature

func (*StopShardEvacuationRequest) ProtoMessage added in v0.37.0

func (*StopShardEvacuationRequest) ProtoMessage()

func (*StopShardEvacuationRequest) ProtoReflect added in v0.37.0

func (*StopShardEvacuationRequest) ReadSignedData added in v0.37.0

func (x *StopShardEvacuationRequest) 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 (*StopShardEvacuationRequest) Reset added in v0.37.0

func (x *StopShardEvacuationRequest) Reset()

func (*StopShardEvacuationRequest) SetSignature added in v0.37.0

func (x *StopShardEvacuationRequest) SetSignature(sig *Signature)

func (*StopShardEvacuationRequest) SignedDataSize added in v0.37.0

func (x *StopShardEvacuationRequest) 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 (*StopShardEvacuationRequest) StableMarshal added in v0.37.0

func (x *StopShardEvacuationRequest) 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 (*StopShardEvacuationRequest) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*StopShardEvacuationRequest) String added in v0.37.0

func (x *StopShardEvacuationRequest) String() string

type StopShardEvacuationRequest_Body added in v0.37.0

type StopShardEvacuationRequest_Body struct {
	// contains filtered or unexported fields
}

Request body structure.

func (*StopShardEvacuationRequest_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StopShardEvacuationRequest_Body.ProtoReflect.Descriptor instead.

func (*StopShardEvacuationRequest_Body) ProtoMessage added in v0.37.0

func (*StopShardEvacuationRequest_Body) ProtoMessage()

func (*StopShardEvacuationRequest_Body) ProtoReflect added in v0.37.0

func (*StopShardEvacuationRequest_Body) Reset added in v0.37.0

func (*StopShardEvacuationRequest_Body) StableMarshal added in v0.37.0

func (x *StopShardEvacuationRequest_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 (*StopShardEvacuationRequest_Body) StableSize added in v0.37.0

func (x *StopShardEvacuationRequest_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 (*StopShardEvacuationRequest_Body) String added in v0.37.0

type StopShardEvacuationResponse added in v0.37.0

type StopShardEvacuationResponse struct {
	Body      *StopShardEvacuationResponse_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
}

StopShardEvacuation response.

func StopShardEvacuation added in v0.37.0

func StopShardEvacuation(cli *client.Client, req *StopShardEvacuationRequest, opts ...client.CallOption) (*StopShardEvacuationResponse, error)

StopShardEvacuation executes ControlService.StopShardEvacuation RPC.

func (*StopShardEvacuationResponse) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StopShardEvacuationResponse.ProtoReflect.Descriptor instead.

func (*StopShardEvacuationResponse) GetBody added in v0.37.0

func (*StopShardEvacuationResponse) GetSignature added in v0.37.0

func (x *StopShardEvacuationResponse) GetSignature() *Signature

func (*StopShardEvacuationResponse) ProtoMessage added in v0.37.0

func (*StopShardEvacuationResponse) ProtoMessage()

func (*StopShardEvacuationResponse) ProtoReflect added in v0.37.0

func (*StopShardEvacuationResponse) ReadSignedData added in v0.37.0

func (x *StopShardEvacuationResponse) 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 (*StopShardEvacuationResponse) Reset added in v0.37.0

func (x *StopShardEvacuationResponse) Reset()

func (*StopShardEvacuationResponse) SetSignature added in v0.37.0

func (x *StopShardEvacuationResponse) SetSignature(sig *Signature)

func (*StopShardEvacuationResponse) SignedDataSize added in v0.37.0

func (x *StopShardEvacuationResponse) 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 (*StopShardEvacuationResponse) StableMarshal added in v0.37.0

func (x *StopShardEvacuationResponse) 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 (*StopShardEvacuationResponse) StableSize added in v0.37.0

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

StableSize returns the size of x in protobuf format.

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

func (*StopShardEvacuationResponse) String added in v0.37.0

func (x *StopShardEvacuationResponse) String() string

type StopShardEvacuationResponse_Body added in v0.37.0

type StopShardEvacuationResponse_Body struct {
	// contains filtered or unexported fields
}

Response body structure.

func (*StopShardEvacuationResponse_Body) Descriptor deprecated added in v0.37.0

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

Deprecated: Use StopShardEvacuationResponse_Body.ProtoReflect.Descriptor instead.

func (*StopShardEvacuationResponse_Body) ProtoMessage added in v0.37.0

func (*StopShardEvacuationResponse_Body) ProtoMessage()

func (*StopShardEvacuationResponse_Body) ProtoReflect added in v0.37.0

func (*StopShardEvacuationResponse_Body) Reset added in v0.37.0

func (*StopShardEvacuationResponse_Body) StableMarshal added in v0.37.0

func (x *StopShardEvacuationResponse_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 (*StopShardEvacuationResponse_Body) StableSize added in v0.37.0

func (x *StopShardEvacuationResponse_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 (*StopShardEvacuationResponse_Body) String added in v0.37.0

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 (*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

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 (*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 (*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

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 (*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

type UnimplementedControlServiceServer

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedControlServiceServer) AddChainLocalOverride added in v0.38.0

func (UnimplementedControlServiceServer) DetachShards added in v0.38.0

func (UnimplementedControlServiceServer) Doctor

func (UnimplementedControlServiceServer) DropObjects

func (UnimplementedControlServiceServer) EvacuateShard

func (UnimplementedControlServiceServer) FlushCache

func (UnimplementedControlServiceServer) GetChainLocalOverride added in v0.38.0

func (UnimplementedControlServiceServer) GetShardEvacuationStatus added in v0.37.0

func (UnimplementedControlServiceServer) HealthCheck

func (UnimplementedControlServiceServer) ListChainLocalOverrides added in v0.38.0

func (UnimplementedControlServiceServer) ListShards

func (UnimplementedControlServiceServer) ListTargetsLocalOverrides added in v0.38.0

func (UnimplementedControlServiceServer) RemoveChainLocalOverride added in v0.38.0

func (UnimplementedControlServiceServer) RemoveChainLocalOverridesByTarget added in v0.38.0

func (UnimplementedControlServiceServer) ResetShardEvacuationStatus added in v0.38.0

func (UnimplementedControlServiceServer) SealWriteCache added in v0.38.0

func (UnimplementedControlServiceServer) SetNetmapStatus

func (UnimplementedControlServiceServer) SetShardMode

func (UnimplementedControlServiceServer) StartShardEvacuation added in v0.37.0

func (UnimplementedControlServiceServer) StopShardEvacuation added in v0.37.0

func (UnimplementedControlServiceServer) SynchronizeTree

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.

Directories

Path Synopsis
ir
ape

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL