raftgrpc

README

raftgrpc

Raft GRPC Service Impl

Documentation

Index

• Variables
• func RaftCommand() sprint.Command
• func RaftGrpcServer() raftapi.RaftGrpcServer
• type ContentStreamServer

Variables

var (
	ErrRaftNotInitialized = status.Errorf(codes.Unavailable, "raft not initialized")
	ErrRaftLeaderNotFound = status.Errorf(codes.Unavailable, "raft leader not found")
)

Functions

func RaftCommand

func RaftCommand() sprint.Command

func RaftGrpcServer

func RaftGrpcServer() raftapi.RaftGrpcServer

Types

type ContentStreamServer

type ContentStreamServer interface {
	Send(*raftpb.Content) error
	grpc.ServerStream
}