Documentation ¶
Index ¶
- Variables
- type Server
- func (srv *Server) BindHeartbeatStream(_ context.Context, node string, sender grpcservice.HeartbeatStreamSender) error
- func (srv *Server) Close()
- func (srv *Server) GetClusterManager() cluster.Manager
- func (srv *Server) GetLeader(ctx context.Context) (*member.GetLeaderResp, error)
- func (srv *Server) IsClosed() bool
- func (srv *Server) ProcessHeartbeat(ctx context.Context, req *metaservicepb.NodeHeartbeatRequest) error
- func (srv *Server) Run(ctx context.Context) error
- func (srv *Server) UnbindHeartbeatStream(_ context.Context, node string) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrCreateEtcdClient = coderr.NewCodeError(coderr.Internal, "create etcd etcdCli") ErrStartEtcd = coderr.NewCodeError(coderr.Internal, "start embed etcd") ErrStartEtcdTimeout = coderr.NewCodeError(coderr.Internal, "start etcd server timeout") ErrStartServer = coderr.NewCodeError(coderr.Internal, "start server") )
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func CreateServer ¶
CreateServer creates the server instance without starting any services or background jobs.
func (*Server) BindHeartbeatStream ¶
func (srv *Server) BindHeartbeatStream(_ context.Context, node string, sender grpcservice.HeartbeatStreamSender) error
func (*Server) GetClusterManager ¶
func (*Server) ProcessHeartbeat ¶
func (srv *Server) ProcessHeartbeat(ctx context.Context, req *metaservicepb.NodeHeartbeatRequest) error
Click to show internal directories.
Click to hide internal directories.