Documentation ¶
Index ¶
- Variables
- func RegisterRavelClusterAdminServer(s grpc.ServiceRegistrar, srv RavelClusterAdminServer)
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetClusterId() string
- func (x *Cluster) GetLeaderGrpcAddress() string
- func (x *Cluster) GetLeaderRaftAddress() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetClusterId() string
- func (x *Node) GetGrpcAddress() string
- func (x *Node) GetNodeId() string
- func (x *Node) GetRaftAddress() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type RavelClusterAdminClient
- type RavelClusterAdminServer
- type Response
- type UnimplementedRavelClusterAdminServer
- func (UnimplementedRavelClusterAdminServer) GetClusterLeader(context.Context, *Cluster) (*Node, error)
- func (UnimplementedRavelClusterAdminServer) InitiateDataRelocation(context.Context, *Cluster) (*Response, error)
- func (UnimplementedRavelClusterAdminServer) JoinAsClusterLeader(context.Context, *Node) (*Cluster, error)
- func (UnimplementedRavelClusterAdminServer) JoinExistingCluster(context.Context, *Node) (*Cluster, error)
- func (UnimplementedRavelClusterAdminServer) LeaveCluster(context.Context, *Node) (*Response, error)
- func (UnimplementedRavelClusterAdminServer) UpdateClusterLeader(context.Context, *Node) (*Response, error)
- type UnsafeRavelClusterAdminServer
Constants ¶
This section is empty.
Variables ¶
var File_cmd_ravel_cluster_admin_cluster_admin_proto protoreflect.FileDescriptor
var RavelClusterAdmin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "RavelClusterAdminPB.RavelClusterAdmin", HandlerType: (*RavelClusterAdminServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "JoinExistingCluster", Handler: _RavelClusterAdmin_JoinExistingCluster_Handler, }, { MethodName: "JoinAsClusterLeader", Handler: _RavelClusterAdmin_JoinAsClusterLeader_Handler, }, { MethodName: "UpdateClusterLeader", Handler: _RavelClusterAdmin_UpdateClusterLeader_Handler, }, { MethodName: "LeaveCluster", Handler: _RavelClusterAdmin_LeaveCluster_Handler, }, { MethodName: "GetClusterLeader", Handler: _RavelClusterAdmin_GetClusterLeader_Handler, }, { MethodName: "InitiateDataRelocation", Handler: _RavelClusterAdmin_InitiateDataRelocation_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cmd/ravel_cluster_admin/cluster_admin.proto", }
RavelClusterAdmin_ServiceDesc is the grpc.ServiceDesc for RavelClusterAdmin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRavelClusterAdminServer ¶
func RegisterRavelClusterAdminServer(s grpc.ServiceRegistrar, srv RavelClusterAdminServer)
Types ¶
type Cluster ¶
type Cluster struct { ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` LeaderGrpcAddress string `protobuf:"bytes,2,opt,name=leader_grpc_address,json=leaderGrpcAddress,proto3" json:"leader_grpc_address,omitempty"` LeaderRaftAddress string `protobuf:"bytes,3,opt,name=leader_raft_address,json=leaderRaftAddress,proto3" json:"leader_raft_address,omitempty"` // contains filtered or unexported fields }
Cluster represents the information to represent a cluster leader in Ravel
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetClusterId ¶
func (*Cluster) GetLeaderGrpcAddress ¶
func (*Cluster) GetLeaderRaftAddress ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type Node ¶
type Node struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` GrpcAddress string `protobuf:"bytes,2,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"` RaftAddress string `protobuf:"bytes,3,opt,name=raft_address,json=raftAddress,proto3" json:"raft_address,omitempty"` ClusterId string `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
Node represents the information to represent a node in Ravel
func (*Node) Descriptor
deprecated
func (*Node) GetClusterId ¶
func (*Node) GetGrpcAddress ¶
func (*Node) GetRaftAddress ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type RavelClusterAdminClient ¶
type RavelClusterAdminClient interface { JoinExistingCluster(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Cluster, error) JoinAsClusterLeader(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Cluster, error) UpdateClusterLeader(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Response, error) LeaveCluster(ctx context.Context, in *Node, opts ...grpc.CallOption) (*Response, error) GetClusterLeader(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*Node, error) InitiateDataRelocation(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*Response, error) }
RavelClusterAdminClient is the client API for RavelClusterAdmin 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 NewRavelClusterAdminClient ¶
func NewRavelClusterAdminClient(cc grpc.ClientConnInterface) RavelClusterAdminClient
type RavelClusterAdminServer ¶
type RavelClusterAdminServer interface { JoinExistingCluster(context.Context, *Node) (*Cluster, error) JoinAsClusterLeader(context.Context, *Node) (*Cluster, error) UpdateClusterLeader(context.Context, *Node) (*Response, error) LeaveCluster(context.Context, *Node) (*Response, error) GetClusterLeader(context.Context, *Cluster) (*Node, error) InitiateDataRelocation(context.Context, *Cluster) (*Response, error) }
RavelClusterAdminServer is the server API for RavelClusterAdmin service. All implementations should embed UnimplementedRavelClusterAdminServer for forward compatibility
type Response ¶
type Response struct { Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type UnimplementedRavelClusterAdminServer ¶
type UnimplementedRavelClusterAdminServer struct { }
UnimplementedRavelClusterAdminServer should be embedded to have forward compatible implementations.
func (UnimplementedRavelClusterAdminServer) GetClusterLeader ¶
func (UnimplementedRavelClusterAdminServer) InitiateDataRelocation ¶
func (UnimplementedRavelClusterAdminServer) JoinAsClusterLeader ¶
func (UnimplementedRavelClusterAdminServer) JoinExistingCluster ¶
func (UnimplementedRavelClusterAdminServer) LeaveCluster ¶
func (UnimplementedRavelClusterAdminServer) UpdateClusterLeader ¶
type UnsafeRavelClusterAdminServer ¶
type UnsafeRavelClusterAdminServer interface {
// contains filtered or unexported methods
}
UnsafeRavelClusterAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RavelClusterAdminServer will result in compilation errors.