inventoryservice

Documentation

Index

• Constants
• Variables
• func RegisterInventoryManagerServer(s grpc.ServiceRegistrar, srv InventoryManagerServer)
• type InventoryManagerClient
  • func NewInventoryManagerClient(cc grpc.ClientConnInterface) InventoryManagerClient
• type InventoryManagerServer
• type InventoryManager_ServerStreamingInventoryClient
• type InventoryManager_ServerStreamingInventoryServer
• type InventoryRequest
  • func (*InventoryRequest) Descriptor() ([]byte, []int)
  • func (x *InventoryRequest) GetMessage() string
  • func (*InventoryRequest) ProtoMessage()
  • func (x *InventoryRequest) ProtoReflect() protoreflect.Message
  • func (x *InventoryRequest) Reset()
  • func (x *InventoryRequest) String() string
• type InventoryResponse
  • func (*InventoryResponse) Descriptor() ([]byte, []int)
  • func (x *InventoryResponse) GetMessage() string
  • func (*InventoryResponse) ProtoMessage()
  • func (x *InventoryResponse) ProtoReflect() protoreflect.Message
  • func (x *InventoryResponse) Reset()
  • func (x *InventoryResponse) String() string
• type UnimplementedInventoryManagerServer
  • func (UnimplementedInventoryManagerServer) ServerStreamingInventory(*InventoryRequest, grpc.ServerStreamingServer[InventoryResponse]) error
  • func (UnimplementedInventoryManagerServer) UnaryInventoryRequest(context.Context, *InventoryRequest) (*InventoryResponse, error)
• type UnsafeInventoryManagerServer

Constants

const (
	InventoryManager_UnaryInventoryRequest_FullMethodName    = "/inventoryservice.InventoryManager/UnaryInventoryRequest"
	InventoryManager_ServerStreamingInventory_FullMethodName = "/inventoryservice.InventoryManager/ServerStreamingInventory"
)

Variables

var File_inventoryservice_inventoryservice_proto protoreflect.FileDescriptor

var InventoryManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inventoryservice.InventoryManager",
	HandlerType: (*InventoryManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UnaryInventoryRequest",
			Handler:    _InventoryManager_UnaryInventoryRequest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ServerStreamingInventory",
			Handler:       _InventoryManager_ServerStreamingInventory_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "inventoryservice/inventoryservice.proto",
}

InventoryManager_ServiceDesc is the grpc.ServiceDesc for InventoryManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterInventoryManagerServer

func RegisterInventoryManagerServer(s grpc.ServiceRegistrar, srv InventoryManagerServer)

Types

type InventoryManagerClient

type InventoryManagerClient interface {
	// UnaryInventoryRequest is unary request for deployment.
	UnaryInventoryRequest(ctx context.Context, in *InventoryRequest, opts ...grpc.CallOption) (*InventoryResponse, error)
	// ServerStreamingInventory is server side streaming of inventory updates.
	ServerStreamingInventory(ctx context.Context, in *InventoryRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[InventoryResponse], error)
}

InventoryManagerClient is the client API for InventoryManager 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.

InventoryManager is the deployment service.

func NewInventoryManagerClient

func NewInventoryManagerClient(cc grpc.ClientConnInterface) InventoryManagerClient

type InventoryManagerServer

type InventoryManagerServer interface {
	// UnaryInventoryRequest is unary request for deployment.
	UnaryInventoryRequest(context.Context, *InventoryRequest) (*InventoryResponse, error)
	// ServerStreamingInventory is server side streaming of inventory updates.
	ServerStreamingInventory(*InventoryRequest, grpc.ServerStreamingServer[InventoryResponse]) error
	// contains filtered or unexported methods
}

InventoryManagerServer is the server API for InventoryManager service. All implementations must embed UnimplementedInventoryManagerServer for forward compatibility.

InventoryManager is the deployment service.

type InventoryManager_ServerStreamingInventoryClient

type InventoryManager_ServerStreamingInventoryClient = grpc.ServerStreamingClient[InventoryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type InventoryManager_ServerStreamingInventoryServer

type InventoryManager_ServerStreamingInventoryServer = grpc.ServerStreamingServer[InventoryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type InventoryRequest

type InventoryRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

DeploymentRequest is the request for deployment.

func (*InventoryRequest) Descriptor

func (*InventoryRequest) Descriptor() ([]byte, []int)

Deprecated: Use InventoryRequest.ProtoReflect.Descriptor instead.

func (*InventoryRequest) GetMessage

func (x *InventoryRequest) GetMessage() string

func (*InventoryRequest) ProtoMessage

func (*InventoryRequest) ProtoMessage()

func (*InventoryRequest) ProtoReflect

func (x *InventoryRequest) ProtoReflect() protoreflect.Message

func (*InventoryRequest) Reset

func (x *InventoryRequest) Reset()

func (*InventoryRequest) String

func (x *InventoryRequest) String() string

type InventoryResponse

type InventoryResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

DeploymentResponse is the response for deployment.

func (*InventoryResponse) Descriptor

func (*InventoryResponse) Descriptor() ([]byte, []int)

Deprecated: Use InventoryResponse.ProtoReflect.Descriptor instead.

func (*InventoryResponse) GetMessage

func (x *InventoryResponse) GetMessage() string

func (*InventoryResponse) ProtoMessage

func (*InventoryResponse) ProtoMessage()

func (*InventoryResponse) ProtoReflect

func (x *InventoryResponse) ProtoReflect() protoreflect.Message

func (*InventoryResponse) Reset

func (x *InventoryResponse) Reset()

func (*InventoryResponse) String

func (x *InventoryResponse) String() string

type UnimplementedInventoryManagerServer

type UnimplementedInventoryManagerServer struct{}

UnimplementedInventoryManagerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedInventoryManagerServer) ServerStreamingInventory

func (UnimplementedInventoryManagerServer) ServerStreamingInventory(*InventoryRequest, grpc.ServerStreamingServer[InventoryResponse]) error

func (UnimplementedInventoryManagerServer) UnaryInventoryRequest

func (UnimplementedInventoryManagerServer) UnaryInventoryRequest(context.Context, *InventoryRequest) (*InventoryResponse, error)

type UnsafeInventoryManagerServer

type UnsafeInventoryManagerServer interface {
	// contains filtered or unexported methods
}

UnsafeInventoryManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InventoryManagerServer will result in compilation errors.