proto

package
v0.0.0-...-ba27772 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Orchestrator_Move_FullMethodName  = "/ranger.Orchestrator/Move"
	Orchestrator_Split_FullMethodName = "/ranger.Orchestrator/Split"
	Orchestrator_Join_FullMethodName  = "/ranger.Orchestrator/Join"
)
View Source 
const (
	Debug_RangesList_FullMethodName = "/ranger.Debug/RangesList"
	Debug_Range_FullMethodName      = "/ranger.Debug/Range"
	Debug_NodesList_FullMethodName  = "/ranger.Debug/NodesList"
	Debug_Node_FullMethodName       = "/ranger.Debug/Node"
)
View Source 
const (
	Node_Prepare_FullMethodName    = "/ranger.Node/Prepare"
	Node_Activate_FullMethodName   = "/ranger.Node/Activate"
	Node_Deactivate_FullMethodName = "/ranger.Node/Deactivate"
	Node_Drop_FullMethodName       = "/ranger.Node/Drop"
	Node_Info_FullMethodName       = "/ranger.Node/Info"
	Node_Ranges_FullMethodName     = "/ranger.Node/Ranges"
)

Variables

View Source 
var (
	RangeNodeState_name = map[int32]string{
		0: "UNKNOWN",
		1: "INACTIVE",
		2: "ACTIVE",
		3: "PREPARING",
		4: "ACTIVATING",
		5: "DEACTIVATING",
		6: "DROPPING",
		7: "NOT_FOUND",
	}
	RangeNodeState_value = map[string]int32{
		"UNKNOWN":      0,
		"INACTIVE":     1,
		"ACTIVE":       2,
		"PREPARING":    3,
		"ACTIVATING":   4,
		"DEACTIVATING": 5,
		"DROPPING":     6,
		"NOT_FOUND":    7,
	}
)

Enum value maps for RangeNodeState.

View Source 
var (
	RangeState_name = map[int32]string{
		0: "RS_UNKNOWN",
		1: "RS_ACTIVE",
		2: "RS_SUBSUMING",
		3: "RS_OBSOLETE",
	}
	RangeState_value = map[string]int32{
		"RS_UNKNOWN":   0,
		"RS_ACTIVE":    1,
		"RS_SUBSUMING": 2,
		"RS_OBSOLETE":  3,
	}
)

Enum value maps for RangeState.

View Source 
var (
	PlacementState_name = map[int32]string{
		0: "PS_UNKNOWN",
		1: "PS_PENDING",
		2: "PS_INACTIVE",
		3: "PS_ACTIVE",
		5: "PS_MISSING",
		6: "PS_DROPPED",
	}
	PlacementState_value = map[string]int32{
		"PS_UNKNOWN":  0,
		"PS_PENDING":  1,
		"PS_INACTIVE": 2,
		"PS_ACTIVE":   3,
		"PS_MISSING":  5,
		"PS_DROPPED":  6,
	}
)

Enum value maps for PlacementState.

View Source 
var Debug_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ranger.Debug",
	HandlerType: (*DebugServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RangesList",
			Handler:    _Debug_RangesList_Handler,
		},
		{
			MethodName: "Range",
			Handler:    _Debug_Range_Handler,
		},
		{
			MethodName: "NodesList",
			Handler:    _Debug_NodesList_Handler,
		},
		{
			MethodName: "Node",
			Handler:    _Debug_Node_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "debug.proto",
}

Debug_ServiceDesc is the grpc.ServiceDesc for Debug 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_controller_proto protoreflect.FileDescriptor
View Source 
var File_debug_proto protoreflect.FileDescriptor
View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var File_ranje_proto protoreflect.FileDescriptor
View Source 
var Node_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ranger.Node",
	HandlerType: (*NodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Prepare",
			Handler:    _Node_Prepare_Handler,
		},
		{
			MethodName: "Activate",
			Handler:    _Node_Activate_Handler,
		},
		{
			MethodName: "Deactivate",
			Handler:    _Node_Deactivate_Handler,
		},
		{
			MethodName: "Drop",
			Handler:    _Node_Drop_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _Node_Info_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Ranges",
			Handler:       _Node_Ranges_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "node.proto",
}

Node_ServiceDesc is the grpc.ServiceDesc for Node 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 Orchestrator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ranger.Orchestrator",
	HandlerType: (*OrchestratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Move",
			Handler:    _Orchestrator_Move_Handler,
		},
		{
			MethodName: "Split",
			Handler:    _Orchestrator_Split_Handler,
		},
		{
			MethodName: "Join",
			Handler:    _Orchestrator_Join_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "controller.proto",
}

Orchestrator_ServiceDesc is the grpc.ServiceDesc for Orchestrator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDebugServer 

func RegisterDebugServer(s grpc.ServiceRegistrar, srv DebugServer)

func RegisterNodeServer 

func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

func RegisterOrchestratorServer 

func RegisterOrchestratorServer(s grpc.ServiceRegistrar, srv OrchestratorServer)

Types

type DeactivateRequest 

type DeactivateRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*DeactivateRequest) Descriptor deprecated 

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

Deprecated: Use DeactivateRequest.ProtoReflect.Descriptor instead.

