intstore

package
v0.0.0-...-a8b797c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_intstore_proto protoreflect.FileDescriptor
View Source 
var IntStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "intstore.IntStore",
	HandlerType: (*IntStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Set",
			Handler:    _IntStore_Set_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _IntStore_Get_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListItems",
			Handler:       _IntStore_ListItems_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetStream",
			Handler:       _IntStore_SetStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamChat",
			Handler:       _IntStore_StreamChat_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "intstore.proto",
}

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

Functions

func RegisterIntStoreServer 

func RegisterIntStoreServer(s grpc.ServiceRegistrar, srv IntStoreServer)

Types

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetName 

func (x *GetRequest) GetName() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type IntStoreClient 

type IntStoreClient interface {
	Set(ctx context.Context, in *Item, opts ...grpc.CallOption) (*SetResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Item, error)
	// A server-to-client streaming RPC.
	ListItems(ctx context.Context, in *ListItemsRequest, opts ...grpc.CallOption) (IntStore_ListItemsClient, error)
	// A client-to-server streaming RPC.
	SetStream(ctx context.Context, opts ...grpc.CallOption) (IntStore_SetStreamClient, error)
	// A Bidirectional streaming RPC.
	StreamChat(ctx context.Context, opts ...grpc.CallOption) (IntStore_StreamChatClient, error)
}

IntStoreClient is the client API for IntStore 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 NewIntStoreClient 

func NewIntStoreClient(cc grpc.ClientConnInterface) IntStoreClient

type IntStoreServer 

type IntStoreServer interface {
	Set(context.Context, *Item) (*SetResponse, error)
	Get(context.Context, *GetRequest) (*Item, error)
	// A server-to-client streaming RPC.
	ListItems(*ListItemsRequest, IntStore_ListItemsServer) error
	// A client-to-server streaming RPC.
	SetStream(IntStore_SetStreamServer) error
	// A Bidirectional streaming RPC.
	StreamChat(IntStore_StreamChatServer) error
	// contains filtered or unexported methods
}

IntStoreServer is the server API for IntStore service. All implementations must embed UnimplementedIntStoreServer for forward compatibility

type IntStore_ListItemsClient 

type IntStore_ListItemsClient interface {
	Recv() (*Item, error)
	grpc.ClientStream
}

type IntStore_ListItemsServer 

type IntStore_ListItemsServer interface {
	Send(*Item) error
	grpc.ServerStream
}

type IntStore_SetStreamClient 

type IntStore_SetStreamClient interface {
	Send(*Item) error
	CloseAndRecv() (*Summary, error)
	grpc.ClientStream
}

type IntStore_SetStreamServer 

type IntStore_SetStreamServer interface {
	SendAndClose(*Summary) error
	Recv() (*Item, error)
	grpc.ServerStream
}

type IntStore_StreamChatClient 

type IntStore_StreamChatClient interface {
	Send(*Item) error
	Recv() (*Item, error)
	grpc.ClientStream
}

type IntStore_StreamChatServer 

type IntStore_StreamChatServer interface {
	Send(*Item) error
	Recv() (*Item, error)
	grpc.ServerStream
}

type Item 

type Item struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value int32  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Item) Descriptor deprecated 

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

Deprecated: Use Item.ProtoReflect.Descriptor instead.

func (*Item) GetName 

func (x *Item) GetName() string

func (*Item) GetValue 

func (x *Item) GetValue() int32

func (*Item) ProtoMessage 

func (*Item) ProtoMessage()

func (*Item) ProtoReflect 

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

func (*Item) Reset 

func (x *Item) Reset()

func (*Item) String 

func (x *Item) String() string

type ListItemsRequest 

type ListItemsRequest struct {

	// Only list items whose value is greater than this.
	GreaterThan int32 `protobuf:"varint,1,opt,name=greaterThan,proto3" json:"greaterThan,omitempty"`
	// contains filtered or unexported fields
}

func (*ListItemsRequest) Descriptor deprecated 

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

Deprecated: Use ListItemsRequest.ProtoReflect.Descriptor instead.

func (*ListItemsRequest) GetGreaterThan 

func (x *ListItemsRequest) GetGreaterThan() int32

func (*ListItemsRequest) ProtoMessage 

func (*ListItemsRequest) ProtoMessage()

func (*ListItemsRequest) ProtoReflect 

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

func (*ListItemsRequest) Reset 

func (x *ListItemsRequest) Reset()

func (*ListItemsRequest) String 

func (x *ListItemsRequest) String() string

type SetResponse 

type SetResponse struct {
	PrevValue int32 `protobuf:"varint,1,opt,name=prev_value,json=prevValue,proto3" json:"prev_value,omitempty"`
	// contains filtered or unexported fields
}

func (*SetResponse) Descriptor deprecated 

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

Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.

func (*SetResponse) GetPrevValue 

func (x *SetResponse) GetPrevValue() int32

func (*SetResponse) ProtoMessage 

func (*SetResponse) ProtoMessage()

func (*SetResponse) ProtoReflect 

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

func (*SetResponse) Reset 

func (x *SetResponse) Reset()

func (*SetResponse) String 

func (x *SetResponse) String() string

type Summary 

type Summary struct {
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*Summary) Descriptor deprecated 

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

Deprecated: Use Summary.ProtoReflect.Descriptor instead.

func (*Summary) GetCount 

func (x *Summary) GetCount() int32

func (*Summary) ProtoMessage 

func (*Summary) ProtoMessage()

func (*Summary) ProtoReflect 

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

func (*Summary) Reset 

func (x *Summary) Reset()

func (*Summary) String 

func (x *Summary) String() string

type UnimplementedIntStoreServer 

type UnimplementedIntStoreServer struct {
}

UnimplementedIntStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedIntStoreServer) Get 

func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item, error)

func (UnimplementedIntStoreServer) ListItems 

func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest, IntStore_ListItemsServer) error

func (UnimplementedIntStoreServer) Set 

func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse, error)

func (UnimplementedIntStoreServer) SetStream 

func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer) error

func (UnimplementedIntStoreServer) StreamChat 

func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer) error

type UnsafeIntStoreServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.