handler

Documentation

Index

• type Handler
  • func GetHandler(session *mgo.Session, vesselClient vesselPb.VesselServiceClient, ...) *Handler
  • func (h *Handler) CreateConsignment(ctx context.Context, req *pb.Consignment, resp *pb.Response) error
  • func (h *Handler) GetConsignments(ctx context.Context, req *pb.GetRequest, resp *pb.Response) error
  • func (h *Handler) GetRepo() model.Repository

Types

type Handler

type Handler struct {
	Broker broker.Broker
	// contains filtered or unexported fields
}

微服务服务端 struct handler 必须实现 protobuf 中定义的 rpc 方法 实现方法的传参等可参考生成的 consignment.pb.go

func GetHandler

func GetHandler(session *mgo.Session, vesselClient vesselPb.VesselServiceClient, userClient userPb.UserServiceClient, bk broker.Broker) *Handler

func (*Handler) CreateConsignment

func (h *Handler) CreateConsignment(ctx context.Context, req *pb.Consignment, resp *pb.Response) error

func (*Handler) GetConsignments

func (h *Handler) GetConsignments(ctx context.Context, req *pb.GetRequest, resp *pb.Response) error

func (*Handler) GetRepo

func (h *Handler) GetRepo() model.Repository

从主会话中 Clone() 出新会话处理查询