func (*DeactivateRequest) GetRange 

func (x *DeactivateRequest) GetRange() uint64

func (*DeactivateRequest) ProtoMessage 

func (*DeactivateRequest) ProtoMessage()

func (*DeactivateRequest) ProtoReflect 

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

func (*DeactivateRequest) Reset 

func (x *DeactivateRequest) Reset()

func (*DeactivateRequest) String 

func (x *DeactivateRequest) String() string

type DeactivateResponse 

type DeactivateResponse struct {
	State RangeNodeState `protobuf:"varint,1,opt,name=state,proto3,enum=ranger.RangeNodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*DeactivateResponse) Descriptor deprecated 

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

Deprecated: Use DeactivateResponse.ProtoReflect.Descriptor instead.

func (*DeactivateResponse) GetState 

func (x *DeactivateResponse) GetState() RangeNodeState

func (*DeactivateResponse) ProtoMessage 

func (*DeactivateResponse) ProtoMessage()

func (*DeactivateResponse) ProtoReflect 

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

func (*DeactivateResponse) Reset 

func (x *DeactivateResponse) Reset()

func (*DeactivateResponse) String 

func (x *DeactivateResponse) String() string

type DebugClient 

type DebugClient interface {
	RangesList(ctx context.Context, in *RangesListRequest, opts ...grpc.CallOption) (*RangesListResponse, error)
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	NodesList(ctx context.Context, in *NodesListRequest, opts ...grpc.CallOption) (*NodesListResponse, error)
	Node(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeResponse, error)
}

DebugClient is the client API for Debug service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDebugClient 

func NewDebugClient(cc grpc.ClientConnInterface) DebugClient

type DebugServer 

type DebugServer interface {
	RangesList(context.Context, *RangesListRequest) (*RangesListResponse, error)
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	NodesList(context.Context, *NodesListRequest) (*NodesListResponse, error)
	Node(context.Context, *NodeRequest) (*NodeResponse, error)
	// contains filtered or unexported methods
}

DebugServer is the server API for Debug service. All implementations must embed UnimplementedDebugServer for forward compatibility

type DropRequest 

type DropRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DropRequest) Descriptor deprecated 

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

Deprecated: Use DropRequest.ProtoReflect.Descriptor instead.

func (*DropRequest) GetForce 

func (x *DropRequest) GetForce() bool

func (*DropRequest) GetRange 

func (x *DropRequest) GetRange() uint64

func (*DropRequest) ProtoMessage 

func (*DropRequest) ProtoMessage()

func (*DropRequest) ProtoReflect 

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

func (*DropRequest) Reset 

func (x *DropRequest) Reset()

func (*DropRequest) String 

func (x *DropRequest) String() string

type DropResponse 

type DropResponse struct {
	State RangeNodeState `protobuf:"varint,1,opt,name=state,proto3,enum=ranger.RangeNodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*DropResponse) Descriptor deprecated 

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

Deprecated: Use DropResponse.ProtoReflect.Descriptor instead.

func (*DropResponse) GetState 

func (x *DropResponse) GetState() RangeNodeState

func (*DropResponse) ProtoMessage 

func (*DropResponse) ProtoMessage()

func (*DropResponse) ProtoReflect 

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

func (*DropResponse) Reset 

func (x *DropResponse) Reset()

func (*DropResponse) String 

func (x *DropResponse) String() string

type InfoRequest 

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

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

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

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Ranges []*RangeInfo `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// The nod wants the controller to remove all ranges from it. Probably because
	// it wants to shut down gracefully.
	WantDrain bool `protobuf:"varint,2,opt,name=wantDrain,proto3" json:"wantDrain,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetRanges 

func (x *InfoResponse) GetRanges() []*RangeInfo

func (*InfoResponse) GetWantDrain 

func (x *InfoResponse) GetWantDrain() bool

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

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

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type JoinRequest 

type JoinRequest struct {
	RangeLeft  uint64 `protobuf:"varint,1,opt,name=range_left,json=rangeLeft,proto3" json:"range_left,omitempty"`
	RangeRight uint64 `protobuf:"varint,2,opt,name=range_right,json=rangeRight,proto3" json:"range_right,omitempty"`
	// The ident of the node to assign the resulting range to.
	Node string `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated 

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetNode 

func (x *JoinRequest) GetNode() string

func (*JoinRequest) GetRangeLeft 

func (x *JoinRequest) GetRangeLeft() uint64

func (*JoinRequest) GetRangeRight 

func (x *JoinRequest) GetRangeRight() uint64

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect 

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

func (*JoinRequest) Reset 

func (x *JoinRequest) Reset()

func (*JoinRequest) String 

func (x *JoinRequest) String() string

type JoinResponse 

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

func (*JoinResponse) Descriptor deprecated 

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

Deprecated: Use JoinResponse.ProtoReflect.Descriptor instead.

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) ProtoReflect 

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

func (*JoinResponse) Reset 

func (x *JoinResponse) Reset()

func (*JoinResponse) String 

func (x *JoinResponse) String() string

type LoadInfo 

type LoadInfo struct {

	// Number of keys which this range contains.
	// Just for reporting? Not balancing?
	Keys uint64 `protobuf:"varint,1,opt,name=keys,proto3" json:"keys,omitempty"`
	// Where the node would suggest that this range be split, in order for the
	// resulting ranges to be evenly loaded. Otherwise the mid-point between start
	// and end keys will be used, which is probably not an even split.
	Splits []string `protobuf:"bytes,2,rep,name=splits,proto3" json:"splits,omitempty"`
	// contains filtered or unexported fields
}

Proto of rangelet.LoadInfo and roster.LoadInfo

func (*LoadInfo) Descriptor deprecated 

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

Deprecated: Use LoadInfo.ProtoReflect.Descriptor instead.

func (*LoadInfo) GetKeys 

func (x *LoadInfo) GetKeys() uint64

func (*LoadInfo) GetSplits 

func (x *LoadInfo) GetSplits() []string

func (*LoadInfo) ProtoMessage 

func (*LoadInfo) ProtoMessage()

func (*LoadInfo) ProtoReflect 

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

func (*LoadInfo) Reset 

func (x *LoadInfo) Reset()

func (*LoadInfo) String 

func (x *LoadInfo) String() string

type MoveRequest 

type MoveRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	// The ident of the node to assign the range to.
	// TODO: Also allow nodes to identified by other features.
	// TODO: Does this need its own message type?
	Node string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest) Descriptor deprecated 

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

Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.

func (*MoveRequest) GetNode 

func (x *MoveRequest) GetNode() string

func (*MoveRequest) GetRange 

func (x *MoveRequest) GetRange() uint64

func (*MoveRequest) ProtoMessage 

func (*MoveRequest) ProtoMessage()

func (*MoveRequest) ProtoReflect 

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

func (*MoveRequest) Reset 

func (x *MoveRequest) Reset()

func (*MoveRequest) String 

func (x *MoveRequest) String() string

type MoveResponse 

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

func (*MoveResponse) Descriptor deprecated 

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

Deprecated: Use MoveResponse.ProtoReflect.Descriptor instead.

func (*MoveResponse) ProtoMessage 

func (*MoveResponse) ProtoMessage()

func (*MoveResponse) ProtoReflect 

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

func (*MoveResponse) Reset 

func (x *MoveResponse) Reset()

func (*MoveResponse) String 

func (x *MoveResponse) String() string

type NodeClient 

type NodeClient interface {
	Prepare(ctx context.Context, in *PrepareRequest, opts ...grpc.CallOption) (*PrepareResponse, error)
	Activate(ctx context.Context, in *ServeRequest, opts ...grpc.CallOption) (*ServeResponse, error)
	Deactivate(ctx context.Context, in *DeactivateRequest, opts ...grpc.CallOption) (*DeactivateResponse, error)
	Drop(ctx context.Context, in *DropRequest, opts ...grpc.CallOption) (*DropResponse, error)
	// Controller wants to know the state of the node, including its ranges.
	// Proxy shouldn't call this; use Ranges instead.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// Proxy wants to know what it can forward to this node.
	// Controller shouldn't call this; use Info instead.
	Ranges(ctx context.Context, in *RangesRequest, opts ...grpc.CallOption) (Node_RangesClient, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeClient 

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeMeta 

type NodeMeta struct {
	Ident     string `protobuf:"bytes,1,opt,name=ident,proto3" json:"ident,omitempty"`
	Address   string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	WantDrain bool   `protobuf:"varint,3,opt,name=want_drain,json=wantDrain,proto3" json:"want_drain,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeMeta) Descriptor deprecated 

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

Deprecated: Use NodeMeta.ProtoReflect.Descriptor instead.

func (*NodeMeta) GetAddress 

func (x *NodeMeta) GetAddress() string

func (*NodeMeta) GetIdent 

func (x *NodeMeta) GetIdent() string

func (*NodeMeta) GetWantDrain 

func (x *NodeMeta) GetWantDrain() bool

func (*NodeMeta) ProtoMessage 

func (*NodeMeta) ProtoMessage()

func (*NodeMeta) ProtoReflect 

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

func (*NodeMeta) Reset 

func (x *NodeMeta) Reset()

func (*NodeMeta) String 

func (x *NodeMeta) String() string

type NodeRange 

type NodeRange struct {
	Meta  *RangeMeta     `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	State PlacementState `protobuf:"varint,3,opt,name=state,proto3,enum=ranger.PlacementState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

TODO: Remove this, and use PlacementWithRangeInfo

func (*NodeRange) Descriptor deprecated 

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

Deprecated: Use NodeRange.ProtoReflect.Descriptor instead.

func (*NodeRange) GetMeta 

func (x *NodeRange) GetMeta() *RangeMeta

func (*NodeRange) GetState 

func (x *NodeRange) GetState() PlacementState

func (*NodeRange) ProtoMessage 

func (*NodeRange) ProtoMessage()

func (*NodeRange) ProtoReflect 

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

func (*NodeRange) Reset 

func (x *NodeRange) Reset()

func (*NodeRange) String 

func (x *NodeRange) String() string

type NodeRequest 

type NodeRequest struct {
	Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRequest) Descriptor deprecated 

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

Deprecated: Use NodeRequest.ProtoReflect.Descriptor instead.

func (*NodeRequest) GetNode 

func (x *NodeRequest) GetNode() string

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) ProtoReflect 

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

func (*NodeRequest) Reset 

func (x *NodeRequest) Reset()

func (*NodeRequest) String 

func (x *NodeRequest) String() string

type NodeResponse 

type NodeResponse struct {
	Node   *NodeMeta    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Ranges []*NodeRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResponse) Descriptor deprecated 

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

Deprecated: Use NodeResponse.ProtoReflect.Descriptor instead.

func (*NodeResponse) GetNode 

func (x *NodeResponse) GetNode() *NodeMeta

func (*NodeResponse) GetRanges 

func (x *NodeResponse) GetRanges() []*NodeRange

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) ProtoReflect 

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

func (*NodeResponse) Reset 

func (x *NodeResponse) Reset()

func (*NodeResponse) String 

func (x *NodeResponse) String() string

type NodeServer 

type NodeServer interface {
	Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)
	Activate(context.Context, *ServeRequest) (*ServeResponse, error)
	Deactivate(context.Context, *DeactivateRequest) (*DeactivateResponse, error)
	Drop(context.Context, *DropRequest) (*DropResponse, error)
	// Controller wants to know the state of the node, including its ranges.
	// Proxy shouldn't call this; use Ranges instead.
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	// Proxy wants to know what it can forward to this node.
	// Controller shouldn't call this; use Info instead.
	Ranges(*RangesRequest, Node_RangesServer) error
	// contains filtered or unexported methods
}

