Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCacheServiceServer(s grpc.ServiceRegistrar, srv CacheServiceServer)
- type CacheServiceClient
- type CacheServiceServer
- type CacheService_EventsClient
- type CacheService_EventsServer
- type Empty
- type Event
- type Event_EventType
- func (Event_EventType) Descriptor() protoreflect.EnumDescriptor
- func (x Event_EventType) Enum() *Event_EventType
- func (Event_EventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Event_EventType) Number() protoreflect.EnumNumber
- func (x Event_EventType) String() string
- func (Event_EventType) Type() protoreflect.EnumType
- type UnimplementedCacheServiceServer
- type UnsafeCacheServiceServer
Constants ¶
const (
CacheService_Events_FullMethodName = "/CacheService/Events"
)
Variables ¶
var ( Event_EventType_name = map[int32]string{ 0: "Add", 1: "Update", 2: "Delete", 3: "Error", } Event_EventType_value = map[string]int32{ "Add": 0, "Update": 1, "Delete": 2, "Error": 3, } )
Enum value maps for Event_EventType.
var CacheService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "CacheService", HandlerType: (*CacheServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Events", Handler: _CacheService_Events_Handler, ServerStreams: true, }, }, Metadata: "event.proto", }
CacheService_ServiceDesc is the grpc.ServiceDesc for CacheService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_event_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCacheServiceServer ¶
func RegisterCacheServiceServer(s grpc.ServiceRegistrar, srv CacheServiceServer)
Types ¶
type CacheServiceClient ¶
type CacheServiceClient interface {
Events(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CacheService_EventsClient, error)
}
CacheServiceClient is the client API for CacheService 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 NewCacheServiceClient ¶
func NewCacheServiceClient(cc grpc.ClientConnInterface) CacheServiceClient
type CacheServiceServer ¶
type CacheServiceServer interface { Events(*Empty, CacheService_EventsServer) error // contains filtered or unexported methods }
CacheServiceServer is the server API for CacheService service. All implementations must embed UnimplementedCacheServiceServer for forward compatibility
type CacheService_EventsClient ¶
type CacheService_EventsClient interface { Recv() (*Event, error) grpc.ClientStream }
type CacheService_EventsServer ¶
type CacheService_EventsServer interface { Send(*Event) error grpc.ServerStream }
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type Event ¶
type Event struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type Event_EventType `protobuf:"varint,2,opt,name=type,proto3,enum=Event_EventType" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetType ¶
func (x *Event) GetType() Event_EventType
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Event_EventType ¶
type Event_EventType int32
const ( Event_Add Event_EventType = 0 Event_Update Event_EventType = 1 Event_Delete Event_EventType = 2 Event_Error Event_EventType = 3 )
func (Event_EventType) Descriptor ¶
func (Event_EventType) Descriptor() protoreflect.EnumDescriptor
func (Event_EventType) Enum ¶
func (x Event_EventType) Enum() *Event_EventType
func (Event_EventType) EnumDescriptor
deprecated
func (Event_EventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Event_EventType.Descriptor instead.
func (Event_EventType) Number ¶
func (x Event_EventType) Number() protoreflect.EnumNumber
func (Event_EventType) String ¶
func (x Event_EventType) String() string
func (Event_EventType) Type ¶
func (Event_EventType) Type() protoreflect.EnumType
type UnimplementedCacheServiceServer ¶
type UnimplementedCacheServiceServer struct { }
UnimplementedCacheServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedCacheServiceServer) Events ¶
func (UnimplementedCacheServiceServer) Events(*Empty, CacheService_EventsServer) error
type UnsafeCacheServiceServer ¶
type UnsafeCacheServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCacheServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServiceServer will result in compilation errors.