registrarserver

Documentation

Index

• Variables
• type EtcdRegistrarServer
  • func NewEtcdRegistrarServer(addr string) *EtcdRegistrarServer
  • func (s *EtcdRegistrarServer) Discover(ctx context.Context, req *pb.DiscoverRequest) (*pb.DiscoverResponse, error)
  • func (s *EtcdRegistrarServer) HeartbeatActive(ctx context.Context, svc *pb.Service) (*pb.Reply, error)
  • func (s *EtcdRegistrarServer) Logout(ctx context.Context, svc *pb.Service) (*pb.Reply, error)
  • func (s *EtcdRegistrarServer) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)
  • func (s *EtcdRegistrarServer) Subscribe(req *pb.SubscribeRequest, stream pb.EtcdRegistrar_SubscribeServer) error

Variables

var (
	ErrKeyNoExist   = errors.New("key don't exist")
	ErrValueNoExist = errors.New("value don't exist")
)

Types

type EtcdRegistrarServer

type EtcdRegistrarServer struct {
	pb.UnimplementedEtcdRegistrarServer
	Cli        *clientv3.Client
	ServiceNum uint64
	// contains filtered or unexported fields
}

func NewEtcdRegistrarServer

func NewEtcdRegistrarServer(addr string) *EtcdRegistrarServer

func (*EtcdRegistrarServer) Discover

func (s *EtcdRegistrarServer) Discover(ctx context.Context, req *pb.DiscoverRequest) (*pb.DiscoverResponse, error)

func (*EtcdRegistrarServer) HeartbeatActive

func (s *EtcdRegistrarServer) HeartbeatActive(ctx context.Context, svc *pb.Service) (*pb.Reply, error)

func (*EtcdRegistrarServer) Logout

func (s *EtcdRegistrarServer) Logout(ctx context.Context, svc *pb.Service) (*pb.Reply, error)

func (*EtcdRegistrarServer) Register

func (s *EtcdRegistrarServer) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterResponse, error)

func (*EtcdRegistrarServer) Subscribe

func (s *EtcdRegistrarServer) Subscribe(req *pb.SubscribeRequest, stream pb.EtcdRegistrar_SubscribeServer) error