NodeServer is the server API for Node service. All implementations must embed UnimplementedNodeServer for forward compatibility

type Node_RangesClient 

type Node_RangesClient interface {
	Recv() (*RangesResponse, error)
	grpc.ClientStream
}

type Node_RangesServer 

type Node_RangesServer interface {
	Send(*RangesResponse) error
	grpc.ServerStream
}

type NodesListRequest 

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

func (*NodesListRequest) Descriptor deprecated 

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

Deprecated: Use NodesListRequest.ProtoReflect.Descriptor instead.

func (*NodesListRequest) ProtoMessage 

func (*NodesListRequest) ProtoMessage()

func (*NodesListRequest) ProtoReflect 

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

func (*NodesListRequest) Reset 

func (x *NodesListRequest) Reset()

func (*NodesListRequest) String 

func (x *NodesListRequest) String() string

type NodesListResponse 

type NodesListResponse struct {
	Nodes []*NodeResponse `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*NodesListResponse) Descriptor deprecated 

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

Deprecated: Use NodesListResponse.ProtoReflect.Descriptor instead.

func (*NodesListResponse) GetNodes 

func (x *NodesListResponse) GetNodes() []*NodeResponse

func (*NodesListResponse) ProtoMessage 

func (*NodesListResponse) ProtoMessage()

func (*NodesListResponse) ProtoReflect 

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

func (*NodesListResponse) Reset 

func (x *NodesListResponse) Reset()

func (*NodesListResponse) String 

func (x *NodesListResponse) String() string

type OrchestratorClient 

type OrchestratorClient interface {
	// Place a range on specific node, moving it from the node it is currently
	// placed on, if any.
	Move(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*MoveResponse, error)
	// Split a range in two.
	Split(ctx context.Context, in *SplitRequest, opts ...grpc.CallOption) (*SplitResponse, error)
	// Join two ranges into one.
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
}

OrchestratorClient is the client API for Orchestrator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOrchestratorClient 

func NewOrchestratorClient(cc grpc.ClientConnInterface) OrchestratorClient

type OrchestratorServer 

type OrchestratorServer interface {
	// Place a range on specific node, moving it from the node it is currently
	// placed on, if any.
	Move(context.Context, *MoveRequest) (*MoveResponse, error)
	// Split a range in two.
	Split(context.Context, *SplitRequest) (*SplitResponse, error)
	// Join two ranges into one.
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// contains filtered or unexported methods
}

OrchestratorServer is the server API for Orchestrator service. All implementations must embed UnimplementedOrchestratorServer for forward compatibility

type Parent 

type Parent struct {
	Range *RangeMeta `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// Range IDs in here may not appear in the PrepareRequest, because at some point
	// the history is pruned.
	Parent []uint64 `protobuf:"varint,2,rep,packed,name=parent,proto3" json:"parent,omitempty"`
	// TODO: This should probably be two fields, host and port? Or node ident?
	Placements []*Placement `protobuf:"bytes,3,rep,name=placements,proto3" json:"placements,omitempty"`
	// contains filtered or unexported fields
}

