Package cloud.google.com/go/rpcreplay/proto/intstore (v0.85.0)

Note: To get more information about this package, such as access to older versions, viewthis package on pkg.go.dev.

Variables

File_intstore_proto

varFile_intstore_protoprotoreflect.FileDescriptor

Functions

func RegisterIntStoreServer

funcRegisterIntStoreServer(s*grpc.Server,srvIntStoreServer)

GetRequest

typeGetRequeststruct{Namestring`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

IntStoreClient

typeIntStoreClientinterface{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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIntStoreClient

funcNewIntStoreClient(ccgrpc.ClientConnInterface)IntStoreClient

IntStoreServer

typeIntStoreServerinterface{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}

IntStoreServer is the server API for IntStore service.

IntStore_ListItemsClient

typeIntStore_ListItemsClientinterface{Recv()(*Item,error)grpc.ClientStream}

IntStore_ListItemsServer

typeIntStore_ListItemsServerinterface{Send(*Item)errorgrpc.ServerStream}

IntStore_SetStreamClient

typeIntStore_SetStreamClientinterface{Send(*Item)errorCloseAndRecv()(*Summary,error)grpc.ClientStream}

IntStore_SetStreamServer

typeIntStore_SetStreamServerinterface{SendAndClose(*Summary)errorRecv()(*Item,error)grpc.ServerStream}

IntStore_StreamChatClient

typeIntStore_StreamChatClientinterface{Send(*Item)errorRecv()(*Item,error)grpc.ClientStream}

IntStore_StreamChatServer

typeIntStore_StreamChatServerinterface{Send(*Item)errorRecv()(*Item,error)grpc.ServerStream}

Item

typeItemstruct{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) 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

ListItemsRequest

typeListItemsRequeststruct{// 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) 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 (*ListItemsRequest) Reset

func(x*ListItemsRequest)Reset()

func (*ListItemsRequest) String

func(x*ListItemsRequest)String()string

SetResponse

typeSetResponsestruct{PrevValueint32`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

Summary

typeSummarystruct{Countint32`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

UnimplementedIntStoreServer

typeUnimplementedIntStoreServerstruct{}

UnimplementedIntStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedIntStoreServer) Get

func (*UnimplementedIntStoreServer) ListItems

func (*UnimplementedIntStoreServer) Set

func (*UnimplementedIntStoreServer) SetStream

func (*UnimplementedIntStoreServer) StreamChat

Except as otherwise noted, the content of this page is licensed under theCreative Commons Attribution 4.0 License, and code samples are licensed under theApache 2.0 License. For details, see theGoogle Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025-10-30 UTC.