eventpb

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Jul 16, 2025 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source 
var (
	StreamEventsResponse_StreamError_Code_name = map[int32]string{
		0: "DENIED",
	}
	StreamEventsResponse_StreamError_Code_value = map[string]int32{
		"DENIED": 0,
	}
)

Enum value maps for StreamEventsResponse_StreamError_Code.

View Source 
var EventStreaming_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flipcash.event.v1.EventStreaming",
	HandlerType: (*EventStreamingServer)(nil),
	Methods:     []grpc.MethodDesc{},
	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 Event 

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

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

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

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
	// 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 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() *v1.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 *v1.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() *v1.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 *v1.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
)

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

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.