eventpb

package
v1.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 24, 2025 License: MIT Imports: 25 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	EventStreaming_StreamEvents_FullMethodName  = "/flipcash.event.v1.EventStreaming/StreamEvents"
	EventStreaming_ForwardEvents_FullMethodName = "/flipcash.event.v1.EventStreaming/ForwardEvents"
)

Variables

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
var File_event_v1_event_streaming_service_proto protoreflect.FileDescriptor
View Source 
var File_event_v1_model_proto protoreflect.FileDescriptor

Functions

func RegisterEventStreamingServer 

func RegisterEventStreamingServer(s grpc.ServiceRegistrar, srv EventStreamingServer)

Types

type ClientPong added in v1.7.1 

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 added in v1.7.1 

func (*ClientPong) Descriptor() ([]byte, []int)

Deprecated: Use ClientPong.ProtoReflect.Descriptor instead.

func (*ClientPong) GetTimestamp added in v1.7.1 

func (x *ClientPong) GetTimestamp() *timestamppb.Timestamp

func (*ClientPong) ProtoMessage added in v1.7.1 

func (*ClientPong) ProtoMessage()

func (*ClientPong) ProtoReflect added in v1.7.1 

func (x *ClientPong) ProtoReflect() protoreflect.Message

func (*ClientPong) Reset added in v1.7.1 

func (x *ClientPong) Reset()

func (*ClientPong) String added in v1.7.1 

func (x *ClientPong) String() string

func (*ClientPong) Validate added in v1.7.1 

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 added in v1.7.1 

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 added in v1.7.1 

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 added in v1.7.1 

func (m ClientPongMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ClientPongMultiError) Error added in v1.7.1 

func (m ClientPongMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ClientPongValidationError added in v1.7.1 

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 added in v1.7.1 

func (e ClientPongValidationError) Cause() error

Cause function returns cause value.

func (ClientPongValidationError) Error added in v1.7.1 

func (e ClientPongValidationError) Error() string

Error satisfies the builtin error interface

func (ClientPongValidationError) ErrorName added in v1.7.1 

func (e ClientPongValidationError) ErrorName() string

ErrorName returns error name.

func (ClientPongValidationError) Field added in v1.7.1 

func (e ClientPongValidationError) Field() string

Field function returns field value.

func (ClientPongValidationError) Key added in v1.7.1 

func (e ClientPongValidationError) Key() bool

Key function returns key value.

func (ClientPongValidationError) Reason added in v1.7.1 

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
	//	*Event_PoolResolved
	//	*Event_PoolBetUpdate
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

todo: define additional events

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetId added in v1.6.3 

func (x *Event) GetId() *EventId

func (*Event) GetPoolBetUpdate added in v1.6.6 

func (x *Event) GetPoolBetUpdate() *PoolBetUpdateEvent

func (*Event) GetPoolResolved added in v1.6.6 

func (x *Event) GetPoolResolved() *PoolResolvedEvent

func (*Event) GetTest added in v1.6.2 

func (x *Event) GetTest() *TestEvent

func (*Event) GetTs added in v1.6.4 

func (x *Event) GetTs() *timestamppb.Timestamp

func (*Event) GetType added in v1.6.2 

func (m *Event) GetType() isEvent_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

func (*Event) Validate 

func (m *Event) Validate() error

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 

func (m *Event) ValidateAll() error

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 added in v1.6.3 

type EventId struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventId) Descriptor deprecated added in v1.6.3 

func (*EventId) Descriptor() ([]byte, []int)

Deprecated: Use EventId.ProtoReflect.Descriptor instead.

func (*EventId) GetId added in v1.6.3 

func (x *EventId) GetId() []byte

func (*EventId) ProtoMessage added in v1.6.3 

func (*EventId) ProtoMessage()

func (*EventId) ProtoReflect added in v1.6.3 

func (x *EventId) ProtoReflect() protoreflect.Message

func (*EventId) Reset added in v1.6.3 

func (x *EventId) Reset()

func (*EventId) String added in v1.6.3 

func (x *EventId) String() string

func (*EventId) Validate added in v1.6.3 

func (m *EventId) Validate() error

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 added in v1.6.3 

func (m *EventId) ValidateAll() error

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 added in v1.6.3 

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 added in v1.6.3 

func (m EventIdMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EventIdMultiError) Error added in v1.6.3 

