intstore
package v0.123.0
Go to latest Published: Sep 22, 2025 License:Apache-2.0
Opens a new window with list of versions in this module.
Latest Latest
This package is not in the latest version of its module.
Opens a new window with license information.
Imports:8 Opens a new window with list of imports.
Imported by:0 Opens a new window with list of known importers.
Details
Validgo.mod file
The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
- Redistributable license
Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
- Tagged version
Modules with tagged versions give importers more predictable builds.
Stable versionWhen a project reaches major version v1 it is considered stable.
- Learn more about best practices
Repository
Links
Open Source Insights
Documentation¶
Index¶
- Constants
- Variables
- func RegisterIntStoreServer(s grpc.ServiceRegistrar, srv IntStoreServer)
- type GetRequest
- type IntStoreClient
- type IntStoreServer
- type IntStore_ListItemsClient
- type IntStore_ListItemsServer
- type IntStore_SetStreamClient
- type IntStore_SetStreamServer
- type IntStore_StreamChatClient
- type IntStore_StreamChatServer
- type Item
- type ListItemsRequest
- type SetResponse
- type Summary
- type UnimplementedIntStoreServer
- func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item, error)
- func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest, IntStore_ListItemsServer) error
- func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse, error)
- func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer) error
- func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer) error
- type UnsafeIntStoreServer
Constants¶
View Source
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¶
View Source
var File_intstore_protoprotoreflect.FileDescriptorView 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¶
funcRegisterIntStoreServer¶
func RegisterIntStoreServer(sgrpc.ServiceRegistrar, srvIntStoreServer)
Types¶
typeGetRequest¶
type GetRequest struct {Namestring `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`// contains filtered or unexported fields} func (*GetRequest)Descriptordeprecated
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¶added inv0.83.0
func (x *GetRequest) ProtoReflect()protoreflect.Message
func (*GetRequest)Reset¶
func (x *GetRequest) Reset()
func (*GetRequest)String¶
func (x *GetRequest) String()string
typeIntStoreClient¶
type IntStoreClient interface {Set(ctxcontext.Context, in *Item, opts ...grpc.CallOption) (*SetResponse,error)Get(ctxcontext.Context, in *GetRequest, opts ...grpc.CallOption) (*Item,error)// A server-to-client streaming RPC.ListItems(ctxcontext.Context, in *ListItemsRequest, opts ...grpc.CallOption) (IntStore_ListItemsClient,error)// A client-to-server streaming RPC.SetStream(ctxcontext.Context, opts ...grpc.CallOption) (IntStore_SetStreamClient,error)// A Bidirectional streaming RPC.StreamChat(ctxcontext.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 tohttps://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
funcNewIntStoreClient¶
func NewIntStoreClient(ccgrpc.ClientConnInterface)IntStoreClient
typeIntStoreServer¶
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 UnimplementedIntStoreServerfor forward compatibility
typeIntStore_ListItemsClient¶
type IntStore_ListItemsClient interface {Recv() (*Item,error)grpc.ClientStream}typeIntStore_ListItemsServer¶
type IntStore_ListItemsServer interface {Send(*Item)errorgrpc.ServerStream}typeItem¶
type Item struct {Namestring `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`Valueint32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`// contains filtered or unexported fields} func (*Item)Descriptordeprecated
func (*Item)ProtoMessage¶
func (*Item) ProtoMessage()
func (*Item)ProtoReflect¶added inv0.83.0
func (x *Item) ProtoReflect()protoreflect.Message
typeListItemsRequest¶
type ListItemsRequest struct {// Only list items whose value is greater than this.GreaterThanint32 `protobuf:"varint,1,opt,name=greaterThan,proto3" json:"greaterThan,omitempty"`// contains filtered or unexported fields} func (*ListItemsRequest)Descriptordeprecated
func (*ListItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListItemsRequest.ProtoReflect.Descriptor instead.
func (*ListItemsRequest)GetGreaterThan¶added inv0.39.0
func (x *ListItemsRequest) GetGreaterThan()int32
func (*ListItemsRequest)ProtoMessage¶
func (*ListItemsRequest) ProtoMessage()
func (*ListItemsRequest)ProtoReflect¶added inv0.83.0
func (x *ListItemsRequest) ProtoReflect()protoreflect.Message
func (*ListItemsRequest)Reset¶
func (x *ListItemsRequest) Reset()
func (*ListItemsRequest)String¶
func (x *ListItemsRequest) String()string
typeSetResponse¶
type SetResponse struct {PrevValueint32 `protobuf:"varint,1,opt,name=prev_value,json=prevValue,proto3" json:"prev_value,omitempty"`// contains filtered or unexported fields} func (*SetResponse)Descriptordeprecated
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¶added inv0.83.0
func (x *SetResponse) ProtoReflect()protoreflect.Message
func (*SetResponse)Reset¶
func (x *SetResponse) Reset()
func (*SetResponse)String¶
func (x *SetResponse) String()string
typeSummary¶
type Summary struct {Countint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`// contains filtered or unexported fields} func (*Summary)Descriptordeprecated
func (*Summary)ProtoMessage¶
func (*Summary) ProtoMessage()
func (*Summary)ProtoReflect¶added inv0.83.0
func (x *Summary) ProtoReflect()protoreflect.Message
typeUnimplementedIntStoreServer¶added inv0.83.0
type UnimplementedIntStoreServer struct {}UnimplementedIntStoreServer must be embedded to have forward compatible implementations.
func (UnimplementedIntStoreServer)Get¶added inv0.83.0
func (UnimplementedIntStoreServer) Get(context.Context, *GetRequest) (*Item,error)
func (UnimplementedIntStoreServer)ListItems¶added inv0.83.0
func (UnimplementedIntStoreServer) ListItems(*ListItemsRequest,IntStore_ListItemsServer)error
func (UnimplementedIntStoreServer)Set¶added inv0.83.0
func (UnimplementedIntStoreServer) Set(context.Context, *Item) (*SetResponse,error)
func (UnimplementedIntStoreServer)SetStream¶added inv0.83.0
func (UnimplementedIntStoreServer) SetStream(IntStore_SetStreamServer)error
func (UnimplementedIntStoreServer)StreamChat¶added inv0.83.0
func (UnimplementedIntStoreServer) StreamChat(IntStore_StreamChatServer)error
typeUnsafeIntStoreServer¶added inv0.113.0
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 willresult in compilation errors.
Source Files Click to show internal directories.
Click to hide internal directories.