package intstore

import "cloud.google.com/go/rpcreplay/proto/intstore"

Index

Constants 

const (
	IntStore_Set_FullMethodName        = "/intstore.IntStore/Set"
	IntStore_Get_FullMethodName        = "/intstore.IntStore/Get"
	IntStore_ListItems_FullMethodName  = "/intstore.IntStore/ListItems"
	IntStore_SetStream_FullMethodName  = "/intstore.IntStore/SetStream"
	IntStore_StreamChat_FullMethodName = "/intstore.IntStore/StreamChat"
)

Variables 

var File_intstore_proto protoreflect.FileDescriptor
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 

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 

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 

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 

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 

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

intstore.pb.go intstore_grpc.pb.go

Version
v0.118.3 (latest)
Published
Feb 20, 2025
Platform
linux/amd64
Imports
8 packages
Last checked
4 hours ago –

Tools for package owners.