Documentation ¶
Index ¶
- func RegisterOrderManagementServer(s *grpc.Server, srv OrderManagementServer)
- type CombinedShipment
- func (*CombinedShipment) Descriptor() ([]byte, []int)
- func (m *CombinedShipment) GetId() string
- func (m *CombinedShipment) GetOrdersList() []*Order
- func (m *CombinedShipment) GetStatus() string
- func (*CombinedShipment) ProtoMessage()
- func (m *CombinedShipment) Reset()
- func (m *CombinedShipment) String() string
- func (m *CombinedShipment) XXX_DiscardUnknown()
- func (m *CombinedShipment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CombinedShipment) XXX_Merge(src proto.Message)
- func (m *CombinedShipment) XXX_Size() int
- func (m *CombinedShipment) XXX_Unmarshal(b []byte) error
- type Order
- func (*Order) Descriptor() ([]byte, []int)
- func (m *Order) GetDescription() string
- func (m *Order) GetDestination() string
- func (m *Order) GetId() string
- func (m *Order) GetItems() []string
- func (m *Order) GetPrice() float32
- func (*Order) ProtoMessage()
- func (m *Order) Reset()
- func (m *Order) String() string
- func (m *Order) XXX_DiscardUnknown()
- func (m *Order) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Order) XXX_Merge(src proto.Message)
- func (m *Order) XXX_Size() int
- func (m *Order) XXX_Unmarshal(b []byte) error
- type OrderManagementClient
- type OrderManagementServer
- type OrderManagement_ProcessOrdersClient
- type OrderManagement_ProcessOrdersServer
- type OrderManagement_SearchOrdersClient
- type OrderManagement_SearchOrdersServer
- type OrderManagement_UpdateOrdersClient
- type OrderManagement_UpdateOrdersServer
- type UnimplementedOrderManagementServer
- func (*UnimplementedOrderManagementServer) AddOrder(ctx context.Context, req *Order) (*wrappers.StringValue, error)
- func (*UnimplementedOrderManagementServer) GetOrder(ctx context.Context, req *wrappers.StringValue) (*Order, error)
- func (*UnimplementedOrderManagementServer) ProcessOrders(srv OrderManagement_ProcessOrdersServer) error
- func (*UnimplementedOrderManagementServer) SearchOrders(req *wrappers.StringValue, srv OrderManagement_SearchOrdersServer) error
- func (*UnimplementedOrderManagementServer) UpdateOrders(srv OrderManagement_UpdateOrdersServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterOrderManagementServer ¶
func RegisterOrderManagementServer(s *grpc.Server, srv OrderManagementServer)
Types ¶
type CombinedShipment ¶
type CombinedShipment struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` OrdersList []*Order `protobuf:"bytes,3,rep,name=ordersList,proto3" json:"ordersList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CombinedShipment) Descriptor ¶
func (*CombinedShipment) Descriptor() ([]byte, []int)
func (*CombinedShipment) GetId ¶
func (m *CombinedShipment) GetId() string
func (*CombinedShipment) GetOrdersList ¶
func (m *CombinedShipment) GetOrdersList() []*Order
func (*CombinedShipment) GetStatus ¶
func (m *CombinedShipment) GetStatus() string
func (*CombinedShipment) ProtoMessage ¶
func (*CombinedShipment) ProtoMessage()
func (*CombinedShipment) Reset ¶
func (m *CombinedShipment) Reset()
func (*CombinedShipment) String ¶
func (m *CombinedShipment) String() string
func (*CombinedShipment) XXX_DiscardUnknown ¶
func (m *CombinedShipment) XXX_DiscardUnknown()
func (*CombinedShipment) XXX_Marshal ¶
func (m *CombinedShipment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CombinedShipment) XXX_Merge ¶
func (m *CombinedShipment) XXX_Merge(src proto.Message)
func (*CombinedShipment) XXX_Size ¶
func (m *CombinedShipment) XXX_Size() int
func (*CombinedShipment) XXX_Unmarshal ¶
func (m *CombinedShipment) XXX_Unmarshal(b []byte) error
type Order ¶
type Order struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Items []string `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"` Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` Price float32 `protobuf:"fixed32,4,opt,name=price,proto3" json:"price,omitempty"` Destination string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Order) Descriptor ¶
func (*Order) GetDescription ¶
func (*Order) GetDestination ¶
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) XXX_DiscardUnknown ¶
func (m *Order) XXX_DiscardUnknown()
func (*Order) XXX_Marshal ¶
func (*Order) XXX_Unmarshal ¶
type OrderManagementClient ¶
type OrderManagementClient interface { AddOrder(ctx context.Context, in *Order, opts ...grpc.CallOption) (*wrappers.StringValue, error) GetOrder(ctx context.Context, in *wrappers.StringValue, opts ...grpc.CallOption) (*Order, error) SearchOrders(ctx context.Context, in *wrappers.StringValue, opts ...grpc.CallOption) (OrderManagement_SearchOrdersClient, error) UpdateOrders(ctx context.Context, opts ...grpc.CallOption) (OrderManagement_UpdateOrdersClient, error) ProcessOrders(ctx context.Context, opts ...grpc.CallOption) (OrderManagement_ProcessOrdersClient, error) }
OrderManagementClient is the client API for OrderManagement service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOrderManagementClient ¶
func NewOrderManagementClient(cc *grpc.ClientConn) OrderManagementClient
type OrderManagementServer ¶
type OrderManagementServer interface { AddOrder(context.Context, *Order) (*wrappers.StringValue, error) GetOrder(context.Context, *wrappers.StringValue) (*Order, error) SearchOrders(*wrappers.StringValue, OrderManagement_SearchOrdersServer) error UpdateOrders(OrderManagement_UpdateOrdersServer) error ProcessOrders(OrderManagement_ProcessOrdersServer) error }
OrderManagementServer is the server API for OrderManagement service.
type OrderManagement_ProcessOrdersClient ¶
type OrderManagement_ProcessOrdersClient interface { Send(*wrappers.StringValue) error Recv() (*CombinedShipment, error) grpc.ClientStream }
type OrderManagement_ProcessOrdersServer ¶
type OrderManagement_ProcessOrdersServer interface { Send(*CombinedShipment) error Recv() (*wrappers.StringValue, error) grpc.ServerStream }
type OrderManagement_SearchOrdersClient ¶
type OrderManagement_SearchOrdersClient interface { Recv() (*Order, error) grpc.ClientStream }
type OrderManagement_SearchOrdersServer ¶
type OrderManagement_SearchOrdersServer interface { Send(*Order) error grpc.ServerStream }
type OrderManagement_UpdateOrdersClient ¶
type OrderManagement_UpdateOrdersClient interface { Send(*Order) error CloseAndRecv() (*wrappers.StringValue, error) grpc.ClientStream }
type OrderManagement_UpdateOrdersServer ¶
type OrderManagement_UpdateOrdersServer interface { SendAndClose(*wrappers.StringValue) error Recv() (*Order, error) grpc.ServerStream }
type UnimplementedOrderManagementServer ¶
type UnimplementedOrderManagementServer struct { }
UnimplementedOrderManagementServer can be embedded to have forward compatible implementations.
func (*UnimplementedOrderManagementServer) AddOrder ¶
func (*UnimplementedOrderManagementServer) AddOrder(ctx context.Context, req *Order) (*wrappers.StringValue, error)
func (*UnimplementedOrderManagementServer) GetOrder ¶
func (*UnimplementedOrderManagementServer) GetOrder(ctx context.Context, req *wrappers.StringValue) (*Order, error)
func (*UnimplementedOrderManagementServer) ProcessOrders ¶
func (*UnimplementedOrderManagementServer) ProcessOrders(srv OrderManagement_ProcessOrdersServer) error
func (*UnimplementedOrderManagementServer) SearchOrders ¶
func (*UnimplementedOrderManagementServer) SearchOrders(req *wrappers.StringValue, srv OrderManagement_SearchOrdersServer) error
func (*UnimplementedOrderManagementServer) UpdateOrders ¶
func (*UnimplementedOrderManagementServer) UpdateOrders(srv OrderManagement_UpdateOrdersServer) error
Click to show internal directories.
Click to hide internal directories.