func (*Parent) Descriptor deprecated 

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

Deprecated: Use Parent.ProtoReflect.Descriptor instead.

func (*Parent) GetParent 

func (x *Parent) GetParent() []uint64

func (*Parent) GetPlacements 

func (x *Parent) GetPlacements() []*Placement

func (*Parent) GetRange 

func (x *Parent) GetRange() *RangeMeta

func (*Parent) ProtoMessage 

func (*Parent) ProtoMessage()

func (*Parent) ProtoReflect 

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

func (*Parent) Reset 

func (x *Parent) Reset()

func (*Parent) String 

func (x *Parent) String() string

type Placement 

type Placement struct {
	Node  string         `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	State PlacementState `protobuf:"varint,2,opt,name=state,proto3,enum=ranger.PlacementState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Sent from the controller with Prepare.

TODO: Should include the placement index in here, so the node can verify that the controller is talking about the same placement when it sees duplicates. Just in case the controller has gone mad and is trying to place multiple replicas of the same range on a single node.

func (*Placement) Descriptor deprecated 

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

Deprecated: Use Placement.ProtoReflect.Descriptor instead.

func (*Placement) GetNode 

func (x *Placement) GetNode() string

func (*Placement) GetState 

func (x *Placement) GetState() PlacementState

func (*Placement) ProtoMessage 

func (*Placement) ProtoMessage()

func (*Placement) ProtoReflect 

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

func (*Placement) Reset 

func (x *Placement) Reset()

func (*Placement) String 

func (x *Placement) String() string

type PlacementState 

type PlacementState int32

This is only for debugging purposes, for now. Keep synced with ranje.PlacementState (in pkg/ranje/placement_state.go) 

const (
	PlacementState_PS_UNKNOWN  PlacementState = 0
	PlacementState_PS_PENDING  PlacementState = 1
	PlacementState_PS_INACTIVE PlacementState = 2
	PlacementState_PS_ACTIVE   PlacementState = 3
	PlacementState_PS_MISSING  PlacementState = 5
	PlacementState_PS_DROPPED  PlacementState = 6
)

func (PlacementState) Descriptor 

func (PlacementState) Descriptor() protoreflect.EnumDescriptor

func (PlacementState) Enum 

func (x PlacementState) Enum() *PlacementState

func (PlacementState) EnumDescriptor deprecated 

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

Deprecated: Use PlacementState.Descriptor instead.

func (PlacementState) Number 

func (x PlacementState) Number() protoreflect.EnumNumber

func (PlacementState) String 

func (x PlacementState) String() string

func (PlacementState) Type 

func (PlacementState) Type() protoreflect.EnumType

type PlacementWithRangeInfo 

type PlacementWithRangeInfo struct {
	Placement *Placement `protobuf:"bytes,1,opt,name=placement,proto3" json:"placement,omitempty"`
	RangeInfo *RangeInfo `protobuf:"bytes,2,opt,name=range_info,json=rangeInfo,proto3" json:"range_info,omitempty"`
	// contains filtered or unexported fields
}

Similar to Placement (from ranje.proto), but includes extra junk for debug views. The other one is used on the control plane, so should be minimal.

func (*PlacementWithRangeInfo) Descriptor deprecated 

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

Deprecated: Use PlacementWithRangeInfo.ProtoReflect.Descriptor instead.

func (*PlacementWithRangeInfo) GetPlacement 

func (x *PlacementWithRangeInfo) GetPlacement() *Placement

func (*PlacementWithRangeInfo) GetRangeInfo 

func (x *PlacementWithRangeInfo) GetRangeInfo() *RangeInfo

func (*PlacementWithRangeInfo) ProtoMessage 

func (*PlacementWithRangeInfo) ProtoMessage()

func (*PlacementWithRangeInfo) ProtoReflect 

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

func (*PlacementWithRangeInfo) Reset 

func (x *PlacementWithRangeInfo) Reset()

func (*PlacementWithRangeInfo) String 

func (x *PlacementWithRangeInfo) String() string

type PrepareRequest 

type PrepareRequest struct {
	Range *RangeMeta `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	// The range(s) which this range was created from, and the nodes where they
	// can currently be found. This is empty is the range is brand new. Nodes may
	// use this info to restore the current state of the range when accepting it.
	// TODO: Need nested parents here?
	Parents []*Parent `protobuf:"bytes,3,rep,name=parents,proto3" json:"parents,omitempty"`
	// contains filtered or unexported fields
}

func (*PrepareRequest) Descriptor deprecated 

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

Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.

func (*PrepareRequest) GetParents 

func (x *PrepareRequest) GetParents() []*Parent

func (*PrepareRequest) GetRange 

func (x *PrepareRequest) GetRange() *RangeMeta

func (*PrepareRequest) ProtoMessage 

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) ProtoReflect 

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

func (*PrepareRequest) Reset 

func (x *PrepareRequest) Reset()

func (*PrepareRequest) String 

func (x *PrepareRequest) String() string

type PrepareResponse 

type PrepareResponse struct {

	// TODO: Return just the state instead, like ServeResponse.
	RangeInfo *RangeInfo `protobuf:"bytes,1,opt,name=range_info,json=rangeInfo,proto3" json:"range_info,omitempty"`
	// contains filtered or unexported fields
}

func (*PrepareResponse) Descriptor deprecated 

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

Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.

func (*PrepareResponse) GetRangeInfo 

func (x *PrepareResponse) GetRangeInfo() *RangeInfo

func (*PrepareResponse) ProtoMessage 

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) ProtoReflect 

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

func (*PrepareResponse) Reset 

func (x *PrepareResponse) Reset()

func (*PrepareResponse) String 

func (x *PrepareResponse) String() string

type RangeInfo 

type RangeInfo struct {

	// TODO: Do we need the whole meta here? Maybe ID is enough? Nice to confirm
	// range boundaries I guess.
	Meta *RangeMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// The state which the range is currently in, according to the node.
	State RangeNodeState `protobuf:"varint,2,opt,name=state,proto3,enum=ranger.RangeNodeState" json:"state,omitempty"`
	// LoadInfo informs the controller how much load this range is applying to the
	// node, relative to the other ranges on that node. The controller will use
	// this info to rebalance ranges.
	Info *LoadInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

TODO: Rename to RemoteRangeInfo, since this is the view from the remote.

func (*RangeInfo) Descriptor deprecated 

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

Deprecated: Use RangeInfo.ProtoReflect.Descriptor instead.

func (*RangeInfo) GetInfo 

func (x *RangeInfo) GetInfo() *LoadInfo

func (*RangeInfo) GetMeta 

func (x *RangeInfo) GetMeta() *RangeMeta

func (*RangeInfo) GetState 

func (x *RangeInfo) GetState() RangeNodeState

func (*RangeInfo) ProtoMessage 

func (*RangeInfo) ProtoMessage()

func (*RangeInfo) ProtoReflect 

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

func (*RangeInfo) Reset 

func (x *RangeInfo) Reset()

func (*RangeInfo) String 

func (x *RangeInfo) String() string

type RangeMeta 

type RangeMeta struct {

	// Unique for every range.
	Ident uint64 `protobuf:"varint,1,opt,name=ident,proto3" json:"ident,omitempty"`
	// Range of the keys in this range.
	Start []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` // inclusive
	End   []byte `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"`     // exclusive
	// contains filtered or unexported fields
}

func (*RangeMeta) Descriptor deprecated 

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

Deprecated: Use RangeMeta.ProtoReflect.Descriptor instead.

func (*RangeMeta) GetEnd 

func (x *RangeMeta) GetEnd() []byte

func (*RangeMeta) GetIdent 

func (x *RangeMeta) GetIdent() uint64

func (*RangeMeta) GetStart 

func (x *RangeMeta) GetStart() []byte

func (*RangeMeta) ProtoMessage 

func (*RangeMeta) ProtoMessage()

func (*RangeMeta) ProtoReflect 

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

func (*RangeMeta) Reset 

func (x *RangeMeta) Reset()

func (*RangeMeta) String 

func (x *RangeMeta) String() string

type RangeNodeState 

type RangeNodeState int32

TODO: Rename to RemoteState, like the non-proto type. Keep synced with roster/api.RemoteState (in pkg/roster/state/remote_state.go) 

const (
	RangeNodeState_UNKNOWN RangeNodeState = 0
	// Stable states
	RangeNodeState_INACTIVE RangeNodeState = 1
	RangeNodeState_ACTIVE   RangeNodeState = 2
	// During transitions
	RangeNodeState_PREPARING    RangeNodeState = 3 // Pending -> Inactive
	RangeNodeState_ACTIVATING   RangeNodeState = 4 // Inactive -> Active
	RangeNodeState_DEACTIVATING RangeNodeState = 5 // Active -> Inactive
	RangeNodeState_DROPPING     RangeNodeState = 6 // Inactive -> NotFound
	// Special case: See roster.RemoteState
	RangeNodeState_NOT_FOUND RangeNodeState = 7
)

func (RangeNodeState) Descriptor 

func (RangeNodeState) Descriptor() protoreflect.EnumDescriptor

func (RangeNodeState) Enum 

func (x RangeNodeState) Enum() *RangeNodeState

func (RangeNodeState) EnumDescriptor deprecated 

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

Deprecated: Use RangeNodeState.Descriptor instead.

func (RangeNodeState) Number 

func (x RangeNodeState) Number() protoreflect.EnumNumber

func (RangeNodeState) String 

func (x RangeNodeState) String() string

func (RangeNodeState) Type 

func (RangeNodeState) Type() protoreflect.EnumType

type RangeRequest 

type RangeRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeRequest) Descriptor deprecated 

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

