handler

Documentation

Index

• type Discovery
  • func (m *Discovery) Endpoints(ctx context.Context, req *proto.EndpointsRequest, rsp *proto.EndpointsResponse) error
  • func (m *Discovery) Heartbeats(ctx context.Context, req *proto.HeartbeatsRequest, ...) error
  • func (m *Discovery) WatchResults(ctx context.Context, req *proto.WatchResultsRequest, ...) error
• type Registry
  • func (r *Registry) Deregister(ctx context.Context, req *proto.DeregisterRequest, ...) error
  • func (r *Registry) GetService(ctx context.Context, req *proto.GetServiceRequest, ...) error
  • func (r *Registry) ListServices(ctx context.Context, req *proto.ListServicesRequest, ...) error
  • func (r *Registry) Register(ctx context.Context, req *proto.RegisterRequest, rsp *proto.RegisterResponse) error
  • func (r *Registry) Watch(ctx context.Context, req *proto.WatchRequest, ...) error

Types

type Discovery

type Discovery struct{}

func (*Discovery) Endpoints

func (m *Discovery) Endpoints(ctx context.Context, req *proto.EndpointsRequest, rsp *proto.EndpointsResponse) error

func (*Discovery) Heartbeats

func (m *Discovery) Heartbeats(ctx context.Context, req *proto.HeartbeatsRequest, rsp *proto.HeartbeatsResponse) error

func (*Discovery) WatchResults

func (m *Discovery) WatchResults(ctx context.Context, req *proto.WatchResultsRequest, rsp *proto.WatchResultsResponse) error

type Registry

type Registry struct{}

func (*Registry) Deregister

func (r *Registry) Deregister(ctx context.Context, req *proto.DeregisterRequest, rsp *proto.DeregisterResponse) error

func (*Registry) GetService

func (r *Registry) GetService(ctx context.Context, req *proto.GetServiceRequest, rsp *proto.GetServiceResponse) error

func (*Registry) ListServices

func (r *Registry) ListServices(ctx context.Context, req *proto.ListServicesRequest, rsp *proto.ListServicesResponse) error

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, req *proto.RegisterRequest, rsp *proto.RegisterResponse) error

func (*Registry) Watch

func (r *Registry) Watch(ctx context.Context, req *proto.WatchRequest, stream proto.Registry_WatchStream) error