Versions in this module Expand all Collapse all v1 v1.6.0 Jul 16, 2025 Changes in this version + const EventStreaming_StreamEvents_FullMethodName + var EventStreaming_ServiceDesc = grpc.ServiceDesc + var File_event_v1_event_streaming_service_proto protoreflect.FileDescriptor + var File_event_v1_model_proto protoreflect.FileDescriptor + var StreamEventsResponse_StreamError_Code_name = map[int32]string + var StreamEventsResponse_StreamError_Code_value = map[string]int32 + func RegisterEventStreamingServer(s grpc.ServiceRegistrar, srv EventStreamingServer) + type Event struct + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) Validate() error + func (m *Event) ValidateAll() error + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type EventBatch struct + Events []*Event + func (*EventBatch) Descriptor() ([]byte, []int) + func (*EventBatch) ProtoMessage() + func (m *EventBatch) Validate() error + func (m *EventBatch) ValidateAll() error + func (x *EventBatch) GetEvents() []*Event + func (x *EventBatch) ProtoReflect() protoreflect.Message + func (x *EventBatch) Reset() + func (x *EventBatch) String() string + type EventBatchMultiError []error + func (m EventBatchMultiError) AllErrors() []error + func (m EventBatchMultiError) Error() string + type EventBatchValidationError struct + func (e EventBatchValidationError) Cause() error + func (e EventBatchValidationError) Error() string + func (e EventBatchValidationError) ErrorName() string + func (e EventBatchValidationError) Field() string + func (e EventBatchValidationError) Key() bool + func (e EventBatchValidationError) Reason() string + type EventMultiError []error + func (m EventMultiError) AllErrors() []error + func (m EventMultiError) Error() string + type EventStreamingClient interface + StreamEvents func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error) + func NewEventStreamingClient(cc grpc.ClientConnInterface) EventStreamingClient + type EventStreamingServer interface + StreamEvents func(grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]) error + type EventStreaming_StreamEventsClient = grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse] + type EventStreaming_StreamEventsServer = grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse] + type EventValidationError struct + func (e EventValidationError) Cause() error + func (e EventValidationError) Error() string + func (e EventValidationError) ErrorName() string + func (e EventValidationError) Field() string + func (e EventValidationError) Key() bool + func (e EventValidationError) Reason() string + type StreamEventsRequest struct + Type isStreamEventsRequest_Type + func (*StreamEventsRequest) Descriptor() ([]byte, []int) + func (*StreamEventsRequest) ProtoMessage() + func (m *StreamEventsRequest) GetType() isStreamEventsRequest_Type + func (m *StreamEventsRequest) Validate() error + func (m *StreamEventsRequest) ValidateAll() error + func (x *StreamEventsRequest) GetParams() *StreamEventsRequest_Params + func (x *StreamEventsRequest) GetPong() *v1.ClientPong + func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message + func (x *StreamEventsRequest) Reset() + func (x *StreamEventsRequest) String() string + type StreamEventsRequestMultiError []error + func (m StreamEventsRequestMultiError) AllErrors() []error + func (m StreamEventsRequestMultiError) Error() string + type StreamEventsRequestValidationError struct + func (e StreamEventsRequestValidationError) Cause() error + func (e StreamEventsRequestValidationError) Error() string + func (e StreamEventsRequestValidationError) ErrorName() string + func (e StreamEventsRequestValidationError) Field() string + func (e StreamEventsRequestValidationError) Key() bool + func (e StreamEventsRequestValidationError) Reason() string + type StreamEventsRequest_Params struct + Auth *v1.Auth + Ts *timestamppb.Timestamp + func (*StreamEventsRequest_Params) Descriptor() ([]byte, []int) + func (*StreamEventsRequest_Params) ProtoMessage() + func (m *StreamEventsRequest_Params) Validate() error + func (m *StreamEventsRequest_Params) ValidateAll() error + func (x *StreamEventsRequest_Params) GetAuth() *v1.Auth + func (x *StreamEventsRequest_Params) GetTs() *timestamppb.Timestamp + func (x *StreamEventsRequest_Params) ProtoReflect() protoreflect.Message + func (x *StreamEventsRequest_Params) Reset() + func (x *StreamEventsRequest_Params) String() string + type StreamEventsRequest_ParamsMultiError []error + func (m StreamEventsRequest_ParamsMultiError) AllErrors() []error + func (m StreamEventsRequest_ParamsMultiError) Error() string + type StreamEventsRequest_ParamsValidationError struct + func (e StreamEventsRequest_ParamsValidationError) Cause() error + func (e StreamEventsRequest_ParamsValidationError) Error() string + func (e StreamEventsRequest_ParamsValidationError) ErrorName() string + func (e StreamEventsRequest_ParamsValidationError) Field() string + func (e StreamEventsRequest_ParamsValidationError) Key() bool + func (e StreamEventsRequest_ParamsValidationError) Reason() string + type StreamEventsRequest_Params_ struct + Params *StreamEventsRequest_Params + type StreamEventsRequest_Pong struct + Pong *v1.ClientPong + type StreamEventsResponse struct + Type isStreamEventsResponse_Type + func (*StreamEventsResponse) Descriptor() ([]byte, []int) + func (*StreamEventsResponse) ProtoMessage() + func (m *StreamEventsResponse) GetType() isStreamEventsResponse_Type + func (m *StreamEventsResponse) Validate() error + func (m *StreamEventsResponse) ValidateAll() error + func (x *StreamEventsResponse) GetError() *StreamEventsResponse_StreamError + func (x *StreamEventsResponse) GetEvents() *EventBatch + func (x *StreamEventsResponse) GetPing() *v1.ServerPing + func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message + func (x *StreamEventsResponse) Reset() + func (x *StreamEventsResponse) String() string + type StreamEventsResponseMultiError []error + func (m StreamEventsResponseMultiError) AllErrors() []error + func (m StreamEventsResponseMultiError) Error() string + type StreamEventsResponseValidationError struct + func (e StreamEventsResponseValidationError) Cause() error + func (e StreamEventsResponseValidationError) Error() string + func (e StreamEventsResponseValidationError) ErrorName() string + func (e StreamEventsResponseValidationError) Field() string + func (e StreamEventsResponseValidationError) Key() bool + func (e StreamEventsResponseValidationError) Reason() string + type StreamEventsResponse_Error struct + Error *StreamEventsResponse_StreamError + type StreamEventsResponse_Events struct + Events *EventBatch + type StreamEventsResponse_Ping struct + Ping *v1.ServerPing + type StreamEventsResponse_StreamError struct + Code StreamEventsResponse_StreamError_Code + func (*StreamEventsResponse_StreamError) Descriptor() ([]byte, []int) + func (*StreamEventsResponse_StreamError) ProtoMessage() + func (m *StreamEventsResponse_StreamError) Validate() error + func (m *StreamEventsResponse_StreamError) ValidateAll() error + func (x *StreamEventsResponse_StreamError) GetCode() StreamEventsResponse_StreamError_Code + func (x *StreamEventsResponse_StreamError) ProtoReflect() protoreflect.Message + func (x *StreamEventsResponse_StreamError) Reset() + func (x *StreamEventsResponse_StreamError) String() string + type StreamEventsResponse_StreamErrorMultiError []error + func (m StreamEventsResponse_StreamErrorMultiError) AllErrors() []error + func (m StreamEventsResponse_StreamErrorMultiError) Error() string + type StreamEventsResponse_StreamErrorValidationError struct + func (e StreamEventsResponse_StreamErrorValidationError) Cause() error + func (e StreamEventsResponse_StreamErrorValidationError) Error() string + func (e StreamEventsResponse_StreamErrorValidationError) ErrorName() string + func (e StreamEventsResponse_StreamErrorValidationError) Field() string + func (e StreamEventsResponse_StreamErrorValidationError) Key() bool + func (e StreamEventsResponse_StreamErrorValidationError) Reason() string + type StreamEventsResponse_StreamError_Code int32 + const StreamEventsResponse_StreamError_DENIED + func (StreamEventsResponse_StreamError_Code) Descriptor() protoreflect.EnumDescriptor + func (StreamEventsResponse_StreamError_Code) EnumDescriptor() ([]byte, []int) + func (StreamEventsResponse_StreamError_Code) Type() protoreflect.EnumType + func (x StreamEventsResponse_StreamError_Code) Enum() *StreamEventsResponse_StreamError_Code + func (x StreamEventsResponse_StreamError_Code) Number() protoreflect.EnumNumber + func (x StreamEventsResponse_StreamError_Code) String() string + type UnimplementedEventStreamingServer struct + func (UnimplementedEventStreamingServer) StreamEvents(grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]) error + type UnsafeEventStreamingServer interface
Go to main page