Deprecated: Use RangeRequest.ProtoReflect.Descriptor instead.

func (*RangeRequest) GetRange 

func (x *RangeRequest) GetRange() uint64

func (*RangeRequest) ProtoMessage 

func (*RangeRequest) ProtoMessage()

func (*RangeRequest) ProtoReflect 

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

func (*RangeRequest) Reset 

func (x *RangeRequest) Reset()

func (*RangeRequest) String 

func (x *RangeRequest) String() string

type RangeResponse 

type RangeResponse struct {
	Meta  *RangeMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	State RangeState `protobuf:"varint,2,opt,name=state,proto3,enum=ranger.RangeState" json:"state,omitempty"`
	// These two are obviously redundant when all ranges are dumped, but the
	// output is intended to be useful, not correct.
	Parents    []uint64                  `protobuf:"varint,3,rep,packed,name=parents,proto3" json:"parents,omitempty"`
	Children   []uint64                  `protobuf:"varint,4,rep,packed,name=children,proto3" json:"children,omitempty"`
	Placements []*PlacementWithRangeInfo `protobuf:"bytes,5,rep,name=placements,proto3" json:"placements,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeResponse) Descriptor deprecated 

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

Deprecated: Use RangeResponse.ProtoReflect.Descriptor instead.

func (*RangeResponse) GetChildren 

func (x *RangeResponse) GetChildren() []uint64

func (*RangeResponse) GetMeta 

func (x *RangeResponse) GetMeta() *RangeMeta

func (*RangeResponse) GetParents 

func (x *RangeResponse) GetParents() []uint64

func (*RangeResponse) GetPlacements 

func (x *RangeResponse) GetPlacements() []*PlacementWithRangeInfo

func (*RangeResponse) GetState 

func (x *RangeResponse) GetState() RangeState

func (*RangeResponse) ProtoMessage 

func (*RangeResponse) ProtoMessage()

func (*RangeResponse) ProtoReflect 

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

func (*RangeResponse) Reset 

func (x *RangeResponse) Reset()

func (*RangeResponse) String 

func (x *RangeResponse) String() string

type RangeState 

type RangeState int32

This is only for debugging purposes, for now. Keep synced with ranje.RangeState (in pkg/ranje/range_state.go) TODO: Remove the prefix; the const is currently e.g. RangeState_RS_ACTIVE. 

const (
	RangeState_RS_UNKNOWN   RangeState = 0
	RangeState_RS_ACTIVE    RangeState = 1
	RangeState_RS_SUBSUMING RangeState = 2
	RangeState_RS_OBSOLETE  RangeState = 3
)

func (RangeState) Descriptor 

func (RangeState) Descriptor() protoreflect.EnumDescriptor

func (RangeState) Enum 

func (x RangeState) Enum() *RangeState

func (RangeState) EnumDescriptor deprecated 

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

Deprecated: Use RangeState.Descriptor instead.

func (RangeState) Number 

func (x RangeState) Number() protoreflect.EnumNumber

func (RangeState) String 

func (x RangeState) String() string

func (RangeState) Type 

func (RangeState) Type() protoreflect.EnumType

type RangesListRequest 

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

func (*RangesListRequest) Descriptor deprecated 

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

Deprecated: Use RangesListRequest.ProtoReflect.Descriptor instead.

func (*RangesListRequest) ProtoMessage 

func (*RangesListRequest) ProtoMessage()

func (*RangesListRequest) ProtoReflect 

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

func (*RangesListRequest) Reset 

func (x *RangesListRequest) Reset()

func (*RangesListRequest) String 

func (x *RangesListRequest) String() string

type RangesListResponse 

type RangesListResponse struct {
	Ranges []*RangeResponse `protobuf:"bytes,1,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*RangesListResponse) Descriptor deprecated 

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

Deprecated: Use RangesListResponse.ProtoReflect.Descriptor instead.

func (*RangesListResponse) GetRanges 

func (x *RangesListResponse) GetRanges() []*RangeResponse

func (*RangesListResponse) ProtoMessage 

func (*RangesListResponse) ProtoMessage()

func (*RangesListResponse) ProtoReflect 

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

func (*RangesListResponse) Reset 

func (x *RangesListResponse) Reset()

func (*RangesListResponse) String 

func (x *RangesListResponse) String() string

type RangesRequest 

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

func (*RangesRequest) Descriptor deprecated 

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

Deprecated: Use RangesRequest.ProtoReflect.Descriptor instead.

func (*RangesRequest) ProtoMessage 

func (*RangesRequest) ProtoMessage()

func (*RangesRequest) ProtoReflect 

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

func (*RangesRequest) Reset 

func (x *RangesRequest) Reset()

func (*RangesRequest) String 

func (x *RangesRequest) String() string

type RangesResponse 

type RangesResponse struct {
	Meta  *RangeMeta     `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	State RangeNodeState `protobuf:"varint,2,opt,name=state,proto3,enum=ranger.RangeNodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*RangesResponse) Descriptor deprecated 

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

Deprecated: Use RangesResponse.ProtoReflect.Descriptor instead.

func (*RangesResponse) GetMeta 

func (x *RangesResponse) GetMeta() *RangeMeta

func (*RangesResponse) GetState 

func (x *RangesResponse) GetState() RangeNodeState

func (*RangesResponse) ProtoMessage 

func (*RangesResponse) ProtoMessage()

func (*RangesResponse) ProtoReflect 

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

func (*RangesResponse) Reset 

func (x *RangesResponse) Reset()

func (*RangesResponse) String 

func (x *RangesResponse) String() string

type ServeRequest 

type ServeRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*ServeRequest) Descriptor deprecated 

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

Deprecated: Use ServeRequest.ProtoReflect.Descriptor instead.

func (*ServeRequest) GetForce 

func (x *ServeRequest) GetForce() bool

func (*ServeRequest) GetRange 

func (x *ServeRequest) GetRange() uint64

func (*ServeRequest) ProtoMessage 

func (*ServeRequest) ProtoMessage()

func (*ServeRequest) ProtoReflect 

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

func (*ServeRequest) Reset 

func (x *ServeRequest) Reset()

func (*ServeRequest) String 

func (x *ServeRequest) String() string

type ServeResponse 

type ServeResponse struct {
	State RangeNodeState `protobuf:"varint,1,opt,name=state,proto3,enum=ranger.RangeNodeState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ServeResponse) Descriptor deprecated 

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

Deprecated: Use ServeResponse.ProtoReflect.Descriptor instead.

func (*ServeResponse) GetState 

func (x *ServeResponse) GetState() RangeNodeState

func (*ServeResponse) ProtoMessage 

func (*ServeResponse) ProtoMessage()

func (*ServeResponse) ProtoReflect 

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

func (*ServeResponse) Reset 

func (x *ServeResponse) Reset()

func (*ServeResponse) String 

func (x *ServeResponse) String() string

type SplitRequest 

type SplitRequest struct {
	Range uint64 `protobuf:"varint,1,opt,name=range,proto3" json:"range,omitempty"`
	// The point at which to split the two ranges. This becomes the end key of the
	// left range, and the start key of the right range.
	Boundary []byte `protobuf:"bytes,2,opt,name=boundary,proto3" json:"boundary,omitempty"`
	// The ident of the node to assign the two parts to. Can be the same as the
	// node which the range is currently on.
	NodeLeft  string `protobuf:"bytes,3,opt,name=node_left,json=nodeLeft,proto3" json:"node_left,omitempty"`
	NodeRight string `protobuf:"bytes,4,opt,name=node_right,json=nodeRight,proto3" json:"node_right,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitRequest) Descriptor deprecated 

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

Deprecated: Use SplitRequest.ProtoReflect.Descriptor instead.

func (*SplitRequest) GetBoundary 

func (x *SplitRequest) GetBoundary() []byte

func (*SplitRequest) GetNodeLeft 

func (x *SplitRequest) GetNodeLeft() string

func (*SplitRequest) GetNodeRight 

func (x *SplitRequest) GetNodeRight() string

func (*SplitRequest) GetRange 

func (x *SplitRequest) GetRange() uint64

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) ProtoReflect 

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

func (*SplitRequest) Reset 

func (x *SplitRequest) Reset()

func (*SplitRequest) String 

func (x *SplitRequest) String() string

type SplitResponse 

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

func (*SplitResponse) Descriptor deprecated 

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

Deprecated: Use SplitResponse.ProtoReflect.Descriptor instead.

func (*SplitResponse) ProtoMessage 

func (*SplitResponse) ProtoMessage()

func (*SplitResponse) ProtoReflect 

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

func (*SplitResponse) Reset 

func (x *SplitResponse) Reset()

func (*SplitResponse) String 

func (x *SplitResponse) String() string

type UnimplementedDebugServer 

type UnimplementedDebugServer struct {
}

UnimplementedDebugServer must be embedded to have forward compatible implementations.

func (UnimplementedDebugServer) Node 

func (UnimplementedDebugServer) Node(context.Context, *NodeRequest) (*NodeResponse, error)

func (UnimplementedDebugServer) NodesList 

func (UnimplementedDebugServer) NodesList(context.Context, *NodesListRequest) (*NodesListResponse, error)

func (UnimplementedDebugServer) Range 

func (UnimplementedDebugServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

func (UnimplementedDebugServer) RangesList 

func (UnimplementedDebugServer) RangesList(context.Context, *RangesListRequest) (*RangesListResponse, error)

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServer) Activate 

func (UnimplementedNodeServer) Activate(context.Context, *ServeRequest) (*ServeResponse, error)

func (UnimplementedNodeServer) Deactivate 

func (UnimplementedNodeServer) Deactivate(context.Context, *DeactivateRequest) (*DeactivateResponse, error)

func (UnimplementedNodeServer) Drop 

func (UnimplementedNodeServer) Drop(context.Context, *DropRequest) (*DropResponse, error)

func (UnimplementedNodeServer) Info 

func (UnimplementedNodeServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (UnimplementedNodeServer) Prepare 

func (UnimplementedNodeServer) Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)

func (UnimplementedNodeServer) Ranges 

func (UnimplementedNodeServer) Ranges(*RangesRequest, Node_RangesServer) error

type UnimplementedOrchestratorServer 

type UnimplementedOrchestratorServer struct {
}

UnimplementedOrchestratorServer must be embedded to have forward compatible implementations.

func (UnimplementedOrchestratorServer) Join 

func (UnimplementedOrchestratorServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)

func (UnimplementedOrchestratorServer) Move 

func (UnimplementedOrchestratorServer) Move(context.Context, *MoveRequest) (*MoveResponse, error)

func (UnimplementedOrchestratorServer) Split 

func (UnimplementedOrchestratorServer) Split(context.Context, *SplitRequest) (*SplitResponse, error)

type UnsafeDebugServer 

type UnsafeDebugServer interface {
	// contains filtered or unexported methods
}

UnsafeDebugServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DebugServer will result in compilation errors.

type UnsafeNodeServer 

type UnsafeNodeServer interface {
	// contains filtered or unexported methods
}

UnsafeNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServer will result in compilation errors.

type UnsafeOrchestratorServer 

type UnsafeOrchestratorServer interface {
	// contains filtered or unexported methods
}

UnsafeOrchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrchestratorServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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