func (m EventIdMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EventIdValidationError added in v1.6.3 

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 added in v1.6.3 

func (e EventIdValidationError) Cause() error

Cause function returns cause value.

func (EventIdValidationError) Error added in v1.6.3 

func (e EventIdValidationError) Error() string

Error satisfies the builtin error interface

func (EventIdValidationError) ErrorName added in v1.6.3 

func (e EventIdValidationError) ErrorName() string

ErrorName returns error name.

func (EventIdValidationError) Field added in v1.6.3 

func (e EventIdValidationError) Field() string

Field function returns field value.

func (EventIdValidationError) Key added in v1.6.3 

func (e EventIdValidationError) Key() bool

Key function returns key value.

func (EventIdValidationError) Reason added in v1.6.3 

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_PoolBetUpdate added in v1.6.6 

type Event_PoolBetUpdate struct {
	PoolBetUpdate *PoolBetUpdateEvent `protobuf:"bytes,101,opt,name=pool_bet_update,json=poolBetUpdate,proto3,oneof"`
}

type Event_PoolResolved added in v1.6.6 

type Event_PoolResolved struct {
	PoolResolved *PoolResolvedEvent `protobuf:"bytes,100,opt,name=pool_resolved,json=poolResolved,proto3,oneof"`
}

type Event_Test added in v1.6.2 

type Event_Test struct {
	Test *TestEvent `protobuf:"bytes,3,opt,name=test,proto3,oneof"`
}

type ForwardEventsRequest added in v1.6.2 

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 added in v1.6.2 

func (*ForwardEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ForwardEventsRequest.ProtoReflect.Descriptor instead.

func (*ForwardEventsRequest) GetUserEvents added in v1.6.2 

func (x *ForwardEventsRequest) GetUserEvents() *UserEventBatch

func (*ForwardEventsRequest) ProtoMessage added in v1.6.2 

func (*ForwardEventsRequest) ProtoMessage()

func (*ForwardEventsRequest) ProtoReflect added in v1.6.2 

func (x *ForwardEventsRequest) ProtoReflect() protoreflect.Message

func (*ForwardEventsRequest) Reset added in v1.6.2 

func (x *ForwardEventsRequest) Reset()

func (*ForwardEventsRequest) String added in v1.6.2 

func (x *ForwardEventsRequest) String() string

func (*ForwardEventsRequest) Validate added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

func (m ForwardEventsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ForwardEventsRequestMultiError) Error added in v1.6.2 

func (m ForwardEventsRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ForwardEventsRequestValidationError added in v1.6.2 

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 added in v1.6.2 

func (e ForwardEventsRequestValidationError) Cause() error

Cause function returns cause value.

func (ForwardEventsRequestValidationError) Error added in v1.6.2 

func (e ForwardEventsRequestValidationError) Error() string

Error satisfies the builtin error interface

func (ForwardEventsRequestValidationError) ErrorName added in v1.6.2 

func (e ForwardEventsRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ForwardEventsRequestValidationError) Field added in v1.6.2 

func (e ForwardEventsRequestValidationError) Field() string

Field function returns field value.

func (ForwardEventsRequestValidationError) Key added in v1.6.2 

func (e ForwardEventsRequestValidationError) Key() bool

Key function returns key value.

func (ForwardEventsRequestValidationError) Reason added in v1.6.2 

func (e ForwardEventsRequestValidationError) Reason() string

Reason function returns reason value.

type ForwardEventsResponse added in v1.6.2 

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 added in v1.6.2 

func (*ForwardEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ForwardEventsResponse.ProtoReflect.Descriptor instead.

func (*ForwardEventsResponse) GetResult added in v1.6.2 

func (x *ForwardEventsResponse) GetResult() ForwardEventsResponse_Result

func (*ForwardEventsResponse) ProtoMessage added in v1.6.2 

func (*ForwardEventsResponse) ProtoMessage()

func (*ForwardEventsResponse) ProtoReflect added in v1.6.2 

func (x *ForwardEventsResponse) ProtoReflect() protoreflect.Message

func (*ForwardEventsResponse) Reset added in v1.6.2 

func (x *ForwardEventsResponse) Reset()

func (*ForwardEventsResponse) String added in v1.6.2 

func (x *ForwardEventsResponse) String() string

func (*ForwardEventsResponse) Validate added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

func (m ForwardEventsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ForwardEventsResponseMultiError) Error added in v1.6.2 

func (m ForwardEventsResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ForwardEventsResponseValidationError added in v1.6.2 

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 added in v1.6.2 

func (e ForwardEventsResponseValidationError) Cause() error

Cause function returns cause value.

func (ForwardEventsResponseValidationError) Error added in v1.6.2 

func (e ForwardEventsResponseValidationError) Error() string

Error satisfies the builtin error interface

func (ForwardEventsResponseValidationError) ErrorName added in v1.6.2 

func (e ForwardEventsResponseValidationError) ErrorName() string

ErrorName returns error name.

func (ForwardEventsResponseValidationError) Field added in v1.6.2 

func (e ForwardEventsResponseValidationError) Field() string

Field function returns field value.

func (ForwardEventsResponseValidationError) Key added in v1.6.2 

func (e ForwardEventsResponseValidationError) Key() bool

Key function returns key value.

func (ForwardEventsResponseValidationError) Reason added in v1.6.2 

func (e ForwardEventsResponseValidationError) Reason() string

Reason function returns reason value.

type ForwardEventsResponse_Result added in v1.6.2 

type ForwardEventsResponse_Result int32
const (
	ForwardEventsResponse_OK     ForwardEventsResponse_Result = 0
	ForwardEventsResponse_DENIED ForwardEventsResponse_Result = 1
)

func (ForwardEventsResponse_Result) Descriptor added in v1.6.2 

func (ForwardEventsResponse_Result) Descriptor() protoreflect.EnumDescriptor

func (ForwardEventsResponse_Result) Enum added in v1.6.2 

func (x ForwardEventsResponse_Result) Enum() *ForwardEventsResponse_Result

func (ForwardEventsResponse_Result) EnumDescriptor deprecated added in v1.6.2 

func (ForwardEventsResponse_Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use ForwardEventsResponse_Result.Descriptor instead.

func (ForwardEventsResponse_Result) Number added in v1.6.2 

func (x ForwardEventsResponse_Result) Number() protoreflect.EnumNumber

func (ForwardEventsResponse_Result) String added in v1.6.2 

func (x ForwardEventsResponse_Result) String() string

func (ForwardEventsResponse_Result) Type added in v1.6.2 

func (ForwardEventsResponse_Result) Type() protoreflect.EnumType

type PoolBetUpdateEvent added in v1.6.6 

type PoolBetUpdateEvent struct {

	// The pool ID the bet update is for
	PoolId *v11.PoolId `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// The latest bet summary for the pool
	BetSummary *v11.BetSummary `protobuf:"bytes,2,opt,name=bet_summary,json=betSummary,proto3" json:"bet_summary,omitempty"`
	// contains filtered or unexported fields
}

Event sent when a bet is made against a pool

func (*PoolBetUpdateEvent) Descriptor deprecated added in v1.6.6 

func (*PoolBetUpdateEvent) Descriptor() ([]byte, []int)

Deprecated: Use PoolBetUpdateEvent.ProtoReflect.Descriptor instead.

func (*PoolBetUpdateEvent) GetBetSummary added in v1.6.6 

func (x *PoolBetUpdateEvent) GetBetSummary() *v11.BetSummary

func (*PoolBetUpdateEvent) GetPoolId added in v1.6.6 

func (x *PoolBetUpdateEvent) GetPoolId() *v11.PoolId

func (*PoolBetUpdateEvent) ProtoMessage added in v1.6.6 

func (*PoolBetUpdateEvent) ProtoMessage()

func (*PoolBetUpdateEvent) ProtoReflect added in v1.6.6 

func (x *PoolBetUpdateEvent) ProtoReflect() protoreflect.Message

func (*PoolBetUpdateEvent) Reset added in v1.6.6 

func (x *PoolBetUpdateEvent) Reset()

func (*PoolBetUpdateEvent) String added in v1.6.6 

func (x *PoolBetUpdateEvent) String() string

func (*PoolBetUpdateEvent) Validate added in v1.6.6 

func (m *PoolBetUpdateEvent) Validate() error

Validate checks the field values on PoolBetUpdateEvent 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 (*PoolBetUpdateEvent) ValidateAll added in v1.6.6 

func (m *PoolBetUpdateEvent) ValidateAll() error

ValidateAll checks the field values on PoolBetUpdateEvent 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 PoolBetUpdateEventMultiError, or nil if none found.

type PoolBetUpdateEventMultiError added in v1.6.6 

type PoolBetUpdateEventMultiError []error

PoolBetUpdateEventMultiError is an error wrapping multiple validation errors returned by PoolBetUpdateEvent.ValidateAll() if the designated constraints aren't met.

func (PoolBetUpdateEventMultiError) AllErrors added in v1.6.6 

func (m PoolBetUpdateEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PoolBetUpdateEventMultiError) Error added in v1.6.6 

func (m PoolBetUpdateEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PoolBetUpdateEventValidationError added in v1.6.6 

type PoolBetUpdateEventValidationError struct {
	// contains filtered or unexported fields
}

PoolBetUpdateEventValidationError is the validation error returned by PoolBetUpdateEvent.Validate if the designated constraints aren't met.

func (PoolBetUpdateEventValidationError) Cause added in v1.6.6 

func (e PoolBetUpdateEventValidationError) Cause() error

Cause function returns cause value.

func (PoolBetUpdateEventValidationError) Error added in v1.6.6 

func (e PoolBetUpdateEventValidationError) Error() string

Error satisfies the builtin error interface

func (PoolBetUpdateEventValidationError) ErrorName added in v1.6.6 

func (e PoolBetUpdateEventValidationError) ErrorName() string

ErrorName returns error name.

func (PoolBetUpdateEventValidationError) Field added in v1.6.6 

func (e PoolBetUpdateEventValidationError) Field() string

Field function returns field value.

func (PoolBetUpdateEventValidationError) Key added in v1.6.6 

func (e PoolBetUpdateEventValidationError) Key() bool

Key function returns key value.

func (PoolBetUpdateEventValidationError) Reason added in v1.6.6 

func (e PoolBetUpdateEventValidationError) Reason() string

Reason function returns reason value.

type PoolResolvedEvent added in v1.6.6 

type PoolResolvedEvent struct {

	// The latest signed pool metadata, which is guaranteed to contain a resolution
	Pool *v11.SignedPoolMetadata `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	// The final bet summary for the pool
	BetSummary *v11.BetSummary `protobuf:"bytes,2,opt,name=bet_summary,json=betSummary,proto3" json:"bet_summary,omitempty"`
	// The user's outcome for the pool
	UserSummary *v11.UserPoolSummary `protobuf:"bytes,3,opt,name=user_summary,json=userSummary,proto3" json:"user_summary,omitempty"`
	// contains filtered or unexported fields
}

Event sent when a pool has been resolved

func (*PoolResolvedEvent) Descriptor deprecated added in v1.6.6 

func (*PoolResolvedEvent) Descriptor() ([]byte, []int)

Deprecated: Use PoolResolvedEvent.ProtoReflect.Descriptor instead.

func (*PoolResolvedEvent) GetBetSummary added in v1.6.6 

func (x *PoolResolvedEvent) GetBetSummary() *v11.BetSummary

func (*PoolResolvedEvent) GetPool added in v1.6.6 

func (x *PoolResolvedEvent) GetPool() *v11.SignedPoolMetadata

func (*PoolResolvedEvent) GetUserSummary added in v1.6.6 

func (x *PoolResolvedEvent) GetUserSummary() *v11.UserPoolSummary

func (*PoolResolvedEvent) ProtoMessage added in v1.6.6 

func (*PoolResolvedEvent) ProtoMessage()

func (*PoolResolvedEvent) ProtoReflect added in v1.6.6 

func (x *PoolResolvedEvent) ProtoReflect() protoreflect.Message

func (*PoolResolvedEvent) Reset added in v1.6.6 

func (x *PoolResolvedEvent) Reset()

func (*PoolResolvedEvent) String added in v1.6.6 

func (x *PoolResolvedEvent) String() string

func (*PoolResolvedEvent) Validate added in v1.6.6 

func (m *PoolResolvedEvent) Validate() error

Validate checks the field values on PoolResolvedEvent 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 (*PoolResolvedEvent) ValidateAll added in v1.6.6 

func (m *PoolResolvedEvent) ValidateAll() error

ValidateAll checks the field values on PoolResolvedEvent 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 PoolResolvedEventMultiError, or nil if none found.

type PoolResolvedEventMultiError added in v1.6.6 

type PoolResolvedEventMultiError []error

PoolResolvedEventMultiError is an error wrapping multiple validation errors returned by PoolResolvedEvent.ValidateAll() if the designated constraints aren't met.

func (PoolResolvedEventMultiError) AllErrors added in v1.6.6 

func (m PoolResolvedEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PoolResolvedEventMultiError) Error added in v1.6.6 

func (m PoolResolvedEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PoolResolvedEventValidationError added in v1.6.6 

type PoolResolvedEventValidationError struct {
	// contains filtered or unexported fields
}

PoolResolvedEventValidationError is the validation error returned by PoolResolvedEvent.Validate if the designated constraints aren't met.

func (PoolResolvedEventValidationError) Cause added in v1.6.6 

func (e PoolResolvedEventValidationError) Cause() error

Cause function returns cause value.

func (PoolResolvedEventValidationError) Error added in v1.6.6 

func (e PoolResolvedEventValidationError) Error() string

Error satisfies the builtin error interface

func (PoolResolvedEventValidationError) ErrorName added in v1.6.6 

func (e PoolResolvedEventValidationError) ErrorName() string

ErrorName returns error name.

func (PoolResolvedEventValidationError) Field added in v1.6.6 

func (e PoolResolvedEventValidationError) Field() string

Field function returns field value.

func (PoolResolvedEventValidationError) Key added in v1.6.6 

func (e PoolResolvedEventValidationError) Key() bool

Key function returns key value.

func (PoolResolvedEventValidationError) Reason added in v1.6.6 

func (e PoolResolvedEventValidationError) Reason() string

Reason function returns reason value.

type ServerPing added in v1.7.1 

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 added in v1.7.1 

func (*ServerPing) Descriptor() ([]byte, []int)

Deprecated: Use ServerPing.ProtoReflect.Descriptor instead.

func (*ServerPing) GetPingDelay added in v1.7.1 

func (x *ServerPing) GetPingDelay() *durationpb.Duration

func (*ServerPing) GetTimestamp added in v1.7.1 

func (x *ServerPing) GetTimestamp() *timestamppb.Timestamp

func (*ServerPing) ProtoMessage added in v1.7.1 

func (*ServerPing) ProtoMessage()

func (*ServerPing) ProtoReflect added in v1.7.1 

func (x *ServerPing) ProtoReflect() protoreflect.Message

func (*ServerPing) Reset added in v1.7.1 

func (x *ServerPing) Reset()

func (*ServerPing) String added in v1.7.1 

func (x *ServerPing) String() string

func (*ServerPing) Validate added in v1.7.1 

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 added in v1.7.1 

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 added in v1.7.1 

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 added in v1.7.1 

func (m ServerPingMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ServerPingMultiError) Error added in v1.7.1 

func (m ServerPingMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ServerPingValidationError added in v1.7.1 

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 added in v1.7.1 

func (e ServerPingValidationError) Cause() error

Cause function returns cause value.

func (ServerPingValidationError) Error added in v1.7.1 

func (e ServerPingValidationError) Error() string

Error satisfies the builtin error interface

func (ServerPingValidationError) ErrorName added in v1.7.1 

func (e ServerPingValidationError) ErrorName() string

ErrorName returns error name.

func (ServerPingValidationError) Field added in v1.7.1 

func (e ServerPingValidationError) Field() string

Field function returns field value.

func (ServerPingValidationError) Key added in v1.7.1 

func (e ServerPingValidationError) Key() bool

Key function returns key value.

func (ServerPingValidationError) Reason added in v1.7.1 

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) Enum 

func (x StreamEventsResponse_StreamError_Code) Enum() *StreamEventsResponse_StreamError_Code

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 added in v1.6.6 

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 added in v1.6.6 

func (*TestEvent) Descriptor() ([]byte, []int)

Deprecated: Use TestEvent.ProtoReflect.Descriptor instead.

func (*TestEvent) GetHops added in v1.6.6 

func (x *TestEvent) GetHops() []string

func (*TestEvent) GetNonce added in v1.6.6 

func (x *TestEvent) GetNonce() uint64

func (*TestEvent) ProtoMessage added in v1.6.6 

func (*TestEvent) ProtoMessage()

func (*TestEvent) ProtoReflect added in v1.6.6 

func (x *TestEvent) ProtoReflect() protoreflect.Message

func (*TestEvent) Reset added in v1.6.6 

func (x *TestEvent) Reset()

func (*TestEvent) String added in v1.6.6 

func (x *TestEvent) String() string

func (*TestEvent) Validate added in v1.6.6 

func (m *TestEvent) Validate() error

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 added in v1.6.6 

func (m *TestEvent) ValidateAll() error

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 added in v1.6.6 

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 added in v1.6.6 

func (m TestEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TestEventMultiError) Error added in v1.6.6 

func (m TestEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TestEventValidationError added in v1.6.6 

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 added in v1.6.6 

func (e TestEventValidationError) Cause() error

Cause function returns cause value.

func (TestEventValidationError) Error added in v1.6.6 

func (e TestEventValidationError) Error() string

Error satisfies the builtin error interface

func (TestEventValidationError) ErrorName added in v1.6.6 

func (e TestEventValidationError) ErrorName() string

ErrorName returns error name.

func (TestEventValidationError) Field added in v1.6.6 

func (e TestEventValidationError) Field() string

Field function returns field value.

func (TestEventValidationError) Key added in v1.6.6 

func (e TestEventValidationError) Key() bool

Key function returns key value.

func (TestEventValidationError) Reason added in v1.6.6 

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 added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

func (*UserEvent) Descriptor() ([]byte, []int)

Deprecated: Use UserEvent.ProtoReflect.Descriptor instead.

func (*UserEvent) GetEvent added in v1.6.2 

func (x *UserEvent) GetEvent() *Event

func (*UserEvent) GetUserId added in v1.6.2 

func (x *UserEvent) GetUserId() *v1.UserId

func (*UserEvent) ProtoMessage added in v1.6.2 

func (*UserEvent) ProtoMessage()

func (*UserEvent) ProtoReflect added in v1.6.2 

func (x *UserEvent) ProtoReflect() protoreflect.Message

func (*UserEvent) Reset added in v1.6.2 

func (x *UserEvent) Reset()

func (*UserEvent) String added in v1.6.2 

func (x *UserEvent) String() string

func (*UserEvent) Validate added in v1.6.2 

func (m *UserEvent) Validate() error

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 added in v1.6.2 

func (m *UserEvent) ValidateAll() error

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 added in v1.6.2 

type UserEventBatch struct {
	Events []*UserEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*UserEventBatch) Descriptor deprecated added in v1.6.2 

func (*UserEventBatch) Descriptor() ([]byte, []int)

Deprecated: Use UserEventBatch.ProtoReflect.Descriptor instead.

func (*UserEventBatch) GetEvents added in v1.6.2 

func (x *UserEventBatch) GetEvents() []*UserEvent

func (*UserEventBatch) ProtoMessage added in v1.6.2 

func (*UserEventBatch) ProtoMessage()

func (*UserEventBatch) ProtoReflect added in v1.6.2 

func (x *UserEventBatch) ProtoReflect() protoreflect.Message

func (*UserEventBatch) Reset added in v1.6.2 

func (x *UserEventBatch) Reset()

func (*UserEventBatch) String added in v1.6.2 

func (x *UserEventBatch) String() string

func (*UserEventBatch) Validate added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

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 added in v1.6.2 

func (m UserEventBatchMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UserEventBatchMultiError) Error added in v1.6.2 

func (m UserEventBatchMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UserEventBatchValidationError added in v1.6.2 

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 added in v1.6.2 

func (e UserEventBatchValidationError) Cause() error

Cause function returns cause value.

func (UserEventBatchValidationError) Error added in v1.6.2 

func (e UserEventBatchValidationError) Error() string

Error satisfies the builtin error interface

func (UserEventBatchValidationError) ErrorName added in v1.6.2 

func (e UserEventBatchValidationError) ErrorName() string

ErrorName returns error name.

func (UserEventBatchValidationError) Field added in v1.6.2 

func (e UserEventBatchValidationError) Field() string

Field function returns field value.

func (UserEventBatchValidationError) Key added in v1.6.2 

func (e UserEventBatchValidationError) Key() bool

Key function returns key value.

func (UserEventBatchValidationError) Reason added in v1.6.2 

func (e UserEventBatchValidationError) Reason() string

Reason function returns reason value.

type UserEventMultiError added in v1.6.2 

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 added in v1.6.2 

func (m UserEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UserEventMultiError) Error added in v1.6.2 

func (m UserEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type UserEventValidationError added in v1.6.2 

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 added in v1.6.2 

func (e UserEventValidationError) Cause() error

Cause function returns cause value.

func (UserEventValidationError) Error added in v1.6.2 

func (e UserEventValidationError) Error() string

Error satisfies the builtin error interface

func (UserEventValidationError) ErrorName added in v1.6.2 

func (e UserEventValidationError) ErrorName() string

ErrorName returns error name.

func (UserEventValidationError) Field added in v1.6.2 

func (e UserEventValidationError) Field() string

Field function returns field value.

func (UserEventValidationError) Key added in v1.6.2 

func (e UserEventValidationError) Key() bool

Key function returns key value.

func (UserEventValidationError) Reason added in v1.6.2 

func (e UserEventValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.