Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterEventStreamingServer(s grpc.ServiceRegistrar, srv EventStreamingServer)
- type ClientPong
- func (*ClientPong) Descriptor() ([]byte, []int)deprecated
- func (x *ClientPong) GetTimestamp() *timestamppb.Timestamp
- func (*ClientPong) ProtoMessage()
- func (x *ClientPong) ProtoReflect() protoreflect.Message
- func (x *ClientPong) Reset()
- func (x *ClientPong) String() string
- func (m *ClientPong) Validate() error
- func (m *ClientPong) ValidateAll() error
- type ClientPongMultiError
- type ClientPongValidationError
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetId() *EventId
- func (x *Event) GetTest() *TestEvent
- func (x *Event) GetTs() *timestamppb.Timestamp
- func (m *Event) GetType() isEvent_Type
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- func (m *Event) Validate() error
- func (m *Event) ValidateAll() error
- type EventBatch
- func (*EventBatch) Descriptor() ([]byte, []int)deprecated
- func (x *EventBatch) GetEvents() []*Event
- func (*EventBatch) ProtoMessage()
- func (x *EventBatch) ProtoReflect() protoreflect.Message
- func (x *EventBatch) Reset()
- func (x *EventBatch) String() string
- func (m *EventBatch) Validate() error
- func (m *EventBatch) ValidateAll() error
- type EventBatchMultiError
- type EventBatchValidationError
- type EventId
- func (*EventId) Descriptor() ([]byte, []int)deprecated
- func (x *EventId) GetId() []byte
- func (*EventId) ProtoMessage()
- func (x *EventId) ProtoReflect() protoreflect.Message
- func (x *EventId) Reset()
- func (x *EventId) String() string
- func (m *EventId) Validate() error
- func (m *EventId) ValidateAll() error
- type EventIdMultiError
- type EventIdValidationError
- type EventMultiError
- type EventStreamingClient
- type EventStreamingServer
- type EventStreaming_StreamEventsClient
- type EventStreaming_StreamEventsServer
- type EventValidationError
- type Event_Test
- type ForwardEventsRequest
- func (*ForwardEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ForwardEventsRequest) GetUserEvents() *UserEventBatch
- func (*ForwardEventsRequest) ProtoMessage()
- func (x *ForwardEventsRequest) ProtoReflect() protoreflect.Message
- func (x *ForwardEventsRequest) Reset()
- func (x *ForwardEventsRequest) String() string
- func (m *ForwardEventsRequest) Validate() error
- func (m *ForwardEventsRequest) ValidateAll() error
- type ForwardEventsRequestMultiError
- type ForwardEventsRequestValidationError
- func (e ForwardEventsRequestValidationError) Cause() error
- func (e ForwardEventsRequestValidationError) Error() string
- func (e ForwardEventsRequestValidationError) ErrorName() string
- func (e ForwardEventsRequestValidationError) Field() string
- func (e ForwardEventsRequestValidationError) Key() bool
- func (e ForwardEventsRequestValidationError) Reason() string
- type ForwardEventsResponse
- func (*ForwardEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ForwardEventsResponse) GetResult() ForwardEventsResponse_Result
- func (*ForwardEventsResponse) ProtoMessage()
- func (x *ForwardEventsResponse) ProtoReflect() protoreflect.Message
- func (x *ForwardEventsResponse) Reset()
- func (x *ForwardEventsResponse) String() string
- func (m *ForwardEventsResponse) Validate() error
- func (m *ForwardEventsResponse) ValidateAll() error
- type ForwardEventsResponseMultiError
- type ForwardEventsResponseValidationError
- func (e ForwardEventsResponseValidationError) Cause() error
- func (e ForwardEventsResponseValidationError) Error() string
- func (e ForwardEventsResponseValidationError) ErrorName() string
- func (e ForwardEventsResponseValidationError) Field() string
- func (e ForwardEventsResponseValidationError) Key() bool
- func (e ForwardEventsResponseValidationError) Reason() string
- type ForwardEventsResponse_Result
- func (ForwardEventsResponse_Result) Descriptor() protoreflect.EnumDescriptor
- func (x ForwardEventsResponse_Result) Enum() *ForwardEventsResponse_Result
- func (ForwardEventsResponse_Result) EnumDescriptor() ([]byte, []int)deprecated
- func (x ForwardEventsResponse_Result) Number() protoreflect.EnumNumber
- func (x ForwardEventsResponse_Result) String() string
- func (ForwardEventsResponse_Result) Type() protoreflect.EnumType
- type ServerPing
- func (*ServerPing) Descriptor() ([]byte, []int)deprecated
- func (x *ServerPing) GetPingDelay() *durationpb.Duration
- func (x *ServerPing) GetTimestamp() *timestamppb.Timestamp
- func (*ServerPing) ProtoMessage()
- func (x *ServerPing) ProtoReflect() protoreflect.Message
- func (x *ServerPing) Reset()
- func (x *ServerPing) String() string
- func (m *ServerPing) Validate() error
- func (m *ServerPing) ValidateAll() error
- type ServerPingMultiError
- type ServerPingValidationError
- type StreamEventsRequest
- func (*StreamEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest) GetParams() *StreamEventsRequest_Params
- func (x *StreamEventsRequest) GetPong() *ClientPong
- func (m *StreamEventsRequest) GetType() isStreamEventsRequest_Type
- func (*StreamEventsRequest) ProtoMessage()
- func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest) Reset()
- func (x *StreamEventsRequest) String() string
- func (m *StreamEventsRequest) Validate() error
- func (m *StreamEventsRequest) ValidateAll() error
- type StreamEventsRequestMultiError
- type StreamEventsRequestValidationError
- 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
- func (*StreamEventsRequest_Params) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsRequest_Params) GetAuth() *v1.Auth
- func (x *StreamEventsRequest_Params) GetTs() *timestamppb.Timestamp
- func (*StreamEventsRequest_Params) ProtoMessage()
- func (x *StreamEventsRequest_Params) ProtoReflect() protoreflect.Message
- func (x *StreamEventsRequest_Params) Reset()
- func (x *StreamEventsRequest_Params) String() string
- func (m *StreamEventsRequest_Params) Validate() error
- func (m *StreamEventsRequest_Params) ValidateAll() error
- type StreamEventsRequest_ParamsMultiError
- type StreamEventsRequest_ParamsValidationError
- 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_
- type StreamEventsRequest_Pong
- type StreamEventsResponse
- func (*StreamEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsResponse) GetError() *StreamEventsResponse_StreamError
- func (x *StreamEventsResponse) GetEvents() *EventBatch
- func (x *StreamEventsResponse) GetPing() *ServerPing
- func (m *StreamEventsResponse) GetType() isStreamEventsResponse_Type
- func (*StreamEventsResponse) ProtoMessage()
- func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
- func (x *StreamEventsResponse) Reset()
- func (x *StreamEventsResponse) String() string
- func (m *StreamEventsResponse) Validate() error
- func (m *StreamEventsResponse) ValidateAll() error
- type StreamEventsResponseMultiError
- type StreamEventsResponseValidationError
- 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
- type StreamEventsResponse_Events
- type StreamEventsResponse_Ping
- type StreamEventsResponse_StreamError
- func (*StreamEventsResponse_StreamError) Descriptor() ([]byte, []int)deprecated
- func (x *StreamEventsResponse_StreamError) GetCode() StreamEventsResponse_StreamError_Code
- func (*StreamEventsResponse_StreamError) ProtoMessage()
- func (x *StreamEventsResponse_StreamError) ProtoReflect() protoreflect.Message
- func (x *StreamEventsResponse_StreamError) Reset()
- func (x *StreamEventsResponse_StreamError) String() string
- func (m *StreamEventsResponse_StreamError) Validate() error
- func (m *StreamEventsResponse_StreamError) ValidateAll() error
- type StreamEventsResponse_StreamErrorMultiError
- type StreamEventsResponse_StreamErrorValidationError
- 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
- func (StreamEventsResponse_StreamError_Code) Descriptor() protoreflect.EnumDescriptor
- func (x StreamEventsResponse_StreamError_Code) Enum() *StreamEventsResponse_StreamError_Code
- func (StreamEventsResponse_StreamError_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x StreamEventsResponse_StreamError_Code) Number() protoreflect.EnumNumber
- func (x StreamEventsResponse_StreamError_Code) String() string
- func (StreamEventsResponse_StreamError_Code) Type() protoreflect.EnumType
- type TestEvent
- func (*TestEvent) Descriptor() ([]byte, []int)deprecated
- func (x *TestEvent) GetHops() []string
- func (x *TestEvent) GetNonce() uint64
- func (*TestEvent) ProtoMessage()
- func (x *TestEvent) ProtoReflect() protoreflect.Message
- func (x *TestEvent) Reset()
- func (x *TestEvent) String() string
- func (m *TestEvent) Validate() error
- func (m *TestEvent) ValidateAll() error
- type TestEventMultiError
- type TestEventValidationError
- type UnimplementedEventStreamingServer
- type UnsafeEventStreamingServer
- type UserEvent
- func (*UserEvent) Descriptor() ([]byte, []int)deprecated
- func (x *UserEvent) GetEvent() *Event
- func (x *UserEvent) GetUserId() *v1.UserId
- func (*UserEvent) ProtoMessage()
- func (x *UserEvent) ProtoReflect() protoreflect.Message
- func (x *UserEvent) Reset()
- func (x *UserEvent) String() string
- func (m *UserEvent) Validate() error
- func (m *UserEvent) ValidateAll() error
- type UserEventBatch
- func (*UserEventBatch) Descriptor() ([]byte, []int)deprecated
- func (x *UserEventBatch) GetEvents() []*UserEvent
- func (*UserEventBatch) ProtoMessage()
- func (x *UserEventBatch) ProtoReflect() protoreflect.Message
- func (x *UserEventBatch) Reset()
- func (x *UserEventBatch) String() string
- func (m *UserEventBatch) Validate() error
- func (m *UserEventBatch) ValidateAll() error
- type UserEventBatchMultiError
- type UserEventBatchValidationError
- func (e UserEventBatchValidationError) Cause() error
- func (e UserEventBatchValidationError) Error() string
- func (e UserEventBatchValidationError) ErrorName() string
- func (e UserEventBatchValidationError) Field() string
- func (e UserEventBatchValidationError) Key() bool
- func (e UserEventBatchValidationError) Reason() string
- type UserEventMultiError
- type UserEventValidationError
Constants ¶
const ( EventStreaming_StreamEvents_FullMethodName = "/flipcash.event.v1.EventStreaming/StreamEvents" EventStreaming_ForwardEvents_FullMethodName = "/flipcash.event.v1.EventStreaming/ForwardEvents" )
Variables ¶
var ( StreamEventsResponse_StreamError_Code_name = map[int32]string{ 0: "DENIED", 1: "INVALID_TIMESTAMP", } StreamEventsResponse_StreamError_Code_value = map[string]int32{ "DENIED": 0, "INVALID_TIMESTAMP": 1, } )
Enum value maps for StreamEventsResponse_StreamError_Code.
var ( ForwardEventsResponse_Result_name = map[int32]string{ 0: "OK", 1: "DENIED", } ForwardEventsResponse_Result_value = map[string]int32{ "OK": 0, "DENIED": 1, } )
Enum value maps for ForwardEventsResponse_Result.
var EventStreaming_ServiceDesc = grpc.ServiceDesc{ ServiceName: "flipcash.event.v1.EventStreaming", HandlerType: (*EventStreamingServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ForwardEvents", Handler: _EventStreaming_ForwardEvents_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamEvents", Handler: _EventStreaming_StreamEvents_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "event/v1/event_streaming_service.proto", }
EventStreaming_ServiceDesc is the grpc.ServiceDesc for EventStreaming 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_v1_event_streaming_service_proto protoreflect.FileDescriptor
var File_event_v1_model_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEventStreamingServer ¶
func RegisterEventStreamingServer(s grpc.ServiceRegistrar, srv EventStreamingServer)
Types ¶
type ClientPong ¶
type ClientPong struct {
// Timestamp the Pong was sent on the stream, for server to get a sense
// of potential network latency
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
func (*ClientPong) Descriptor
deprecated
func (*ClientPong) Descriptor() ([]byte, []int)
Deprecated: Use ClientPong.ProtoReflect.Descriptor instead.
func (*ClientPong) GetTimestamp ¶
func (x *ClientPong) GetTimestamp() *timestamppb.Timestamp
func (*ClientPong) ProtoMessage ¶
func (*ClientPong) ProtoMessage()
func (*ClientPong) ProtoReflect ¶
func (x *ClientPong) ProtoReflect() protoreflect.Message
func (*ClientPong) Reset ¶
func (x *ClientPong) Reset()
func (*ClientPong) String ¶
func (x *ClientPong) String() string
func (*ClientPong) Validate ¶
func (m *ClientPong) Validate() error
Validate checks the field values on ClientPong with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ClientPong) ValidateAll ¶
func (m *ClientPong) ValidateAll() error
ValidateAll checks the field values on ClientPong with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ClientPongMultiError, or nil if none found.
type ClientPongMultiError ¶
type ClientPongMultiError []error
ClientPongMultiError is an error wrapping multiple validation errors returned by ClientPong.ValidateAll() if the designated constraints aren't met.
func (ClientPongMultiError) AllErrors ¶
func (m ClientPongMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ClientPongMultiError) Error ¶
func (m ClientPongMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ClientPongValidationError ¶
type ClientPongValidationError struct {
// contains filtered or unexported fields
}
ClientPongValidationError is the validation error returned by ClientPong.Validate if the designated constraints aren't met.
func (ClientPongValidationError) Cause ¶
func (e ClientPongValidationError) Cause() error
Cause function returns cause value.
func (ClientPongValidationError) Error ¶
func (e ClientPongValidationError) Error() string
Error satisfies the builtin error interface
func (ClientPongValidationError) ErrorName ¶
func (e ClientPongValidationError) ErrorName() string
ErrorName returns error name.
func (ClientPongValidationError) Field ¶
func (e ClientPongValidationError) Field() string
Field function returns field value.
func (ClientPongValidationError) Key ¶
func (e ClientPongValidationError) Key() bool
Key function returns key value.
func (ClientPongValidationError) Reason ¶
func (e ClientPongValidationError) Reason() string
Reason function returns reason value.
type Event ¶
type Event struct {
Id *EventId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Ts *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
// Types that are assignable to Type:
//
// *Event_Test
Type isEvent_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
todo: define additional events
func (*Event) Descriptor
deprecated
func (*Event) GetTs ¶
func (x *Event) GetTs() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
func (*Event) Validate ¶
Validate checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*Event) ValidateAll ¶
ValidateAll checks the field values on Event with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventMultiError, or nil if none found.
type EventBatch ¶
type EventBatch struct {
Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
// contains filtered or unexported fields
}
func (*EventBatch) Descriptor
deprecated
func (*EventBatch) Descriptor() ([]byte, []int)
Deprecated: Use EventBatch.ProtoReflect.Descriptor instead.
func (*EventBatch) GetEvents ¶
func (x *EventBatch) GetEvents() []*Event
func (*EventBatch) ProtoMessage ¶
func (*EventBatch) ProtoMessage()
func (*EventBatch) ProtoReflect ¶
func (x *EventBatch) ProtoReflect() protoreflect.Message
func (*EventBatch) Reset ¶
func (x *EventBatch) Reset()
func (*EventBatch) String ¶
func (x *EventBatch) String() string
func (*EventBatch) Validate ¶
func (m *EventBatch) Validate() error
Validate checks the field values on EventBatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EventBatch) ValidateAll ¶
func (m *EventBatch) ValidateAll() error
ValidateAll checks the field values on EventBatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventBatchMultiError, or nil if none found.
type EventBatchMultiError ¶
type EventBatchMultiError []error
EventBatchMultiError is an error wrapping multiple validation errors returned by EventBatch.ValidateAll() if the designated constraints aren't met.
func (EventBatchMultiError) AllErrors ¶
func (m EventBatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventBatchMultiError) Error ¶
func (m EventBatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventBatchValidationError ¶
type EventBatchValidationError struct {
// contains filtered or unexported fields
}
EventBatchValidationError is the validation error returned by EventBatch.Validate if the designated constraints aren't met.
func (EventBatchValidationError) Cause ¶
func (e EventBatchValidationError) Cause() error
Cause function returns cause value.
func (EventBatchValidationError) Error ¶
func (e EventBatchValidationError) Error() string
Error satisfies the builtin error interface
func (EventBatchValidationError) ErrorName ¶
func (e EventBatchValidationError) ErrorName() string
ErrorName returns error name.
func (EventBatchValidationError) Field ¶
func (e EventBatchValidationError) Field() string
Field function returns field value.
func (EventBatchValidationError) Key ¶
func (e EventBatchValidationError) Key() bool
Key function returns key value.
func (EventBatchValidationError) Reason ¶
func (e EventBatchValidationError) Reason() string
Reason function returns reason value.
type EventId ¶
type EventId struct {
Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*EventId) Descriptor
deprecated
func (*EventId) ProtoMessage ¶
func (*EventId) ProtoMessage()
func (*EventId) ProtoReflect ¶
func (x *EventId) ProtoReflect() protoreflect.Message
func (*EventId) Validate ¶
Validate checks the field values on EventId with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*EventId) ValidateAll ¶
ValidateAll checks the field values on EventId with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EventIdMultiError, or nil if none found.
type EventIdMultiError ¶
type EventIdMultiError []error
EventIdMultiError is an error wrapping multiple validation errors returned by EventId.ValidateAll() if the designated constraints aren't met.
func (EventIdMultiError) AllErrors ¶
func (m EventIdMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventIdMultiError) Error ¶
func (m EventIdMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventIdValidationError ¶
type EventIdValidationError struct {
// contains filtered or unexported fields
}
EventIdValidationError is the validation error returned by EventId.Validate if the designated constraints aren't met.
func (EventIdValidationError) Cause ¶
func (e EventIdValidationError) Cause() error
Cause function returns cause value.
func (EventIdValidationError) Error ¶
func (e EventIdValidationError) Error() string
Error satisfies the builtin error interface
func (EventIdValidationError) ErrorName ¶
func (e EventIdValidationError) ErrorName() string
ErrorName returns error name.
func (EventIdValidationError) Field ¶
func (e EventIdValidationError) Field() string
Field function returns field value.
func (EventIdValidationError) Key ¶
func (e EventIdValidationError) Key() bool
Key function returns key value.
func (EventIdValidationError) Reason ¶
func (e EventIdValidationError) Reason() string
Reason function returns reason value.
type EventMultiError ¶
type EventMultiError []error
EventMultiError is an error wrapping multiple validation errors returned by Event.ValidateAll() if the designated constraints aren't met.
func (EventMultiError) AllErrors ¶
func (m EventMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (EventMultiError) Error ¶
func (m EventMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type EventStreamingClient ¶
type EventStreamingClient interface {
// StreamEvents streams events for the requesting user.
StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse], error)
// ForwardEvents is an internal RPC for forwarding events to another server.
ForwardEvents(ctx context.Context, in *ForwardEventsRequest, opts ...grpc.CallOption) (*ForwardEventsResponse, error)
}
EventStreamingClient is the client API for EventStreaming 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 NewEventStreamingClient ¶
func NewEventStreamingClient(cc grpc.ClientConnInterface) EventStreamingClient
type EventStreamingServer ¶
type EventStreamingServer interface {
// StreamEvents streams events for the requesting user.
StreamEvents(grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]) error
// ForwardEvents is an internal RPC for forwarding events to another server.
ForwardEvents(context.Context, *ForwardEventsRequest) (*ForwardEventsResponse, error)
// contains filtered or unexported methods
}
EventStreamingServer is the server API for EventStreaming service. All implementations must embed UnimplementedEventStreamingServer for forward compatibility.
type EventStreaming_StreamEventsClient ¶
type EventStreaming_StreamEventsClient = grpc.BidiStreamingClient[StreamEventsRequest, StreamEventsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type EventStreaming_StreamEventsServer ¶
type EventStreaming_StreamEventsServer = grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type EventValidationError ¶
type EventValidationError struct {
// contains filtered or unexported fields
}
EventValidationError is the validation error returned by Event.Validate if the designated constraints aren't met.
func (EventValidationError) Cause ¶
func (e EventValidationError) Cause() error
Cause function returns cause value.
func (EventValidationError) Error ¶
func (e EventValidationError) Error() string
Error satisfies the builtin error interface
func (EventValidationError) ErrorName ¶
func (e EventValidationError) ErrorName() string
ErrorName returns error name.
func (EventValidationError) Field ¶
func (e EventValidationError) Field() string
Field function returns field value.
func (EventValidationError) Key ¶
func (e EventValidationError) Key() bool
Key function returns key value.
func (EventValidationError) Reason ¶
func (e EventValidationError) Reason() string
Reason function returns reason value.
type Event_Test ¶
type Event_Test struct {
Test *TestEvent `protobuf:"bytes,3,opt,name=test,proto3,oneof"`
}
type ForwardEventsRequest ¶
type ForwardEventsRequest struct {
UserEvents *UserEventBatch `protobuf:"bytes,1,opt,name=user_events,json=userEvents,proto3" json:"user_events,omitempty"`
// contains filtered or unexported fields
}
func (*ForwardEventsRequest) Descriptor
deprecated
func (*ForwardEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ForwardEventsRequest.ProtoReflect.Descriptor instead.
func (*ForwardEventsRequest) GetUserEvents ¶
func (x *ForwardEventsRequest) GetUserEvents() *UserEventBatch
func (*ForwardEventsRequest) ProtoMessage ¶
func (*ForwardEventsRequest) ProtoMessage()
func (*ForwardEventsRequest) ProtoReflect ¶
func (x *ForwardEventsRequest) ProtoReflect() protoreflect.Message
func (*ForwardEventsRequest) Reset ¶
func (x *ForwardEventsRequest) Reset()
func (*ForwardEventsRequest) String ¶
func (x *ForwardEventsRequest) String() string
func (*ForwardEventsRequest) Validate ¶
func (m *ForwardEventsRequest) Validate() error
Validate checks the field values on ForwardEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ForwardEventsRequest) ValidateAll ¶
func (m *ForwardEventsRequest) ValidateAll() error
ValidateAll checks the field values on ForwardEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ForwardEventsRequestMultiError, or nil if none found.
type ForwardEventsRequestMultiError ¶
type ForwardEventsRequestMultiError []error
ForwardEventsRequestMultiError is an error wrapping multiple validation errors returned by ForwardEventsRequest.ValidateAll() if the designated constraints aren't met.
func (ForwardEventsRequestMultiError) AllErrors ¶
func (m ForwardEventsRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ForwardEventsRequestMultiError) Error ¶
func (m ForwardEventsRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ForwardEventsRequestValidationError ¶
type ForwardEventsRequestValidationError struct {
// contains filtered or unexported fields
}
ForwardEventsRequestValidationError is the validation error returned by ForwardEventsRequest.Validate if the designated constraints aren't met.
func (ForwardEventsRequestValidationError) Cause ¶
func (e ForwardEventsRequestValidationError) Cause() error
Cause function returns cause value.
func (ForwardEventsRequestValidationError) Error ¶
func (e ForwardEventsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ForwardEventsRequestValidationError) ErrorName ¶
func (e ForwardEventsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ForwardEventsRequestValidationError) Field ¶
func (e ForwardEventsRequestValidationError) Field() string
Field function returns field value.
func (ForwardEventsRequestValidationError) Key ¶
func (e ForwardEventsRequestValidationError) Key() bool
Key function returns key value.
func (ForwardEventsRequestValidationError) Reason ¶
func (e ForwardEventsRequestValidationError) Reason() string
Reason function returns reason value.
type ForwardEventsResponse ¶
type ForwardEventsResponse struct {
Result ForwardEventsResponse_Result `protobuf:"varint,1,opt,name=result,proto3,enum=flipcash.event.v1.ForwardEventsResponse_Result" json:"result,omitempty"`
// contains filtered or unexported fields
}
func (*ForwardEventsResponse) Descriptor
deprecated
func (*ForwardEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ForwardEventsResponse.ProtoReflect.Descriptor instead.
func (*ForwardEventsResponse) GetResult ¶
func (x *ForwardEventsResponse) GetResult() ForwardEventsResponse_Result
func (*ForwardEventsResponse) ProtoMessage ¶
func (*ForwardEventsResponse) ProtoMessage()
func (*ForwardEventsResponse) ProtoReflect ¶
func (x *ForwardEventsResponse) ProtoReflect() protoreflect.Message
func (*ForwardEventsResponse) Reset ¶
func (x *ForwardEventsResponse) Reset()
func (*ForwardEventsResponse) String ¶
func (x *ForwardEventsResponse) String() string
func (*ForwardEventsResponse) Validate ¶
func (m *ForwardEventsResponse) Validate() error
Validate checks the field values on ForwardEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ForwardEventsResponse) ValidateAll ¶
func (m *ForwardEventsResponse) ValidateAll() error
ValidateAll checks the field values on ForwardEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ForwardEventsResponseMultiError, or nil if none found.
type ForwardEventsResponseMultiError ¶
type ForwardEventsResponseMultiError []error
ForwardEventsResponseMultiError is an error wrapping multiple validation errors returned by ForwardEventsResponse.ValidateAll() if the designated constraints aren't met.
func (ForwardEventsResponseMultiError) AllErrors ¶
func (m ForwardEventsResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ForwardEventsResponseMultiError) Error ¶
func (m ForwardEventsResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ForwardEventsResponseValidationError ¶
type ForwardEventsResponseValidationError struct {
// contains filtered or unexported fields
}
ForwardEventsResponseValidationError is the validation error returned by ForwardEventsResponse.Validate if the designated constraints aren't met.
func (ForwardEventsResponseValidationError) Cause ¶
func (e ForwardEventsResponseValidationError) Cause() error
Cause function returns cause value.
func (ForwardEventsResponseValidationError) Error ¶
func (e ForwardEventsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ForwardEventsResponseValidationError) ErrorName ¶
func (e ForwardEventsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ForwardEventsResponseValidationError) Field ¶
func (e ForwardEventsResponseValidationError) Field() string
Field function returns field value.
func (ForwardEventsResponseValidationError) Key ¶
func (e ForwardEventsResponseValidationError) Key() bool
Key function returns key value.
func (ForwardEventsResponseValidationError) Reason ¶
func (e ForwardEventsResponseValidationError) Reason() string
Reason function returns reason value.
type ForwardEventsResponse_Result ¶
type ForwardEventsResponse_Result int32
const ( ForwardEventsResponse_OK ForwardEventsResponse_Result = 0 ForwardEventsResponse_DENIED ForwardEventsResponse_Result = 1 )
func (ForwardEventsResponse_Result) Descriptor ¶
func (ForwardEventsResponse_Result) Descriptor() protoreflect.EnumDescriptor
func (ForwardEventsResponse_Result) Enum ¶
func (x ForwardEventsResponse_Result) Enum() *ForwardEventsResponse_Result
func (ForwardEventsResponse_Result) EnumDescriptor
deprecated
func (ForwardEventsResponse_Result) EnumDescriptor() ([]byte, []int)
Deprecated: Use ForwardEventsResponse_Result.Descriptor instead.
func (ForwardEventsResponse_Result) Number ¶
func (x ForwardEventsResponse_Result) Number() protoreflect.EnumNumber
func (ForwardEventsResponse_Result) String ¶
func (x ForwardEventsResponse_Result) String() string
func (ForwardEventsResponse_Result) Type ¶
func (ForwardEventsResponse_Result) Type() protoreflect.EnumType
type ServerPing ¶
type ServerPing struct {
// Timestamp the ping was sent on the stream, for client to get a sense
// of potential network latency
Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// The delay server will apply before sending the next ping
PingDelay *durationpb.Duration `protobuf:"bytes,2,opt,name=ping_delay,json=pingDelay,proto3" json:"ping_delay,omitempty"`
// contains filtered or unexported fields
}
func (*ServerPing) Descriptor
deprecated
func (*ServerPing) Descriptor() ([]byte, []int)
Deprecated: Use ServerPing.ProtoReflect.Descriptor instead.
func (*ServerPing) GetPingDelay ¶
func (x *ServerPing) GetPingDelay() *durationpb.Duration
func (*ServerPing) GetTimestamp ¶
func (x *ServerPing) GetTimestamp() *timestamppb.Timestamp
func (*ServerPing) ProtoMessage ¶
func (*ServerPing) ProtoMessage()
func (*ServerPing) ProtoReflect ¶
func (x *ServerPing) ProtoReflect() protoreflect.Message
func (*ServerPing) Reset ¶
func (x *ServerPing) Reset()
func (*ServerPing) String ¶
func (x *ServerPing) String() string
func (*ServerPing) Validate ¶
func (m *ServerPing) Validate() error
Validate checks the field values on ServerPing with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ServerPing) ValidateAll ¶
func (m *ServerPing) ValidateAll() error
ValidateAll checks the field values on ServerPing with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ServerPingMultiError, or nil if none found.
type ServerPingMultiError ¶
type ServerPingMultiError []error
ServerPingMultiError is an error wrapping multiple validation errors returned by ServerPing.ValidateAll() if the designated constraints aren't met.
func (ServerPingMultiError) AllErrors ¶
func (m ServerPingMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ServerPingMultiError) Error ¶
func (m ServerPingMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ServerPingValidationError ¶
type ServerPingValidationError struct {
// contains filtered or unexported fields
}
ServerPingValidationError is the validation error returned by ServerPing.Validate if the designated constraints aren't met.
func (ServerPingValidationError) Cause ¶
func (e ServerPingValidationError) Cause() error
Cause function returns cause value.
func (ServerPingValidationError) Error ¶
func (e ServerPingValidationError) Error() string
Error satisfies the builtin error interface
func (ServerPingValidationError) ErrorName ¶
func (e ServerPingValidationError) ErrorName() string
ErrorName returns error name.
func (ServerPingValidationError) Field ¶
func (e ServerPingValidationError) Field() string
Field function returns field value.
func (ServerPingValidationError) Key ¶
func (e ServerPingValidationError) Key() bool
Key function returns key value.
func (ServerPingValidationError) Reason ¶
func (e ServerPingValidationError) Reason() string
Reason function returns reason value.
type StreamEventsRequest ¶
type StreamEventsRequest struct {
// Types that are assignable to Type:
//
// *StreamEventsRequest_Params_
// *StreamEventsRequest_Pong
Type isStreamEventsRequest_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*StreamEventsRequest) Descriptor
deprecated
func (*StreamEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsRequest.ProtoReflect.Descriptor instead.
func (*StreamEventsRequest) GetParams ¶
func (x *StreamEventsRequest) GetParams() *StreamEventsRequest_Params
func (*StreamEventsRequest) GetPong ¶
func (x *StreamEventsRequest) GetPong() *ClientPong
func (*StreamEventsRequest) GetType ¶
func (m *StreamEventsRequest) GetType() isStreamEventsRequest_Type
func (*StreamEventsRequest) ProtoMessage ¶
func (*StreamEventsRequest) ProtoMessage()
func (*StreamEventsRequest) ProtoReflect ¶
func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message
func (*StreamEventsRequest) Reset ¶
func (x *StreamEventsRequest) Reset()
func (*StreamEventsRequest) String ¶
func (x *StreamEventsRequest) String() string
func (*StreamEventsRequest) Validate ¶
func (m *StreamEventsRequest) Validate() error
Validate checks the field values on StreamEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamEventsRequest) ValidateAll ¶
func (m *StreamEventsRequest) ValidateAll() error
ValidateAll checks the field values on StreamEventsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamEventsRequestMultiError, or nil if none found.
type StreamEventsRequestMultiError ¶
type StreamEventsRequestMultiError []error
StreamEventsRequestMultiError is an error wrapping multiple validation errors returned by StreamEventsRequest.ValidateAll() if the designated constraints aren't met.
func (StreamEventsRequestMultiError) AllErrors ¶
func (m StreamEventsRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamEventsRequestMultiError) Error ¶
func (m StreamEventsRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamEventsRequestValidationError ¶
type StreamEventsRequestValidationError struct {
// contains filtered or unexported fields
}
StreamEventsRequestValidationError is the validation error returned by StreamEventsRequest.Validate if the designated constraints aren't met.
func (StreamEventsRequestValidationError) Cause ¶
func (e StreamEventsRequestValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsRequestValidationError) Error ¶
func (e StreamEventsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsRequestValidationError) ErrorName ¶
func (e StreamEventsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsRequestValidationError) Field ¶
func (e StreamEventsRequestValidationError) Field() string
Field function returns field value.
func (StreamEventsRequestValidationError) Key ¶
func (e StreamEventsRequestValidationError) Key() bool
Key function returns key value.
func (StreamEventsRequestValidationError) Reason ¶
func (e StreamEventsRequestValidationError) Reason() string
Reason function returns reason value.
type StreamEventsRequest_Params ¶
type StreamEventsRequest_Params struct {
Auth *v1.Auth `protobuf:"bytes,1,opt,name=auth,proto3" json:"auth,omitempty"`
// ts contains the time for stream open.
//
// It is used primarily as a nonce for auth. Server may reject
// timestamps that are too far in the future or past.
Ts *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
// contains filtered or unexported fields
}
func (*StreamEventsRequest_Params) Descriptor
deprecated
func (*StreamEventsRequest_Params) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsRequest_Params.ProtoReflect.Descriptor instead.
func (*StreamEventsRequest_Params) GetAuth ¶
func (x *StreamEventsRequest_Params) GetAuth() *v1.Auth
func (*StreamEventsRequest_Params) GetTs ¶
func (x *StreamEventsRequest_Params) GetTs() *timestamppb.Timestamp
func (*StreamEventsRequest_Params) ProtoMessage ¶
func (*StreamEventsRequest_Params) ProtoMessage()
func (*StreamEventsRequest_Params) ProtoReflect ¶
func (x *StreamEventsRequest_Params) ProtoReflect() protoreflect.Message
func (*StreamEventsRequest_Params) Reset ¶
func (x *StreamEventsRequest_Params) Reset()
func (*StreamEventsRequest_Params) String ¶
func (x *StreamEventsRequest_Params) String() string
func (*StreamEventsRequest_Params) Validate ¶
func (m *StreamEventsRequest_Params) Validate() error
Validate checks the field values on StreamEventsRequest_Params with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamEventsRequest_Params) ValidateAll ¶
func (m *StreamEventsRequest_Params) ValidateAll() error
ValidateAll checks the field values on StreamEventsRequest_Params with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamEventsRequest_ParamsMultiError, or nil if none found.
type StreamEventsRequest_ParamsMultiError ¶
type StreamEventsRequest_ParamsMultiError []error
StreamEventsRequest_ParamsMultiError is an error wrapping multiple validation errors returned by StreamEventsRequest_Params.ValidateAll() if the designated constraints aren't met.
func (StreamEventsRequest_ParamsMultiError) AllErrors ¶
func (m StreamEventsRequest_ParamsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamEventsRequest_ParamsMultiError) Error ¶
func (m StreamEventsRequest_ParamsMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamEventsRequest_ParamsValidationError ¶
type StreamEventsRequest_ParamsValidationError struct {
// contains filtered or unexported fields
}
StreamEventsRequest_ParamsValidationError is the validation error returned by StreamEventsRequest_Params.Validate if the designated constraints aren't met.
func (StreamEventsRequest_ParamsValidationError) Cause ¶
func (e StreamEventsRequest_ParamsValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsRequest_ParamsValidationError) Error ¶
func (e StreamEventsRequest_ParamsValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsRequest_ParamsValidationError) ErrorName ¶
func (e StreamEventsRequest_ParamsValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsRequest_ParamsValidationError) Field ¶
func (e StreamEventsRequest_ParamsValidationError) Field() string
Field function returns field value.
func (StreamEventsRequest_ParamsValidationError) Key ¶
func (e StreamEventsRequest_ParamsValidationError) Key() bool
Key function returns key value.
func (StreamEventsRequest_ParamsValidationError) Reason ¶
func (e StreamEventsRequest_ParamsValidationError) Reason() string
Reason function returns reason value.
type StreamEventsRequest_Params_ ¶
type StreamEventsRequest_Params_ struct {
Params *StreamEventsRequest_Params `protobuf:"bytes,1,opt,name=params,proto3,oneof"`
}
type StreamEventsRequest_Pong ¶
type StreamEventsRequest_Pong struct {
Pong *ClientPong `protobuf:"bytes,2,opt,name=pong,proto3,oneof"`
}
type StreamEventsResponse ¶
type StreamEventsResponse struct {
// Types that are assignable to Type:
//
// *StreamEventsResponse_Ping
// *StreamEventsResponse_Error
// *StreamEventsResponse_Events
Type isStreamEventsResponse_Type `protobuf_oneof:"type"`
// contains filtered or unexported fields
}
func (*StreamEventsResponse) Descriptor
deprecated
func (*StreamEventsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsResponse.ProtoReflect.Descriptor instead.
func (*StreamEventsResponse) GetError ¶
func (x *StreamEventsResponse) GetError() *StreamEventsResponse_StreamError
func (*StreamEventsResponse) GetEvents ¶
func (x *StreamEventsResponse) GetEvents() *EventBatch
func (*StreamEventsResponse) GetPing ¶
func (x *StreamEventsResponse) GetPing() *ServerPing
func (*StreamEventsResponse) GetType ¶
func (m *StreamEventsResponse) GetType() isStreamEventsResponse_Type
func (*StreamEventsResponse) ProtoMessage ¶
func (*StreamEventsResponse) ProtoMessage()
func (*StreamEventsResponse) ProtoReflect ¶
func (x *StreamEventsResponse) ProtoReflect() protoreflect.Message
func (*StreamEventsResponse) Reset ¶
func (x *StreamEventsResponse) Reset()
func (*StreamEventsResponse) String ¶
func (x *StreamEventsResponse) String() string
func (*StreamEventsResponse) Validate ¶
func (m *StreamEventsResponse) Validate() error
Validate checks the field values on StreamEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamEventsResponse) ValidateAll ¶
func (m *StreamEventsResponse) ValidateAll() error
ValidateAll checks the field values on StreamEventsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamEventsResponseMultiError, or nil if none found.
type StreamEventsResponseMultiError ¶
type StreamEventsResponseMultiError []error
StreamEventsResponseMultiError is an error wrapping multiple validation errors returned by StreamEventsResponse.ValidateAll() if the designated constraints aren't met.
func (StreamEventsResponseMultiError) AllErrors ¶
func (m StreamEventsResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamEventsResponseMultiError) Error ¶
func (m StreamEventsResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamEventsResponseValidationError ¶
type StreamEventsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamEventsResponseValidationError is the validation error returned by StreamEventsResponse.Validate if the designated constraints aren't met.
func (StreamEventsResponseValidationError) Cause ¶
func (e StreamEventsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsResponseValidationError) Error ¶
func (e StreamEventsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsResponseValidationError) ErrorName ¶
func (e StreamEventsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsResponseValidationError) Field ¶
func (e StreamEventsResponseValidationError) Field() string
Field function returns field value.
func (StreamEventsResponseValidationError) Key ¶
func (e StreamEventsResponseValidationError) Key() bool
Key function returns key value.
func (StreamEventsResponseValidationError) Reason ¶
func (e StreamEventsResponseValidationError) Reason() string
Reason function returns reason value.
type StreamEventsResponse_Error ¶
type StreamEventsResponse_Error struct {
Error *StreamEventsResponse_StreamError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}
type StreamEventsResponse_Events ¶
type StreamEventsResponse_Events struct {
Events *EventBatch `protobuf:"bytes,3,opt,name=events,proto3,oneof"`
}
type StreamEventsResponse_Ping ¶
type StreamEventsResponse_Ping struct {
Ping *ServerPing `protobuf:"bytes,1,opt,name=ping,proto3,oneof"`
}
type StreamEventsResponse_StreamError ¶
type StreamEventsResponse_StreamError struct {
Code StreamEventsResponse_StreamError_Code `protobuf:"varint,1,opt,name=code,proto3,enum=flipcash.event.v1.StreamEventsResponse_StreamError_Code" json:"code,omitempty"`
// contains filtered or unexported fields
}
func (*StreamEventsResponse_StreamError) Descriptor
deprecated
func (*StreamEventsResponse_StreamError) Descriptor() ([]byte, []int)
Deprecated: Use StreamEventsResponse_StreamError.ProtoReflect.Descriptor instead.
func (*StreamEventsResponse_StreamError) GetCode ¶
func (x *StreamEventsResponse_StreamError) GetCode() StreamEventsResponse_StreamError_Code
func (*StreamEventsResponse_StreamError) ProtoMessage ¶
func (*StreamEventsResponse_StreamError) ProtoMessage()
func (*StreamEventsResponse_StreamError) ProtoReflect ¶
func (x *StreamEventsResponse_StreamError) ProtoReflect() protoreflect.Message
func (*StreamEventsResponse_StreamError) Reset ¶
func (x *StreamEventsResponse_StreamError) Reset()
func (*StreamEventsResponse_StreamError) String ¶
func (x *StreamEventsResponse_StreamError) String() string
func (*StreamEventsResponse_StreamError) Validate ¶
func (m *StreamEventsResponse_StreamError) Validate() error
Validate checks the field values on StreamEventsResponse_StreamError with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*StreamEventsResponse_StreamError) ValidateAll ¶
func (m *StreamEventsResponse_StreamError) ValidateAll() error
ValidateAll checks the field values on StreamEventsResponse_StreamError with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StreamEventsResponse_StreamErrorMultiError, or nil if none found.
type StreamEventsResponse_StreamErrorMultiError ¶
type StreamEventsResponse_StreamErrorMultiError []error
StreamEventsResponse_StreamErrorMultiError is an error wrapping multiple validation errors returned by StreamEventsResponse_StreamError.ValidateAll() if the designated constraints aren't met.
func (StreamEventsResponse_StreamErrorMultiError) AllErrors ¶
func (m StreamEventsResponse_StreamErrorMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (StreamEventsResponse_StreamErrorMultiError) Error ¶
func (m StreamEventsResponse_StreamErrorMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type StreamEventsResponse_StreamErrorValidationError ¶
type StreamEventsResponse_StreamErrorValidationError struct {
// contains filtered or unexported fields
}
StreamEventsResponse_StreamErrorValidationError is the validation error returned by StreamEventsResponse_StreamError.Validate if the designated constraints aren't met.
func (StreamEventsResponse_StreamErrorValidationError) Cause ¶
func (e StreamEventsResponse_StreamErrorValidationError) Cause() error
Cause function returns cause value.
func (StreamEventsResponse_StreamErrorValidationError) Error ¶
func (e StreamEventsResponse_StreamErrorValidationError) Error() string
Error satisfies the builtin error interface
func (StreamEventsResponse_StreamErrorValidationError) ErrorName ¶
func (e StreamEventsResponse_StreamErrorValidationError) ErrorName() string
ErrorName returns error name.
func (StreamEventsResponse_StreamErrorValidationError) Field ¶
func (e StreamEventsResponse_StreamErrorValidationError) Field() string
Field function returns field value.
func (StreamEventsResponse_StreamErrorValidationError) Key ¶
func (e StreamEventsResponse_StreamErrorValidationError) Key() bool
Key function returns key value.
func (StreamEventsResponse_StreamErrorValidationError) Reason ¶
func (e StreamEventsResponse_StreamErrorValidationError) Reason() string
Reason function returns reason value.
type StreamEventsResponse_StreamError_Code ¶
type StreamEventsResponse_StreamError_Code int32
const ( StreamEventsResponse_StreamError_DENIED StreamEventsResponse_StreamError_Code = 0 StreamEventsResponse_StreamError_INVALID_TIMESTAMP StreamEventsResponse_StreamError_Code = 1 )
func (StreamEventsResponse_StreamError_Code) Descriptor ¶
func (StreamEventsResponse_StreamError_Code) Descriptor() protoreflect.EnumDescriptor
func (StreamEventsResponse_StreamError_Code) EnumDescriptor
deprecated
func (StreamEventsResponse_StreamError_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use StreamEventsResponse_StreamError_Code.Descriptor instead.
func (StreamEventsResponse_StreamError_Code) Number ¶
func (x StreamEventsResponse_StreamError_Code) Number() protoreflect.EnumNumber
func (StreamEventsResponse_StreamError_Code) String ¶
func (x StreamEventsResponse_StreamError_Code) String() string
func (StreamEventsResponse_StreamError_Code) Type ¶
func (StreamEventsResponse_StreamError_Code) Type() protoreflect.EnumType
type TestEvent ¶
type TestEvent struct {
Hops []string `protobuf:"bytes,1,rep,name=hops,proto3" json:"hops,omitempty"`
Nonce uint64 `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
// contains filtered or unexported fields
}
func (*TestEvent) Descriptor
deprecated
func (*TestEvent) ProtoMessage ¶
func (*TestEvent) ProtoMessage()
func (*TestEvent) ProtoReflect ¶
func (x *TestEvent) ProtoReflect() protoreflect.Message
func (*TestEvent) Validate ¶
Validate checks the field values on TestEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*TestEvent) ValidateAll ¶
ValidateAll checks the field values on TestEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TestEventMultiError, or nil if none found.
type TestEventMultiError ¶
type TestEventMultiError []error
TestEventMultiError is an error wrapping multiple validation errors returned by TestEvent.ValidateAll() if the designated constraints aren't met.
func (TestEventMultiError) AllErrors ¶
func (m TestEventMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (TestEventMultiError) Error ¶
func (m TestEventMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type TestEventValidationError ¶
type TestEventValidationError struct {
// contains filtered or unexported fields
}
TestEventValidationError is the validation error returned by TestEvent.Validate if the designated constraints aren't met.
func (TestEventValidationError) Cause ¶
func (e TestEventValidationError) Cause() error
Cause function returns cause value.
func (TestEventValidationError) Error ¶
func (e TestEventValidationError) Error() string
Error satisfies the builtin error interface
func (TestEventValidationError) ErrorName ¶
func (e TestEventValidationError) ErrorName() string
ErrorName returns error name.
func (TestEventValidationError) Field ¶
func (e TestEventValidationError) Field() string
Field function returns field value.
func (TestEventValidationError) Key ¶
func (e TestEventValidationError) Key() bool
Key function returns key value.
func (TestEventValidationError) Reason ¶
func (e TestEventValidationError) Reason() string
Reason function returns reason value.
type UnimplementedEventStreamingServer ¶
type UnimplementedEventStreamingServer struct{}
UnimplementedEventStreamingServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedEventStreamingServer) ForwardEvents ¶
func (UnimplementedEventStreamingServer) ForwardEvents(context.Context, *ForwardEventsRequest) (*ForwardEventsResponse, error)
func (UnimplementedEventStreamingServer) StreamEvents ¶
func (UnimplementedEventStreamingServer) StreamEvents(grpc.BidiStreamingServer[StreamEventsRequest, StreamEventsResponse]) error
type UnsafeEventStreamingServer ¶
type UnsafeEventStreamingServer interface {
// contains filtered or unexported methods
}
UnsafeEventStreamingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventStreamingServer will result in compilation errors.
type UserEvent ¶
type UserEvent struct {
UserId *v1.UserId `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
// contains filtered or unexported fields
}
func (*UserEvent) Descriptor
deprecated
func (*UserEvent) ProtoMessage ¶
func (*UserEvent) ProtoMessage()
func (*UserEvent) ProtoReflect ¶
func (x *UserEvent) ProtoReflect() protoreflect.Message
func (*UserEvent) Validate ¶
Validate checks the field values on UserEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*UserEvent) ValidateAll ¶
ValidateAll checks the field values on UserEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UserEventMultiError, or nil if none found.
type UserEventBatch ¶
type UserEventBatch struct {
Events []*UserEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
// contains filtered or unexported fields
}
func (*UserEventBatch) Descriptor
deprecated
func (*UserEventBatch) Descriptor() ([]byte, []int)
Deprecated: Use UserEventBatch.ProtoReflect.Descriptor instead.
func (*UserEventBatch) GetEvents ¶
func (x *UserEventBatch) GetEvents() []*UserEvent
func (*UserEventBatch) ProtoMessage ¶
func (*UserEventBatch) ProtoMessage()
func (*UserEventBatch) ProtoReflect ¶
func (x *UserEventBatch) ProtoReflect() protoreflect.Message
func (*UserEventBatch) Reset ¶
func (x *UserEventBatch) Reset()
func (*UserEventBatch) String ¶
func (x *UserEventBatch) String() string
func (*UserEventBatch) Validate ¶
func (m *UserEventBatch) Validate() error
Validate checks the field values on UserEventBatch with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*UserEventBatch) ValidateAll ¶
func (m *UserEventBatch) ValidateAll() error
ValidateAll checks the field values on UserEventBatch with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UserEventBatchMultiError, or nil if none found.
type UserEventBatchMultiError ¶
type UserEventBatchMultiError []error
UserEventBatchMultiError is an error wrapping multiple validation errors returned by UserEventBatch.ValidateAll() if the designated constraints aren't met.
func (UserEventBatchMultiError) AllErrors ¶
func (m UserEventBatchMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UserEventBatchMultiError) Error ¶
func (m UserEventBatchMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UserEventBatchValidationError ¶
type UserEventBatchValidationError struct {
// contains filtered or unexported fields
}
UserEventBatchValidationError is the validation error returned by UserEventBatch.Validate if the designated constraints aren't met.
func (UserEventBatchValidationError) Cause ¶
func (e UserEventBatchValidationError) Cause() error
Cause function returns cause value.
func (UserEventBatchValidationError) Error ¶
func (e UserEventBatchValidationError) Error() string
Error satisfies the builtin error interface
func (UserEventBatchValidationError) ErrorName ¶
func (e UserEventBatchValidationError) ErrorName() string
ErrorName returns error name.
func (UserEventBatchValidationError) Field ¶
func (e UserEventBatchValidationError) Field() string
Field function returns field value.
func (UserEventBatchValidationError) Key ¶
func (e UserEventBatchValidationError) Key() bool
Key function returns key value.
func (UserEventBatchValidationError) Reason ¶
func (e UserEventBatchValidationError) Reason() string
Reason function returns reason value.
type UserEventMultiError ¶
type UserEventMultiError []error
UserEventMultiError is an error wrapping multiple validation errors returned by UserEvent.ValidateAll() if the designated constraints aren't met.
func (UserEventMultiError) AllErrors ¶
func (m UserEventMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (UserEventMultiError) Error ¶
func (m UserEventMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type UserEventValidationError ¶
type UserEventValidationError struct {
// contains filtered or unexported fields
}
UserEventValidationError is the validation error returned by UserEvent.Validate if the designated constraints aren't met.
func (UserEventValidationError) Cause ¶
func (e UserEventValidationError) Cause() error
Cause function returns cause value.
func (UserEventValidationError) Error ¶
func (e UserEventValidationError) Error() string
Error satisfies the builtin error interface
func (UserEventValidationError) ErrorName ¶
func (e UserEventValidationError) ErrorName() string
ErrorName returns error name.
func (UserEventValidationError) Field ¶
func (e UserEventValidationError) Field() string
Field function returns field value.
func (UserEventValidationError) Key ¶
func (e UserEventValidationError) Key() bool
Key function returns key value.
func (UserEventValidationError) Reason ¶
func (e UserEventValidationError) Reason() string
Reason function returns reason value.