Documentation ¶
Index ¶
Constants ¶
const (
EventManager_Events_FullMethodName = "/api.EventManager/Events"
)
Variables ¶
var EventManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.EventManager", HandlerType: (*EventManagerServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Events", Handler: _EventManager_Events_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "event_manager.proto", }
EventManager_ServiceDesc is the grpc.ServiceDesc for EventManager 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_manager_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEventManagerServer ¶
func RegisterEventManagerServer(s grpc.ServiceRegistrar, srv EventManagerServer)
Types ¶
type Event ¶
type Event struct { Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"` From *UUID `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventManagerClient ¶
type EventManagerClient interface {
Events(ctx context.Context, opts ...grpc.CallOption) (EventManager_EventsClient, error)
}
EventManagerClient is the client API for EventManager 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 NewEventManagerClient ¶
func NewEventManagerClient(cc grpc.ClientConnInterface) EventManagerClient
type EventManagerServer ¶
type EventManagerServer interface { Events(EventManager_EventsServer) error // contains filtered or unexported methods }
EventManagerServer is the server API for EventManager service. All implementations must embed UnimplementedEventManagerServer for forward compatibility
type UUID ¶
type UUID struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*UUID) Descriptor
deprecated
func (*UUID) ProtoMessage ¶
func (*UUID) ProtoMessage()
func (*UUID) ProtoReflect ¶
func (x *UUID) ProtoReflect() protoreflect.Message
type UnimplementedEventManagerServer ¶
type UnimplementedEventManagerServer struct { }
UnimplementedEventManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedEventManagerServer) Events ¶
func (UnimplementedEventManagerServer) Events(EventManager_EventsServer) error
type UnsafeEventManagerServer ¶
type UnsafeEventManagerServer interface {
// contains filtered or unexported methods
}
UnsafeEventManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventManagerServer will result in compilation errors.