Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterOrderManagementServer(s grpc.ServiceRegistrar, srv OrderManagementServer)
- type CombinedShipment
- func (*CombinedShipment) Descriptor() ([]byte, []int)deprecated
- func (x *CombinedShipment) GetId() string
- func (x *CombinedShipment) GetOrderList() []*Order
- func (x *CombinedShipment) GetStatus() string
- func (*CombinedShipment) ProtoMessage()
- func (x *CombinedShipment) ProtoReflect() protoreflect.Message
- func (x *CombinedShipment) Reset()
- func (x *CombinedShipment) String() string
- type Order
- func (*Order) Descriptor() ([]byte, []int)deprecated
- func (x *Order) GetDescription() string
- func (x *Order) GetDestination() string
- func (x *Order) GetId() string
- func (x *Order) GetItems() []string
- func (x *Order) GetPrice() float32
- func (*Order) ProtoMessage()
- func (x *Order) ProtoReflect() protoreflect.Message
- func (x *Order) Reset()
- func (x *Order) String() string
- 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) GetOrder(context.Context, *wrapperspb.StringValue) (*Order, error)
- func (UnimplementedOrderManagementServer) ProcessOrders(OrderManagement_ProcessOrdersServer) error
- func (UnimplementedOrderManagementServer) SearchOrders(*wrapperspb.StringValue, OrderManagement_SearchOrdersServer) error
- func (UnimplementedOrderManagementServer) UpdateOrders(OrderManagement_UpdateOrdersServer) error
- type UnsafeOrderManagementServer
Constants ¶
const ( OrderManagement_GetOrder_FullMethodName = "/ecommerce.OrderManagement/getOrder" OrderManagement_SearchOrders_FullMethodName = "/ecommerce.OrderManagement/searchOrders" OrderManagement_UpdateOrders_FullMethodName = "/ecommerce.OrderManagement/updateOrders" OrderManagement_ProcessOrders_FullMethodName = "/ecommerce.OrderManagement/processOrders" )
Variables ¶
var File_product_proto protoreflect.FileDescriptor
var OrderManagement_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ecommerce.OrderManagement", HandlerType: (*OrderManagementServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "getOrder", Handler: _OrderManagement_GetOrder_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "searchOrders", Handler: _OrderManagement_SearchOrders_Handler, ServerStreams: true, }, { StreamName: "updateOrders", Handler: _OrderManagement_UpdateOrders_Handler, ClientStreams: true, }, { StreamName: "processOrders", Handler: _OrderManagement_ProcessOrders_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "product.proto", }
OrderManagement_ServiceDesc is the grpc.ServiceDesc for OrderManagement service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterOrderManagementServer ¶
func RegisterOrderManagementServer(s grpc.ServiceRegistrar, 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"` OrderList []*Order `protobuf:"bytes,3,rep,name=orderList,proto3" json:"orderList,omitempty"` // contains filtered or unexported fields }
func (*CombinedShipment) Descriptor
deprecated
func (*CombinedShipment) Descriptor() ([]byte, []int)
Deprecated: Use CombinedShipment.ProtoReflect.Descriptor instead.
func (*CombinedShipment) GetId ¶
func (x *CombinedShipment) GetId() string
func (*CombinedShipment) GetOrderList ¶
func (x *CombinedShipment) GetOrderList() []*Order
func (*CombinedShipment) GetStatus ¶
func (x *CombinedShipment) GetStatus() string
func (*CombinedShipment) ProtoMessage ¶
func (*CombinedShipment) ProtoMessage()
func (*CombinedShipment) ProtoReflect ¶
func (x *CombinedShipment) ProtoReflect() protoreflect.Message
func (*CombinedShipment) Reset ¶
func (x *CombinedShipment) Reset()
func (*CombinedShipment) String ¶
func (x *CombinedShipment) String() string
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"` // contains filtered or unexported fields }
func (*Order) Descriptor
deprecated
func (*Order) GetDescription ¶
func (*Order) GetDestination ¶
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) ProtoReflect ¶
func (x *Order) ProtoReflect() protoreflect.Message
type OrderManagementClient ¶
type OrderManagementClient interface { GetOrder(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*Order, error) SearchOrders(ctx context.Context, in *wrapperspb.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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewOrderManagementClient ¶
func NewOrderManagementClient(cc grpc.ClientConnInterface) OrderManagementClient
type OrderManagementServer ¶
type OrderManagementServer interface { GetOrder(context.Context, *wrapperspb.StringValue) (*Order, error) SearchOrders(*wrapperspb.StringValue, OrderManagement_SearchOrdersServer) error UpdateOrders(OrderManagement_UpdateOrdersServer) error ProcessOrders(OrderManagement_ProcessOrdersServer) error // contains filtered or unexported methods }
OrderManagementServer is the server API for OrderManagement service. All implementations must embed UnimplementedOrderManagementServer for forward compatibility
type OrderManagement_ProcessOrdersClient ¶
type OrderManagement_ProcessOrdersClient interface { Send(*wrapperspb.StringValue) error Recv() (*CombinedShipment, error) grpc.ClientStream }
type OrderManagement_ProcessOrdersServer ¶
type OrderManagement_ProcessOrdersServer interface { Send(*CombinedShipment) error Recv() (*wrapperspb.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() (*wrapperspb.StringValue, error) grpc.ClientStream }
type OrderManagement_UpdateOrdersServer ¶
type OrderManagement_UpdateOrdersServer interface { SendAndClose(*wrapperspb.StringValue) error Recv() (*Order, error) grpc.ServerStream }
type UnimplementedOrderManagementServer ¶
type UnimplementedOrderManagementServer struct { }
UnimplementedOrderManagementServer must be embedded to have forward compatible implementations.
func (UnimplementedOrderManagementServer) GetOrder ¶
func (UnimplementedOrderManagementServer) GetOrder(context.Context, *wrapperspb.StringValue) (*Order, error)
func (UnimplementedOrderManagementServer) ProcessOrders ¶
func (UnimplementedOrderManagementServer) ProcessOrders(OrderManagement_ProcessOrdersServer) error
func (UnimplementedOrderManagementServer) SearchOrders ¶
func (UnimplementedOrderManagementServer) SearchOrders(*wrapperspb.StringValue, OrderManagement_SearchOrdersServer) error
func (UnimplementedOrderManagementServer) UpdateOrders ¶
func (UnimplementedOrderManagementServer) UpdateOrders(OrderManagement_UpdateOrdersServer) error
type UnsafeOrderManagementServer ¶
type UnsafeOrderManagementServer interface {
// contains filtered or unexported methods
}
UnsafeOrderManagementServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrderManagementServer will result in compilation errors.