diff --git a/consignment-service/consignment.pb.micro.go b/consignment-service/consignment.pb.micro.go new file mode 100644 index 0000000..5b7cf4d --- /dev/null +++ b/consignment-service/consignment.pb.micro.go @@ -0,0 +1,104 @@ +// Code generated by protoc-gen-micro. DO NOT EDIT. +// source: consignment.proto + +package consignment_service + +import ( + fmt "fmt" + proto "google.golang.org/protobuf/proto" + math "math" +) + +import ( + context "context" + api "go-micro.dev/v4/api" + client "go-micro.dev/v4/client" + server "go-micro.dev/v4/server" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// Reference imports to suppress errors if they are not otherwise used. +var _ api.Endpoint +var _ context.Context +var _ client.Option +var _ server.Option + +// Api Endpoints for ShippingService service + +func NewShippingServiceEndpoints() []*api.Endpoint { + return []*api.Endpoint{} +} + +// Client API for ShippingService service + +type ShippingService interface { + CreateConsignment(ctx context.Context, in *Consignment, opts ...client.CallOption) (*Response, error) + GetConsignments(ctx context.Context, in *GetRequest, opts ...client.CallOption) (*Response, error) +} + +type shippingService struct { + c client.Client + name string +} + +func NewShippingService(name string, c client.Client) ShippingService { + return &shippingService{ + c: c, + name: name, + } +} + +func (c *shippingService) CreateConsignment(ctx context.Context, in *Consignment, opts ...client.CallOption) (*Response, error) { + req := c.c.NewRequest(c.name, "ShippingService.CreateConsignment", in) + out := new(Response) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *shippingService) GetConsignments(ctx context.Context, in *GetRequest, opts ...client.CallOption) (*Response, error) { + req := c.c.NewRequest(c.name, "ShippingService.GetConsignments", in) + out := new(Response) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// Server API for ShippingService service + +type ShippingServiceHandler interface { + CreateConsignment(context.Context, *Consignment, *Response) error + GetConsignments(context.Context, *GetRequest, *Response) error +} + +func RegisterShippingServiceHandler(s server.Server, hdlr ShippingServiceHandler, opts ...server.HandlerOption) error { + type shippingService interface { + CreateConsignment(ctx context.Context, in *Consignment, out *Response) error + GetConsignments(ctx context.Context, in *GetRequest, out *Response) error + } + type ShippingService struct { + shippingService + } + h := &shippingServiceHandler{hdlr} + return s.Handle(s.NewHandler(&ShippingService{h}, opts...)) +} + +type shippingServiceHandler struct { + ShippingServiceHandler +} + +func (h *shippingServiceHandler) CreateConsignment(ctx context.Context, in *Consignment, out *Response) error { + return h.ShippingServiceHandler.CreateConsignment(ctx, in, out) +} + +func (h *shippingServiceHandler) GetConsignments(ctx context.Context, in *GetRequest, out *Response) error { + return h.ShippingServiceHandler.GetConsignments(ctx, in, out) +} diff --git a/vessel-service/vessel.pb.micro.go b/vessel-service/vessel.pb.micro.go new file mode 100644 index 0000000..11c84be --- /dev/null +++ b/vessel-service/vessel.pb.micro.go @@ -0,0 +1,87 @@ +// Code generated by protoc-gen-micro. DO NOT EDIT. +// source: vessel.proto + +package vessel_service + +import ( + fmt "fmt" + proto "google.golang.org/protobuf/proto" + math "math" +) + +import ( + context "context" + api "go-micro.dev/v4/api" + client "go-micro.dev/v4/client" + server "go-micro.dev/v4/server" +) + +// Reference imports to suppress errors if they are not otherwise used. +var _ = proto.Marshal +var _ = fmt.Errorf +var _ = math.Inf + +// Reference imports to suppress errors if they are not otherwise used. +var _ api.Endpoint +var _ context.Context +var _ client.Option +var _ server.Option + +// Api Endpoints for VesselService service + +func NewVesselServiceEndpoints() []*api.Endpoint { + return []*api.Endpoint{} +} + +// Client API for VesselService service + +type VesselService interface { + FindAvailable(ctx context.Context, in *Specification, opts ...client.CallOption) (*Response, error) +} + +type vesselService struct { + c client.Client + name string +} + +func NewVesselService(name string, c client.Client) VesselService { + return &vesselService{ + c: c, + name: name, + } +} + +func (c *vesselService) FindAvailable(ctx context.Context, in *Specification, opts ...client.CallOption) (*Response, error) { + req := c.c.NewRequest(c.name, "VesselService.FindAvailable", in) + out := new(Response) + err := c.c.Call(ctx, req, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +// Server API for VesselService service + +type VesselServiceHandler interface { + FindAvailable(context.Context, *Specification, *Response) error +} + +func RegisterVesselServiceHandler(s server.Server, hdlr VesselServiceHandler, opts ...server.HandlerOption) error { + type vesselService interface { + FindAvailable(ctx context.Context, in *Specification, out *Response) error + } + type VesselService struct { + vesselService + } + h := &vesselServiceHandler{hdlr} + return s.Handle(s.NewHandler(&VesselService{h}, opts...)) +} + +type vesselServiceHandler struct { + VesselServiceHandler +} + +func (h *vesselServiceHandler) FindAvailable(ctx context.Context, in *Specification, out *Response) error { + return h.VesselServiceHandler.FindAvailable(ctx, in, out) +}