grpc

Documentation

Index

• type GRPCHandler
  • func NewGRPCHandler(h handler.Handler) GRPCHandler
  • func (g GRPCHandler) GetShardOwner(ctx context.Context, request *sharddistributorv1.GetShardOwnerRequest) (*sharddistributorv1.GetShardOwnerResponse, error)
  • func (g GRPCHandler) Health(ctx context.Context, _ *apiv1.HealthRequest) (*apiv1.HealthResponse, error)
  • func (g GRPCHandler) Register(dispatcher *yarpc.Dispatcher)

Types

type GRPCHandler

type GRPCHandler struct {
	// contains filtered or unexported fields
}

func NewGRPCHandler

func NewGRPCHandler(h handler.Handler) GRPCHandler

func (GRPCHandler) GetShardOwner

func (g GRPCHandler) GetShardOwner(ctx context.Context, request *sharddistributorv1.GetShardOwnerRequest) (*sharddistributorv1.GetShardOwnerResponse, error)

func (GRPCHandler) Health

func (g GRPCHandler) Health(ctx context.Context, _ *apiv1.HealthRequest) (*apiv1.HealthResponse, error)

func (GRPCHandler) Register

func (g GRPCHandler) Register(dispatcher *yarpc.Dispatcher)