service

Documentation

Index

• type MembershipServer
  • func NewMembershipService(cluster membership.Cluster) *MembershipServer
  • func (s *MembershipServer) ListNodes(ctx context.Context, req *proto.ListNodesRequest) (*proto.ListNodesResponse, error)
  • func (s *MembershipServer) Ping(ctx context.Context, req *proto.PingRequest) (*proto.PingResponse, error)
  • func (s *MembershipServer) PingIndirect(ctx context.Context, req *proto.PingIndirectRequest) (*proto.PingIndirectResponse, error)
  • func (s *MembershipServer) PullPushState(ctx context.Context, req *proto.PullPushStateRequest) (*proto.PullPushStateResponse, error)

Types

type MembershipServer

type MembershipServer struct {
	proto.UnimplementedMembershipServer
	// contains filtered or unexported fields
}

func NewMembershipService

func NewMembershipService(cluster membership.Cluster) *MembershipServer

func (*MembershipServer) ListNodes

func (s *MembershipServer) ListNodes(ctx context.Context, req *proto.ListNodesRequest) (*proto.ListNodesResponse, error)

func (*MembershipServer) Ping

func (s *MembershipServer) Ping(ctx context.Context, req *proto.PingRequest) (*proto.PingResponse, error)

func (*MembershipServer) PingIndirect

func (s *MembershipServer) PingIndirect(ctx context.Context, req *proto.PingIndirectRequest) (*proto.PingIndirectResponse, error)

func (*MembershipServer) PullPushState

func (s *MembershipServer) PullPushState(ctx context.Context, req *proto.PullPushStateRequest) (*proto.PullPushStateResponse, error)