raftnodepbconnect

Documentation

Index

• Constants
• func NewRaftNodeServiceHandler(svc RaftNodeServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• func RegisterRaftNodeServiceHandler(mux *mux.Router, svc RaftNodeServiceHandler, opts ...connect.HandlerOption)
• type RaftNodeServiceClient
  • func NewRaftNodeServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RaftNodeServiceClient
• type RaftNodeServiceHandler
• type UnimplementedRaftNodeServiceHandler
  • func (UnimplementedRaftNodeServiceHandler) AddNode(context.Context, *connect.Request[raftnodepb.AddNodeRequest]) (*connect.Response[raftnodepb.AddNodeResponse], error)
  • func (UnimplementedRaftNodeServiceHandler) DemoteLeader(context.Context, *connect.Request[raftnodepb.DemoteLeaderRequest]) (*connect.Response[raftnodepb.DemoteLeaderResponse], error)
  • func (UnimplementedRaftNodeServiceHandler) NodeInfo(context.Context, *connect.Request[raftnodepb.NodeInfoRequest]) (*connect.Response[raftnodepb.NodeInfoResponse], error)
  • func (UnimplementedRaftNodeServiceHandler) PromoteToLeader(context.Context, *connect.Request[raftnodepb.PromoteToLeaderRequest]) (*connect.Response[raftnodepb.PromoteToLeaderResponse], error)
  • func (UnimplementedRaftNodeServiceHandler) ReadIndex(context.Context, *connect.Request[raftnodepb.ReadIndexRequest]) (*connect.Response[raftnodepb.ReadIndexResponse], error)
  • func (UnimplementedRaftNodeServiceHandler) RemoveNode(context.Context, *connect.Request[raftnodepb.RemoveNodeRequest]) (*connect.Response[raftnodepb.RemoveNodeResponse], error)

Constants

const (
	// RaftNodeServiceReadIndexProcedure is the fully-qualified name of the RaftNodeService's ReadIndex
	// RPC.
	RaftNodeServiceReadIndexProcedure = "/raft_node.RaftNodeService/ReadIndex"
	// RaftNodeServiceNodeInfoProcedure is the fully-qualified name of the RaftNodeService's NodeInfo
	// RPC.
	RaftNodeServiceNodeInfoProcedure = "/raft_node.RaftNodeService/NodeInfo"
	// RaftNodeServiceRemoveNodeProcedure is the fully-qualified name of the RaftNodeService's
	// RemoveNode RPC.
	RaftNodeServiceRemoveNodeProcedure = "/raft_node.RaftNodeService/RemoveNode"
	// RaftNodeServiceAddNodeProcedure is the fully-qualified name of the RaftNodeService's AddNode RPC.
	RaftNodeServiceAddNodeProcedure = "/raft_node.RaftNodeService/AddNode"
	// RaftNodeServiceDemoteLeaderProcedure is the fully-qualified name of the RaftNodeService's
	// DemoteLeader RPC.
	RaftNodeServiceDemoteLeaderProcedure = "/raft_node.RaftNodeService/DemoteLeader"
	// RaftNodeServicePromoteToLeaderProcedure is the fully-qualified name of the RaftNodeService's
	// PromoteToLeader RPC.
	RaftNodeServicePromoteToLeaderProcedure = "/raft_node.RaftNodeService/PromoteToLeader"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// RaftNodeServiceName is the fully-qualified name of the RaftNodeService service.
	RaftNodeServiceName = "raft_node.RaftNodeService"
)

Functions

func NewRaftNodeServiceHandler

func NewRaftNodeServiceHandler(svc RaftNodeServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewRaftNodeServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func RegisterRaftNodeServiceHandler

func RegisterRaftNodeServiceHandler(mux *mux.Router, svc RaftNodeServiceHandler, opts ...connect.HandlerOption)

RegisterRaftNodeServiceHandler register an HTTP handler to a mux.Router from the service implementation.

Types

type RaftNodeServiceClient

type RaftNodeServiceClient interface {
	ReadIndex(context.Context, *connect.Request[raftnodepb.ReadIndexRequest]) (*connect.Response[raftnodepb.ReadIndexResponse], error)
	NodeInfo(context.Context, *connect.Request[raftnodepb.NodeInfoRequest]) (*connect.Response[raftnodepb.NodeInfoResponse], error)
	RemoveNode(context.Context, *connect.Request[raftnodepb.RemoveNodeRequest]) (*connect.Response[raftnodepb.RemoveNodeResponse], error)
	AddNode(context.Context, *connect.Request[raftnodepb.AddNodeRequest]) (*connect.Response[raftnodepb.AddNodeResponse], error)
	DemoteLeader(context.Context, *connect.Request[raftnodepb.DemoteLeaderRequest]) (*connect.Response[raftnodepb.DemoteLeaderResponse], error)
	PromoteToLeader(context.Context, *connect.Request[raftnodepb.PromoteToLeaderRequest]) (*connect.Response[raftnodepb.PromoteToLeaderResponse], error)
}

RaftNodeServiceClient is a client for the raft_node.RaftNodeService service.

func NewRaftNodeServiceClient

func NewRaftNodeServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) RaftNodeServiceClient

NewRaftNodeServiceClient constructs a client for the raft_node.RaftNodeService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type RaftNodeServiceHandler

type RaftNodeServiceHandler interface {
	ReadIndex(context.Context, *connect.Request[raftnodepb.ReadIndexRequest]) (*connect.Response[raftnodepb.ReadIndexResponse], error)
	NodeInfo(context.Context, *connect.Request[raftnodepb.NodeInfoRequest]) (*connect.Response[raftnodepb.NodeInfoResponse], error)
	RemoveNode(context.Context, *connect.Request[raftnodepb.RemoveNodeRequest]) (*connect.Response[raftnodepb.RemoveNodeResponse], error)
	AddNode(context.Context, *connect.Request[raftnodepb.AddNodeRequest]) (*connect.Response[raftnodepb.AddNodeResponse], error)
	DemoteLeader(context.Context, *connect.Request[raftnodepb.DemoteLeaderRequest]) (*connect.Response[raftnodepb.DemoteLeaderResponse], error)
	PromoteToLeader(context.Context, *connect.Request[raftnodepb.PromoteToLeaderRequest]) (*connect.Response[raftnodepb.PromoteToLeaderResponse], error)
}

RaftNodeServiceHandler is an implementation of the raft_node.RaftNodeService service.

type UnimplementedRaftNodeServiceHandler

type UnimplementedRaftNodeServiceHandler struct{}

UnimplementedRaftNodeServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedRaftNodeServiceHandler) AddNode

