protobufhandler

Documentation

Index

• func Call[RspT proto.Message, ReqT proto.Message](o *ProtobufHandler, ctx context.Context, req ReqT) (RspT, error)
• type ProtobufHandler
  • func NewProtobufHandler() *ProtobufHandler
  • func (o *ProtobufHandler) Call(ctx context.Context, req proto.Message) (proto.Message, error)
  • func (o *ProtobufHandler) GetHandleFuncInfo(reqPbName string) *delivery.HandleFuncInfo
  • func (o *ProtobufHandler) GetHandlers() map[string]*delivery.HandleFuncInfo
  • func (o *ProtobufHandler) Regist(f interface{}) error
  • func (o *ProtobufHandler) Regists(fs ...interface{}) error

Functions

func Call

func Call[RspT proto.Message, ReqT proto.Message](o *ProtobufHandler, ctx context.Context, req ReqT) (RspT, error)

Types

type ProtobufHandler

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

func NewProtobufHandler

func NewProtobufHandler() *ProtobufHandler

func (*ProtobufHandler) Call

func (o *ProtobufHandler) Call(ctx context.Context, req proto.Message) (proto.Message, error)

func (*ProtobufHandler) GetHandleFuncInfo

func (o *ProtobufHandler) GetHandleFuncInfo(reqPbName string) *delivery.HandleFuncInfo

func (*ProtobufHandler) GetHandlers

func (o *ProtobufHandler) GetHandlers() map[string]*delivery.HandleFuncInfo

func (*ProtobufHandler) Regist

func (o *ProtobufHandler) Regist(f interface{}) error

func (*ProtobufHandler) Regists

func (o *ProtobufHandler) Regists(fs ...interface{}) error