func (UnimplementedRaftNodeServiceHandler) AddNode(context.Context, *connect.Request[raftnodepb.AddNodeRequest]) (*connect.Response[raftnodepb.AddNodeResponse], error)

func (UnimplementedRaftNodeServiceHandler) DemoteLeader

func (UnimplementedRaftNodeServiceHandler) DemoteLeader(context.Context, *connect.Request[raftnodepb.DemoteLeaderRequest]) (*connect.Response[raftnodepb.DemoteLeaderResponse], error)

func (UnimplementedRaftNodeServiceHandler) NodeInfo

func (UnimplementedRaftNodeServiceHandler) NodeInfo(context.Context, *connect.Request[raftnodepb.NodeInfoRequest]) (*connect.Response[raftnodepb.NodeInfoResponse], error)

func (UnimplementedRaftNodeServiceHandler) PromoteToLeader

func (UnimplementedRaftNodeServiceHandler) PromoteToLeader(context.Context, *connect.Request[raftnodepb.PromoteToLeaderRequest]) (*connect.Response[raftnodepb.PromoteToLeaderResponse], error)

func (UnimplementedRaftNodeServiceHandler) ReadIndex

func (UnimplementedRaftNodeServiceHandler) ReadIndex(context.Context, *connect.Request[raftnodepb.ReadIndexRequest]) (*connect.Response[raftnodepb.ReadIndexResponse], error)

func (UnimplementedRaftNodeServiceHandler) RemoveNode

func (UnimplementedRaftNodeServiceHandler) RemoveNode(context.Context, *connect.Request[raftnodepb.RemoveNodeRequest]) (*connect.Response[raftnodepb.RemoveNodeResponse], error)