messaginggrpc

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Package messaginggrpc defines gRPC services for interacting with the messages produced and consumed by hosted Dogma applications, including executing commands and consuming event streams.

Index

Constants

View Source 
const (
	EventStreamConsumerAPI_ListEventStreams_FullMethodName = "/dogma.messaging.v1.EventStreamConsumerAPI/ListEventStreams"
	EventStreamConsumerAPI_ConsumeEvents_FullMethodName    = "/dogma.messaging.v1.EventStreamConsumerAPI/ConsumeEvents"
)
View Source 
const (
	CommandExecutorAPI_ExecuteCommand_FullMethodName = "/dogma.messaging.v1.CommandExecutorAPI/ExecuteCommand"
)
View Source 
const ExecuteCommandResponse_CommandAccepted_case case_ExecuteCommandResponse_Operation = 1
View Source 
const ExecuteCommandResponse_EventRecorded_case case_ExecuteCommandResponse_Operation = 2
View Source 
const ExecuteCommandResponse_Operation_not_set_case case_ExecuteCommandResponse_Operation = 0

Variables

View Source 
var CommandExecutorAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dogma.messaging.v1.CommandExecutorAPI",
	HandlerType: (*CommandExecutorAPIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteCommand",
			Handler:       _CommandExecutorAPI_ExecuteCommand_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "github.com/dogmatiq/enginekit/grpc/messaginggrpc/commandexecutor.proto",
}

CommandExecutorAPI_ServiceDesc is the grpc.ServiceDesc for CommandExecutorAPI 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 EventStreamConsumerAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dogma.messaging.v1.EventStreamConsumerAPI",
	HandlerType: (*EventStreamConsumerAPIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListEventStreams",
			Handler:       _EventStreamConsumerAPI_ListEventStreams_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ConsumeEvents",
			Handler:       _EventStreamConsumerAPI_ConsumeEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "github.com/dogmatiq/enginekit/grpc/messaginggrpc/eventstreamconsumer.proto",
}

EventStreamConsumerAPI_ServiceDesc is the grpc.ServiceDesc for EventStreamConsumerAPI 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_github_com_dogmatiq_enginekit_grpc_messaginggrpc_commandexecutor_proto protoreflect.FileDescriptor
View Source 
var File_github_com_dogmatiq_enginekit_grpc_messaginggrpc_errors_proto protoreflect.FileDescriptor
View Source 
var File_github_com_dogmatiq_enginekit_grpc_messaginggrpc_eventstreamconsumer_proto protoreflect.FileDescriptor

Functions

func InvalidMessageError 

func InvalidMessageError(id *uuidpb.UUID, reason string) error

InvalidMessageError returns an error indicating that a message of the given type failed the application's validation logic. reason is a human-readable description of the validation failure.

func MalformedMessageError 

func MalformedMessageError(id *uuidpb.UUID) error

MalformedMessageError returns an error indicating that a message's binary data could not be unmarshaled as the given message type.

func Map_ExecuteCommandResponse_Operation 

func Map_ExecuteCommandResponse_Operation[T any](
	x *ExecuteCommandResponse,
	caseCommandAccepted func(*ExecuteCommandResponse_CommandAccepted) T,
	caseEventRecorded func(*ExecuteCommandResponse_EventRecorded) T,
	none func() T,
) T

Map_ExecuteCommandResponse_Operation maps x.Operation to a value of type T by invoking one of the given functions.

It invokes the function that corresponds to the value of x.Operation, and returns that function's result. It calls none() if x.Operation is nil.

func MustMap_ExecuteCommandResponse_Operation 

func MustMap_ExecuteCommandResponse_Operation[T any](
	x *ExecuteCommandResponse,
	caseCommandAccepted func(*ExecuteCommandResponse_CommandAccepted) T,
	caseEventRecorded func(*ExecuteCommandResponse_EventRecorded) T,
) T

MustMap_ExecuteCommandResponse_Operation maps x.Operation to a value of type T by invoking one of the given functions.

It invokes the function that corresponds to the value of x.Operation, and returns that function's result. It panics if x.Operation is nil.

func MustSwitch_ExecuteCommandResponse_Operation 

func MustSwitch_ExecuteCommandResponse_Operation(
	x *ExecuteCommandResponse,
	caseCommandAccepted func(*ExecuteCommandResponse_CommandAccepted),
	caseEventRecorded func(*ExecuteCommandResponse_EventRecorded),
)

MustSwitch_ExecuteCommandResponse_Operation invokes one of the given functions based on the value of x.Operation.

It panics if x.Operation is nil.

func RegisterCommandExecutorAPIServer 

func RegisterCommandExecutorAPIServer(s grpc.ServiceRegistrar, srv CommandExecutorAPIServer)

func RegisterEventStreamConsumerAPIServer 

func RegisterEventStreamConsumerAPIServer(s grpc.ServiceRegistrar, srv EventStreamConsumerAPIServer)

func Switch_ExecuteCommandResponse_Operation 

func Switch_ExecuteCommandResponse_Operation(
	x *ExecuteCommandResponse,
	caseCommandAccepted func(*ExecuteCommandResponse_CommandAccepted),
	caseEventRecorded func(*ExecuteCommandResponse_EventRecorded),
	none func(),
)

Switch_ExecuteCommandResponse_Operation invokes one of the given functions based on the value of x.Operation.

It calls none() if x.Operation is nil.

func UnrecognizedApplicationError 

func UnrecognizedApplicationError(key *uuidpb.UUID) error

UnrecognizedApplicationError returns an error indicating that the given application is not recognized by the server.

func UnrecognizedCommandTypeError 

func UnrecognizedCommandTypeError(id *uuidpb.UUID) error

UnrecognizedCommandTypeError returns an error indicating that the given command type is not recognized by the server, or is not executable within the target application.

func UnrecognizedEventStreamError 

func UnrecognizedEventStreamError(id *uuidpb.UUID) error

UnrecognizedEventStreamError returns an error indicating that the given stream is not recognized by the server.

func UnrecognizedEventTypeError 

func UnrecognizedEventTypeError(id *uuidpb.UUID) error

UnrecognizedEventTypeError returns an error indicating that the given event type is not recognized by the server.

Types

type CommandExecutorAPIClient 

type CommandExecutorAPIClient interface {
	// ExecuteCommand submits a command for execution, and optionally observes
	// the events that are recorded as a result of executing it.
	//
	// If the requested application key is unknown to the server it MUST return
	// a NOT_FOUND error with an attached [UnrecognizedApplication] value. See
	// [UnrecognizedApplicationError].
	//
	// If the requested command type ID does not identify a command that is
	// executable within the target application the server MUST return an
	// INVALID_ARGUMENT error with an attached [UnrecognizedCommandType] value.
	// See [UnrecognizedCommandTypeError].
	//
	// If the command data cannot be unmarshaled the server MUST return an
	// INVALID_ARGUMENT error with an attached [MalformedMessage] value. See
	// [MalformedMessageError].
	//
	// If the command is well-formed but fails the application's validation
	// logic the server MUST return an INVALID_ARGUMENT error with an attached
	// [InvalidMessage] value. See [InvalidMessageError].
	//
	// The requested event type IDs MUST identify event types that may be
	// recorded by the target application. If any other type IDs are requested
	// the server MUST return an INVALID_ARGUMENT error with an attached
	// [UnrecognizedEventType] value for each unrecognized type ID. See
	// [UnrecognizedEventTypeError].
	//
	// The first response MUST be a [CommandAccepted] operation, sent once the
	// engine has taken ownership of the command. Ownership means that the
	// command has been durably accepted for execution; it does not mean that
	// handling of the command is complete.
	//
	// Subsequent responses each deliver a single event that was recorded as a
	// result of executing the command and that matches one of the requested
	// event type IDs. If no event type IDs are requested the server MUST end
	// the stream immediately after sending the [CommandAccepted] operation.
	//
	// The server MUST end the stream with an OK status once it determines that
	// no further relevant events can occur. Any other outcome, such as a
	// network failure or server shutdown, leaves the client unable to resume
	// observation; the client may re-execute the command using the same
	// idempotency key to confirm its acceptance.
	//
	// If the command is a duplicate, as identified by its idempotency key, the
	// server MUST NOT execute it again, but MUST still send a [CommandAccepted]
	// operation. The server SHOULD deliver the relevant events recorded by the
	// original execution, but MAY end the stream immediately if it is unable to
	// determine which events those are.
	ExecuteCommand(ctx context.Context, in *ExecuteCommandRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExecuteCommandResponse], error)
}

CommandExecutorAPIClient is the client API for CommandExecutorAPI 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.

CommandExecutorAPI is a service for executing commands within a Dogma application hosted by the engine on the server.

func NewCommandExecutorAPIClient 

func NewCommandExecutorAPIClient(cc grpc.ClientConnInterface) CommandExecutorAPIClient

type CommandExecutorAPIClientStub 

type CommandExecutorAPIClientStub struct {
	// ExecuteCommandFunc is a function that implements the ExecuteCommand RPC method.
	ExecuteCommandFunc func(ctx context.Context, req *ExecuteCommandRequest, options ...grpc.CallOption) (CommandExecutorAPI_ExecuteCommandClient, error)
}

func (*CommandExecutorAPIClientStub) ExecuteCommand 

func (c *CommandExecutorAPIClientStub) ExecuteCommand(ctx context.Context, req *ExecuteCommandRequest, options ...grpc.CallOption) (CommandExecutorAPI_ExecuteCommandClient, error)

ExecuteCommand calls c.ExecuteCommandFunc if it is non-nil. Otherwise, it returns an error.

type CommandExecutorAPIServer 

type CommandExecutorAPIServer interface {
	// ExecuteCommand submits a command for execution, and optionally observes
	// the events that are recorded as a result of executing it.
	//
	// If the requested application key is unknown to the server it MUST return
	// a NOT_FOUND error with an attached [UnrecognizedApplication] value. See
	// [UnrecognizedApplicationError].
	//
	// If the requested command type ID does not identify a command that is
	// executable within the target application the server MUST return an
	// INVALID_ARGUMENT error with an attached [UnrecognizedCommandType] value.
	// See [UnrecognizedCommandTypeError].
	//
	// If the command data cannot be unmarshaled the server MUST return an
	// INVALID_ARGUMENT error with an attached [MalformedMessage] value. See
	// [MalformedMessageError].
	//
	// If the command is well-formed but fails the application's validation
	// logic the server MUST return an INVALID_ARGUMENT error with an attached
	// [InvalidMessage] value. See [InvalidMessageError].
	//
	// The requested event type IDs MUST identify event types that may be
	// recorded by the target application. If any other type IDs are requested
	// the server MUST return an INVALID_ARGUMENT error with an attached
	// [UnrecognizedEventType] value for each unrecognized type ID. See
	// [UnrecognizedEventTypeError].
	//
	// The first response MUST be a [CommandAccepted] operation, sent once the
	// engine has taken ownership of the command. Ownership means that the
	// command has been durably accepted for execution; it does not mean that
	// handling of the command is complete.
	//
	// Subsequent responses each deliver a single event that was recorded as a
	// result of executing the command and that matches one of the requested
	// event type IDs. If no event type IDs are requested the server MUST end
	// the stream immediately after sending the [CommandAccepted] operation.
	//
	// The server MUST end the stream with an OK status once it determines that
	// no further relevant events can occur. Any other outcome, such as a
	// network failure or server shutdown, leaves the client unable to resume
	// observation; the client may re-execute the command using the same
	// idempotency key to confirm its acceptance.
	//
	// If the command is a duplicate, as identified by its idempotency key, the
	// server MUST NOT execute it again, but MUST still send a [CommandAccepted]
	// operation. The server SHOULD deliver the relevant events recorded by the
	// original execution, but MAY end the stream immediately if it is unable to
	// determine which events those are.
	ExecuteCommand(*ExecuteCommandRequest, grpc.ServerStreamingServer[ExecuteCommandResponse]) error
}

CommandExecutorAPIServer is the server API for CommandExecutorAPI service. All implementations should embed UnimplementedCommandExecutorAPIServer for forward compatibility.

CommandExecutorAPI is a service for executing commands within a Dogma application hosted by the engine on the server.

type CommandExecutorAPI_ExecuteCommandClient 

type CommandExecutorAPI_ExecuteCommandClient = grpc.ServerStreamingClient[ExecuteCommandResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CommandExecutorAPI_ExecuteCommandServer 

type CommandExecutorAPI_ExecuteCommandServer = grpc.ServerStreamingServer[ExecuteCommandResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ConsumeEventsRequest 

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

ConsumeEventsRequest is the input to the [EventStreamConsumerAPI.ConsumeEvents] method.

func (*ConsumeEventsRequest) ClearEventStreamId 

func (x *ConsumeEventsRequest) ClearEventStreamId()

func (*ConsumeEventsRequest) Format 

func (x *ConsumeEventsRequest) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ConsumeEventsRequest) GetCheckpointOffset 

func (x *ConsumeEventsRequest) GetCheckpointOffset() uint64

func (*ConsumeEventsRequest) GetEventStreamId 

func (x *ConsumeEventsRequest) GetEventStreamId() *uuidpb.UUID

func (*ConsumeEventsRequest) GetMessageTypeIds 

func (x *ConsumeEventsRequest) GetMessageTypeIds() []*uuidpb.UUID

func (*ConsumeEventsRequest) HasEventStreamId 

func (x *ConsumeEventsRequest) HasEventStreamId() bool

func (*ConsumeEventsRequest) MarshalBinary 

func (x *ConsumeEventsRequest) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ConsumeEventsRequest to implement encoding.BinaryMarshaler.

func (*ConsumeEventsRequest) ProtoMessage 

func (*ConsumeEventsRequest) ProtoMessage()

func (*ConsumeEventsRequest) ProtoReflect 

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

func (*ConsumeEventsRequest) Reset 

func (x *ConsumeEventsRequest) Reset()

func (*ConsumeEventsRequest) SetCheckpointOffset 

func (x *ConsumeEventsRequest) SetCheckpointOffset(v uint64)

func (*ConsumeEventsRequest) SetEventStreamId 

func (x *ConsumeEventsRequest) SetEventStreamId(v *uuidpb.UUID)

func (*ConsumeEventsRequest) SetMessageTypeIds 

func (x *ConsumeEventsRequest) SetMessageTypeIds(v []*uuidpb.UUID)

func (*ConsumeEventsRequest) String 

func (x *ConsumeEventsRequest) String() string

func (*ConsumeEventsRequest) UnmarshalBinary 

func (x *ConsumeEventsRequest) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ConsumeEventsRequest to implement encoding.BinaryUnmarshaler.

type ConsumeEventsRequestBuilder 

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

func NewConsumeEventsRequestBuilder 

func NewConsumeEventsRequestBuilder() *ConsumeEventsRequestBuilder

NewConsumeEventsRequestBuilder returns a builder that constructs ConsumeEventsRequest messages.

func (*ConsumeEventsRequestBuilder) Build 

func (b *ConsumeEventsRequestBuilder) Build() *ConsumeEventsRequest

Build returns a new ConsumeEventsRequest containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ConsumeEventsRequestBuilder) From 

func (b *ConsumeEventsRequestBuilder) From(x *ConsumeEventsRequest) *ConsumeEventsRequestBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ConsumeEventsRequestBuilder) WithCheckpointOffset 

func (b *ConsumeEventsRequestBuilder) WithCheckpointOffset(v uint64) *ConsumeEventsRequestBuilder

WithCheckpointOffset configures the builder to set the CheckpointOffset field to v, then returns b.

func (*ConsumeEventsRequestBuilder) WithEventStreamId 

func (b *ConsumeEventsRequestBuilder) WithEventStreamId(v *uuidpb.UUID) *ConsumeEventsRequestBuilder

WithEventStreamId configures the builder to set the EventStreamId field to v, then returns b.

func (*ConsumeEventsRequestBuilder) WithMessageTypeIds 

func (b *ConsumeEventsRequestBuilder) WithMessageTypeIds(v []*uuidpb.UUID) *ConsumeEventsRequestBuilder

WithMessageTypeIds configures the builder to set the MessageTypeIds field to v, then returns b.

type ConsumeEventsRequest_builder 

type ConsumeEventsRequest_builder struct {

	// EventStreamId is the ID from which events are consumed.
	EventStreamId *uuidpb.UUID
	// CheckpointOffset is the offset at which the consumer begins.
	CheckpointOffset uint64
	// MessageTypeIds is the set of message type IDs of the event types to
	// include in the responses.
	MessageTypeIds []*uuidpb.UUID
	// contains filtered or unexported fields
}

func (ConsumeEventsRequest_builder) Build 

func (b0 ConsumeEventsRequest_builder) Build() *ConsumeEventsRequest

type ConsumeEventsResponse 

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

ConsumeEventsResponse is the (streaming) output of the [EventStreamConsumerAPI.ConsumeEvents] method.

It contains all of the events that match the requested message type IDs specified in the ConsumeEventsRequest, starting at the checkpoint offset up to, but not including, the checkpoint offset in this response.

The list of events may be empty, indicating that there are no matching events in that range.

func (*ConsumeEventsResponse) Format 

func (x *ConsumeEventsResponse) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ConsumeEventsResponse) GetCheckpointOffset 

func (x *ConsumeEventsResponse) GetCheckpointOffset() uint64

func (*ConsumeEventsResponse) GetEnvelopes 

func (x *ConsumeEventsResponse) GetEnvelopes() []*envelopepb.MultiEnvelope

func (*ConsumeEventsResponse) MarshalBinary 

func (x *ConsumeEventsResponse) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ConsumeEventsResponse to implement encoding.BinaryMarshaler.

func (*ConsumeEventsResponse) ProtoMessage 

func (*ConsumeEventsResponse) ProtoMessage()

func (*ConsumeEventsResponse) ProtoReflect 

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

func (*ConsumeEventsResponse) Reset 

func (x *ConsumeEventsResponse) Reset()

func (*ConsumeEventsResponse) SetCheckpointOffset 

func (x *ConsumeEventsResponse) SetCheckpointOffset(v uint64)

func (*ConsumeEventsResponse) SetEnvelopes 

func (x *ConsumeEventsResponse) SetEnvelopes(v []*envelopepb.MultiEnvelope)

func (*ConsumeEventsResponse) String 

func (x *ConsumeEventsResponse) String() string

func (*ConsumeEventsResponse) UnmarshalBinary 

func (x *ConsumeEventsResponse) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ConsumeEventsResponse to implement encoding.BinaryUnmarshaler.

type ConsumeEventsResponseBuilder 

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

func NewConsumeEventsResponseBuilder 

func NewConsumeEventsResponseBuilder() *ConsumeEventsResponseBuilder

NewConsumeEventsResponseBuilder returns a builder that constructs ConsumeEventsResponse messages.

func (*ConsumeEventsResponseBuilder) Build 

func (b *ConsumeEventsResponseBuilder) Build() *ConsumeEventsResponse

Build returns a new ConsumeEventsResponse containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ConsumeEventsResponseBuilder) From 

func (b *ConsumeEventsResponseBuilder) From(x *ConsumeEventsResponse) *ConsumeEventsResponseBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ConsumeEventsResponseBuilder) WithCheckpointOffset 

func (b *ConsumeEventsResponseBuilder) WithCheckpointOffset(v uint64) *ConsumeEventsResponseBuilder

WithCheckpointOffset configures the builder to set the CheckpointOffset field to v, then returns b.

func (*ConsumeEventsResponseBuilder) WithEnvelopes 

func (b *ConsumeEventsResponseBuilder) WithEnvelopes(v []*envelopepb.MultiEnvelope) *ConsumeEventsResponseBuilder

WithEnvelopes configures the builder to set the Envelopes field to v, then returns b.

type ConsumeEventsResponse_builder 

type ConsumeEventsResponse_builder struct {

	// CheckpointOffset is the offset immediately after the range of the
	// stream described by this response.
	//
	// After handling this and all preceding responses, the client may use
	// this value as the checkpoint offset to resume consuming from the
	// stream in a subsequent [ConsumeEventsRequest].
	CheckpointOffset uint64
	// Envelopes is a (possibly empty) list of multi-envelopes containing
	// events at offsets between the prior checkpoint offset and the
	// checkpoint offset in this response.
	//
	// Each envelope includes the [envelopepb.EventStreamPosition] extension.
	//
	// The envelopes are ordered by the offset of the events they contain.
	// There is no additional relationship implied between envelopes that
	// appear in the same response.
	//
	// The offsets of the events within this response, or even within a
	// single [envelopepb.MultiEnvelope] are not necessarily contiguous.
	Envelopes []*envelopepb.MultiEnvelope
	// contains filtered or unexported fields
}

func (ConsumeEventsResponse_builder) Build 

func (b0 ConsumeEventsResponse_builder) Build() *ConsumeEventsResponse

type EventStream 

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

EventStream describes an offset-based ordered event stream.

func (*EventStream) ClearEventStreamId 

func (x *EventStream) ClearEventStreamId()

func (*EventStream) Format 

func (x *EventStream) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*EventStream) GetEventStreamId 

func (x *EventStream) GetEventStreamId() *uuidpb.UUID

func (*EventStream) GetNextOffset 

func (x *EventStream) GetNextOffset() uint64

func (*EventStream) HasEventStreamId 

func (x *EventStream) HasEventStreamId() bool

func (*EventStream) MarshalBinary 

func (x *EventStream) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *EventStream to implement encoding.BinaryMarshaler.

func (*EventStream) ProtoMessage 

func (*EventStream) ProtoMessage()

func (*EventStream) ProtoReflect 

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

func (*EventStream) Reset 

func (x *EventStream) Reset()

func (*EventStream) SetEventStreamId 

func (x *EventStream) SetEventStreamId(v *uuidpb.UUID)

func (*EventStream) SetNextOffset 

func (x *EventStream) SetNextOffset(v uint64)

func (*EventStream) String 

func (x *EventStream) String() string

func (*EventStream) UnmarshalBinary 

func (x *EventStream) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *EventStream to implement encoding.BinaryUnmarshaler.

type EventStreamBuilder 

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

func NewEventStreamBuilder 

func NewEventStreamBuilder() *EventStreamBuilder

NewEventStreamBuilder returns a builder that constructs EventStream messages.

func (*EventStreamBuilder) Build 

func (b *EventStreamBuilder) Build() *EventStream

Build returns a new EventStream containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*EventStreamBuilder) From 

func (b *EventStreamBuilder) From(x *EventStream) *EventStreamBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*EventStreamBuilder) WithEventStreamId 

func (b *EventStreamBuilder) WithEventStreamId(v *uuidpb.UUID) *EventStreamBuilder

WithEventStreamId configures the builder to set the EventStreamId field to v, then returns b.

func (*EventStreamBuilder) WithNextOffset 

func (b *EventStreamBuilder) WithNextOffset(v uint64) *EventStreamBuilder

WithNextOffset configures the builder to set the NextOffset field to v, then returns b.

type EventStreamConsumerAPIClient 

type EventStreamConsumerAPIClient interface {
	// ListEventStreams returns the event streams offered by the server.
	ListEventStreams(ctx context.Context, in *ListEventStreamsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ListEventStreamsResponse], error)
	// ConsumeEvents returns event messages from a single stream, in order,
	// starting from a specific offset within an event stream.
	//
	// The server delivers every event at or after the requested checkpoint offset
	// whose message type ID is among those in the [ConsumeEventsRequest]. If no
	// such events remain in the event stream, and the server cannot produce new
	// events with any of the requested message type IDs, it closes the gRPC
	// stream.
	//
	// If the requested stream ID is not recognized the server MUST return a
	// NOT_FOUND error with an attached [UnrecognizedEventStream] value. See
	// [UnrecognizedEventStreamError].
	//
	// If the requested offset is beyond the end of the stream an OUT_OF_RANGE
	// error occurs.
	ConsumeEvents(ctx context.Context, in *ConsumeEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConsumeEventsResponse], error)
}

EventStreamConsumerAPIClient is the client API for EventStreamConsumerAPI 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.

EventStreamConsumerAPI is a service for consuming event messages from offset-based, ordered event streams.

func NewEventStreamConsumerAPIClient 

func NewEventStreamConsumerAPIClient(cc grpc.ClientConnInterface) EventStreamConsumerAPIClient

type EventStreamConsumerAPIClientStub 

type EventStreamConsumerAPIClientStub struct {
	// ListEventStreamsFunc is a function that implements the ListEventStreams RPC method.
	ListEventStreamsFunc func(ctx context.Context, req *ListEventStreamsRequest, options ...grpc.CallOption) (EventStreamConsumerAPI_ListEventStreamsClient, error)

	// ConsumeEventsFunc is a function that implements the ConsumeEvents RPC method.
	ConsumeEventsFunc func(ctx context.Context, req *ConsumeEventsRequest, options ...grpc.CallOption) (EventStreamConsumerAPI_ConsumeEventsClient, error)
}

func (*EventStreamConsumerAPIClientStub) ConsumeEvents 

func (c *EventStreamConsumerAPIClientStub) ConsumeEvents(ctx context.Context, req *ConsumeEventsRequest, options ...grpc.CallOption) (EventStreamConsumerAPI_ConsumeEventsClient, error)

ConsumeEvents calls c.ConsumeEventsFunc if it is non-nil. Otherwise, it returns an error.

func (*EventStreamConsumerAPIClientStub) ListEventStreams 

func (c *EventStreamConsumerAPIClientStub) ListEventStreams(ctx context.Context, req *ListEventStreamsRequest, options ...grpc.CallOption) (EventStreamConsumerAPI_ListEventStreamsClient, error)

ListEventStreams calls c.ListEventStreamsFunc if it is non-nil. Otherwise, it returns an error.

type EventStreamConsumerAPIServer 

type EventStreamConsumerAPIServer interface {
	// ListEventStreams returns the event streams offered by the server.
	ListEventStreams(*ListEventStreamsRequest, grpc.ServerStreamingServer[ListEventStreamsResponse]) error
	// ConsumeEvents returns event messages from a single stream, in order,
	// starting from a specific offset within an event stream.
	//
	// The server delivers every event at or after the requested checkpoint offset
	// whose message type ID is among those in the [ConsumeEventsRequest]. If no
	// such events remain in the event stream, and the server cannot produce new
	// events with any of the requested message type IDs, it closes the gRPC
	// stream.
	//
	// If the requested stream ID is not recognized the server MUST return a
	// NOT_FOUND error with an attached [UnrecognizedEventStream] value. See
	// [UnrecognizedEventStreamError].
	//
	// If the requested offset is beyond the end of the stream an OUT_OF_RANGE
	// error occurs.
	ConsumeEvents(*ConsumeEventsRequest, grpc.ServerStreamingServer[ConsumeEventsResponse]) error
}

EventStreamConsumerAPIServer is the server API for EventStreamConsumerAPI service. All implementations should embed UnimplementedEventStreamConsumerAPIServer for forward compatibility.

EventStreamConsumerAPI is a service for consuming event messages from offset-based, ordered event streams.

type EventStreamConsumerAPI_ConsumeEventsClient 

type EventStreamConsumerAPI_ConsumeEventsClient = grpc.ServerStreamingClient[ConsumeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EventStreamConsumerAPI_ConsumeEventsServer 

type EventStreamConsumerAPI_ConsumeEventsServer = grpc.ServerStreamingServer[ConsumeEventsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EventStreamConsumerAPI_ListEventStreamsClient 

type EventStreamConsumerAPI_ListEventStreamsClient = grpc.ServerStreamingClient[ListEventStreamsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EventStreamConsumerAPI_ListEventStreamsServer 

type EventStreamConsumerAPI_ListEventStreamsServer = grpc.ServerStreamingServer[ListEventStreamsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EventStream_builder 

type EventStream_builder struct {

	// EventStreamId is a unique identifier for the stream.
	EventStreamId *uuidpb.UUID
	// NextOffset is the offset of the next event that will be written to the
	// stream. The first event in the stream is at offset zero; therefore,
	// this value is equivalent to the number of events that have been written
	// to the stream.
	NextOffset uint64
	// contains filtered or unexported fields
}

func (EventStream_builder) Build 

func (b0 EventStream_builder) Build() *EventStream

type ExecuteCommandRequest 

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

ExecuteCommandRequest is the input to the [CommandExecutorAPI.ExecuteCommand] method.

func (*ExecuteCommandRequest) ClearApplicationKey 

func (x *ExecuteCommandRequest) ClearApplicationKey()

func (*ExecuteCommandRequest) ClearMessageTypeId 

func (x *ExecuteCommandRequest) ClearMessageTypeId()

func (*ExecuteCommandRequest) Format 

func (x *ExecuteCommandRequest) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ExecuteCommandRequest) GetApplicationKey 

func (x *ExecuteCommandRequest) GetApplicationKey() *uuidpb.UUID

func (*ExecuteCommandRequest) GetData 

func (x *ExecuteCommandRequest) GetData() []byte

func (*ExecuteCommandRequest) GetIdempotencyKey 

func (x *ExecuteCommandRequest) GetIdempotencyKey() string

func (*ExecuteCommandRequest) GetMessageTypeId 

func (x *ExecuteCommandRequest) GetMessageTypeId() *uuidpb.UUID

func (*ExecuteCommandRequest) GetObservedMessageTypeIds 

func (x *ExecuteCommandRequest) GetObservedMessageTypeIds() []*uuidpb.UUID

func (*ExecuteCommandRequest) HasApplicationKey 

func (x *ExecuteCommandRequest) HasApplicationKey() bool

func (*ExecuteCommandRequest) HasMessageTypeId 

func (x *ExecuteCommandRequest) HasMessageTypeId() bool

func (*ExecuteCommandRequest) MarshalBinary 

func (x *ExecuteCommandRequest) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ExecuteCommandRequest to implement encoding.BinaryMarshaler.

func (*ExecuteCommandRequest) ProtoMessage 

func (*ExecuteCommandRequest) ProtoMessage()

func (*ExecuteCommandRequest) ProtoReflect 

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

func (*ExecuteCommandRequest) Reset 

func (x *ExecuteCommandRequest) Reset()

func (*ExecuteCommandRequest) SetApplicationKey 

func (x *ExecuteCommandRequest) SetApplicationKey(v *uuidpb.UUID)

func (*ExecuteCommandRequest) SetData 

func (x *ExecuteCommandRequest) SetData(v []byte)

func (*ExecuteCommandRequest) SetIdempotencyKey 

func (x *ExecuteCommandRequest) SetIdempotencyKey(v string)

func (*ExecuteCommandRequest) SetMessageTypeId 

func (x *ExecuteCommandRequest) SetMessageTypeId(v *uuidpb.UUID)

func (*ExecuteCommandRequest) SetObservedMessageTypeIds 

func (x *ExecuteCommandRequest) SetObservedMessageTypeIds(v []*uuidpb.UUID)

func (*ExecuteCommandRequest) String 

func (x *ExecuteCommandRequest) String() string

func (*ExecuteCommandRequest) UnmarshalBinary 

func (x *ExecuteCommandRequest) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ExecuteCommandRequest to implement encoding.BinaryUnmarshaler.

type ExecuteCommandRequestBuilder 

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

func NewExecuteCommandRequestBuilder 

func NewExecuteCommandRequestBuilder() *ExecuteCommandRequestBuilder

NewExecuteCommandRequestBuilder returns a builder that constructs ExecuteCommandRequest messages.

func (*ExecuteCommandRequestBuilder) Build 

func (b *ExecuteCommandRequestBuilder) Build() *ExecuteCommandRequest

Build returns a new ExecuteCommandRequest containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ExecuteCommandRequestBuilder) From 

func (b *ExecuteCommandRequestBuilder) From(x *ExecuteCommandRequest) *ExecuteCommandRequestBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ExecuteCommandRequestBuilder) WithApplicationKey 

func (b *ExecuteCommandRequestBuilder) WithApplicationKey(v *uuidpb.UUID) *ExecuteCommandRequestBuilder

WithApplicationKey configures the builder to set the ApplicationKey field to v, then returns b.

func (*ExecuteCommandRequestBuilder) WithData 

func (b *ExecuteCommandRequestBuilder) WithData(v []byte) *ExecuteCommandRequestBuilder

WithData configures the builder to set the Data field to v, then returns b.

func (*ExecuteCommandRequestBuilder) WithIdempotencyKey 

func (b *ExecuteCommandRequestBuilder) WithIdempotencyKey(v string) *ExecuteCommandRequestBuilder

WithIdempotencyKey configures the builder to set the IdempotencyKey field to v, then returns b.

func (*ExecuteCommandRequestBuilder) WithMessageTypeId 

func (b *ExecuteCommandRequestBuilder) WithMessageTypeId(v *uuidpb.UUID) *ExecuteCommandRequestBuilder

WithMessageTypeId configures the builder to set the MessageTypeId field to v, then returns b.

func (*ExecuteCommandRequestBuilder) WithObservedMessageTypeIds 

func (b *ExecuteCommandRequestBuilder) WithObservedMessageTypeIds(v []*uuidpb.UUID) *ExecuteCommandRequestBuilder

WithObservedMessageTypeIds configures the builder to set the ObservedMessageTypeIds field to v, then returns b.

type ExecuteCommandRequest_builder 

type ExecuteCommandRequest_builder struct {

	// ApplicationKey is the key of the application that is the target of the
	// command.
	ApplicationKey *uuidpb.UUID
	// MessageTypeId is a unique identifier for the command's message type, as
	// per the Dogma message type registry.
	MessageTypeId *uuidpb.UUID
	// Data is the binary command data obtained by calling
	// [dogma.Message.MarshalBinary] on the command.
	Data []byte
	// IdempotencyKey is an (optional) application-defined value used to
	// identify the command across retries.
	//
	// If it is non-empty, the server MUST NOT execute the command again if it
	// has already been executed with the same idempotency key.
	IdempotencyKey string
	// ObservedMessageTypeIds is a list of message type IDs identifying the events
	// to be observed as a result of executing the command. The client must be
	// explicit about the event types that it understands; there is no mechanism
	// to observe all event types.
	ObservedMessageTypeIds []*uuidpb.UUID
	// contains filtered or unexported fields
}

func (ExecuteCommandRequest_builder) Build 

func (b0 ExecuteCommandRequest_builder) Build() *ExecuteCommandRequest

type ExecuteCommandResponse 

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

ExecuteCommandResponse is the streaming output of the [CommandExecutorAPI.ExecuteCommand] method.

func (*ExecuteCommandResponse) ClearCommandAccepted 

func (x *ExecuteCommandResponse) ClearCommandAccepted()

func (*ExecuteCommandResponse) ClearEventRecorded 

func (x *ExecuteCommandResponse) ClearEventRecorded()

func (*ExecuteCommandResponse) ClearOperation 

func (x *ExecuteCommandResponse) ClearOperation()

func (*ExecuteCommandResponse) Format 

func (x *ExecuteCommandResponse) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ExecuteCommandResponse) GetCommandAccepted 

func (x *ExecuteCommandResponse) GetCommandAccepted() *ExecuteCommandResponse_CommandAccepted

func (*ExecuteCommandResponse) GetEventRecorded 

func (x *ExecuteCommandResponse) GetEventRecorded() *ExecuteCommandResponse_EventRecorded

func (*ExecuteCommandResponse) HasCommandAccepted 

func (x *ExecuteCommandResponse) HasCommandAccepted() bool

func (*ExecuteCommandResponse) HasEventRecorded 

func (x *ExecuteCommandResponse) HasEventRecorded() bool

func (*ExecuteCommandResponse) HasOperation 

func (x *ExecuteCommandResponse) HasOperation() bool

func (*ExecuteCommandResponse) MarshalBinary 

func (x *ExecuteCommandResponse) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ExecuteCommandResponse to implement encoding.BinaryMarshaler.

func (*ExecuteCommandResponse) ProtoMessage 

func (*ExecuteCommandResponse) ProtoMessage()

func (*ExecuteCommandResponse) ProtoReflect 

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

func (*ExecuteCommandResponse) Reset 

func (x *ExecuteCommandResponse) Reset()

func (*ExecuteCommandResponse) SetCommandAccepted 

func (x *ExecuteCommandResponse) SetCommandAccepted(v *ExecuteCommandResponse_CommandAccepted)

func (*ExecuteCommandResponse) SetEventRecorded 

func (x *ExecuteCommandResponse) SetEventRecorded(v *ExecuteCommandResponse_EventRecorded)

func (*ExecuteCommandResponse) String 

func (x *ExecuteCommandResponse) String() string

func (*ExecuteCommandResponse) TryGetCommandAccepted 

func (x *ExecuteCommandResponse) TryGetCommandAccepted() (v *ExecuteCommandResponse_CommandAccepted, ok bool)

TryGetCommandAccepted returns the CommandAccepted value if x.Operation is set to CommandAccepted. Otherwise, ok is false and v is the zero-value.

func (*ExecuteCommandResponse) TryGetEventRecorded 

func (x *ExecuteCommandResponse) TryGetEventRecorded() (v *ExecuteCommandResponse_EventRecorded, ok bool)

TryGetEventRecorded returns the EventRecorded value if x.Operation is set to EventRecorded. Otherwise, ok is false and v is the zero-value.

func (*ExecuteCommandResponse) UnmarshalBinary 

func (x *ExecuteCommandResponse) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ExecuteCommandResponse to implement encoding.BinaryUnmarshaler.

func (*ExecuteCommandResponse) WhichOperation 

func (x *ExecuteCommandResponse) WhichOperation() case_ExecuteCommandResponse_Operation

type ExecuteCommandResponseBuilder 

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

func NewExecuteCommandResponseBuilder 

func NewExecuteCommandResponseBuilder() *ExecuteCommandResponseBuilder

NewExecuteCommandResponseBuilder returns a builder that constructs ExecuteCommandResponse messages.

func (*ExecuteCommandResponseBuilder) Build 

func (b *ExecuteCommandResponseBuilder) Build() *ExecuteCommandResponse

Build returns a new ExecuteCommandResponse containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ExecuteCommandResponseBuilder) From 

func (b *ExecuteCommandResponseBuilder) From(x *ExecuteCommandResponse) *ExecuteCommandResponseBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ExecuteCommandResponseBuilder) WithCommandAccepted 

func (b *ExecuteCommandResponseBuilder) WithCommandAccepted(v *ExecuteCommandResponse_CommandAccepted) *ExecuteCommandResponseBuilder

WithCommandAccepted configures the builder to set the CommandAccepted field to v, then returns b.

func (*ExecuteCommandResponseBuilder) WithEventRecorded 

func (b *ExecuteCommandResponseBuilder) WithEventRecorded(v *ExecuteCommandResponse_EventRecorded) *ExecuteCommandResponseBuilder

WithEventRecorded configures the builder to set the EventRecorded field to v, then returns b.

type ExecuteCommandResponse_CommandAccepted 

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

CommandAccepted indicates that the engine has taken ownership of the command.

func (*ExecuteCommandResponse_CommandAccepted) Format 

func (x *ExecuteCommandResponse_CommandAccepted) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ExecuteCommandResponse_CommandAccepted) MarshalBinary 

func (x *ExecuteCommandResponse_CommandAccepted) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ExecuteCommandResponse_CommandAccepted to implement encoding.BinaryMarshaler.

func (*ExecuteCommandResponse_CommandAccepted) ProtoMessage 

func (*ExecuteCommandResponse_CommandAccepted) ProtoMessage()

func (*ExecuteCommandResponse_CommandAccepted) ProtoReflect 

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

func (*ExecuteCommandResponse_CommandAccepted) Reset 

func (x *ExecuteCommandResponse_CommandAccepted) Reset()

func (*ExecuteCommandResponse_CommandAccepted) String 

func (x *ExecuteCommandResponse_CommandAccepted) String() string

func (*ExecuteCommandResponse_CommandAccepted) UnmarshalBinary 

func (x *ExecuteCommandResponse_CommandAccepted) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ExecuteCommandResponse_CommandAccepted to implement encoding.BinaryUnmarshaler.

type ExecuteCommandResponse_CommandAcceptedBuilder 

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

func NewExecuteCommandResponse_CommandAcceptedBuilder 

func NewExecuteCommandResponse_CommandAcceptedBuilder() *ExecuteCommandResponse_CommandAcceptedBuilder

NewExecuteCommandResponse_CommandAcceptedBuilder returns a builder that constructs ExecuteCommandResponse_CommandAccepted messages.

func (*ExecuteCommandResponse_CommandAcceptedBuilder) Build 

func (b *ExecuteCommandResponse_CommandAcceptedBuilder) Build() *ExecuteCommandResponse_CommandAccepted

Build returns a new ExecuteCommandResponse_CommandAccepted containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ExecuteCommandResponse_CommandAcceptedBuilder) From 

func (b *ExecuteCommandResponse_CommandAcceptedBuilder) From(x *ExecuteCommandResponse_CommandAccepted) *ExecuteCommandResponse_CommandAcceptedBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

type ExecuteCommandResponse_CommandAccepted_builder 

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

func (ExecuteCommandResponse_CommandAccepted_builder) Build 

func (b0 ExecuteCommandResponse_CommandAccepted_builder) Build() *ExecuteCommandResponse_CommandAccepted

type ExecuteCommandResponse_EventRecorded 

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

EventRecorded represents the delivery of a single event that was recorded as a result of executing the command.

func (*ExecuteCommandResponse_EventRecorded) ClearEnvelope 

func (x *ExecuteCommandResponse_EventRecorded) ClearEnvelope()

func (*ExecuteCommandResponse_EventRecorded) Format 

func (x *ExecuteCommandResponse_EventRecorded) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ExecuteCommandResponse_EventRecorded) GetEnvelope 

func (x *ExecuteCommandResponse_EventRecorded) GetEnvelope() *envelopepb.Envelope

func (*ExecuteCommandResponse_EventRecorded) HasEnvelope 

func (x *ExecuteCommandResponse_EventRecorded) HasEnvelope() bool

func (*ExecuteCommandResponse_EventRecorded) MarshalBinary 

func (x *ExecuteCommandResponse_EventRecorded) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ExecuteCommandResponse_EventRecorded to implement encoding.BinaryMarshaler.

func (*ExecuteCommandResponse_EventRecorded) ProtoMessage 

func (*ExecuteCommandResponse_EventRecorded) ProtoMessage()

func (*ExecuteCommandResponse_EventRecorded) ProtoReflect 

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

func (*ExecuteCommandResponse_EventRecorded) Reset 

func (x *ExecuteCommandResponse_EventRecorded) Reset()

func (*ExecuteCommandResponse_EventRecorded) SetEnvelope 

func (x *ExecuteCommandResponse_EventRecorded) SetEnvelope(v *envelopepb.Envelope)

func (*ExecuteCommandResponse_EventRecorded) String 

func (x *ExecuteCommandResponse_EventRecorded) String() string

func (*ExecuteCommandResponse_EventRecorded) UnmarshalBinary 

func (x *ExecuteCommandResponse_EventRecorded) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ExecuteCommandResponse_EventRecorded to implement encoding.BinaryUnmarshaler.

type ExecuteCommandResponse_EventRecordedBuilder 

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

func NewExecuteCommandResponse_EventRecordedBuilder 

func NewExecuteCommandResponse_EventRecordedBuilder() *ExecuteCommandResponse_EventRecordedBuilder

NewExecuteCommandResponse_EventRecordedBuilder returns a builder that constructs ExecuteCommandResponse_EventRecorded messages.

func (*ExecuteCommandResponse_EventRecordedBuilder) Build 

func (b *ExecuteCommandResponse_EventRecordedBuilder) Build() *ExecuteCommandResponse_EventRecorded

Build returns a new ExecuteCommandResponse_EventRecorded containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ExecuteCommandResponse_EventRecordedBuilder) From 

func (b *ExecuteCommandResponse_EventRecordedBuilder) From(x *ExecuteCommandResponse_EventRecorded) *ExecuteCommandResponse_EventRecordedBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ExecuteCommandResponse_EventRecordedBuilder) WithEnvelope 

func (b *ExecuteCommandResponse_EventRecordedBuilder) WithEnvelope(v *envelopepb.Envelope) *ExecuteCommandResponse_EventRecordedBuilder

WithEnvelope configures the builder to set the Envelope field to v, then returns b.

type ExecuteCommandResponse_EventRecorded_builder 

type ExecuteCommandResponse_EventRecorded_builder struct {

	// Envelope is the envelope containing the event.
	Envelope *envelopepb.Envelope
	// contains filtered or unexported fields
}

func (ExecuteCommandResponse_EventRecorded_builder) Build 

func (b0 ExecuteCommandResponse_EventRecorded_builder) Build() *ExecuteCommandResponse_EventRecorded

type ExecuteCommandResponse_builder 

type ExecuteCommandResponse_builder struct {

	// Fields of oneof xxx_hidden_Operation:
	CommandAccepted *ExecuteCommandResponse_CommandAccepted
	EventRecorded   *ExecuteCommandResponse_EventRecorded
	// contains filtered or unexported fields
}

func (ExecuteCommandResponse_builder) Build 

func (b0 ExecuteCommandResponse_builder) Build() *ExecuteCommandResponse

type InvalidMessage 

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

InvalidMessage is an error-details value for INVALID_ARGUMENT errors that occurred because a message failed the application's validation logic.

func (*InvalidMessage) ClearMessageTypeId 

func (x *InvalidMessage) ClearMessageTypeId()

func (*InvalidMessage) Format 

func (x *InvalidMessage) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*InvalidMessage) GetMessageTypeId 

func (x *InvalidMessage) GetMessageTypeId() *uuidpb.UUID

func (*InvalidMessage) HasMessageTypeId 

func (x *InvalidMessage) HasMessageTypeId() bool

func (*InvalidMessage) MarshalBinary 

func (x *InvalidMessage) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *InvalidMessage to implement encoding.BinaryMarshaler.

func (*InvalidMessage) ProtoMessage 

func (*InvalidMessage) ProtoMessage()

func (*InvalidMessage) ProtoReflect 

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

func (*InvalidMessage) Reset 

func (x *InvalidMessage) Reset()

func (*InvalidMessage) SetMessageTypeId 

func (x *InvalidMessage) SetMessageTypeId(v *uuidpb.UUID)

func (*InvalidMessage) String 

func (x *InvalidMessage) String() string

func (*InvalidMessage) UnmarshalBinary 

func (x *InvalidMessage) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *InvalidMessage to implement encoding.BinaryUnmarshaler.

type InvalidMessageBuilder 

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

func NewInvalidMessageBuilder 

func NewInvalidMessageBuilder() *InvalidMessageBuilder

NewInvalidMessageBuilder returns a builder that constructs InvalidMessage messages.

func (*InvalidMessageBuilder) Build 

func (b *InvalidMessageBuilder) Build() *InvalidMessage

Build returns a new InvalidMessage containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*InvalidMessageBuilder) From 

func (b *InvalidMessageBuilder) From(x *InvalidMessage) *InvalidMessageBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*InvalidMessageBuilder) WithMessageTypeId 

func (b *InvalidMessageBuilder) WithMessageTypeId(v *uuidpb.UUID) *InvalidMessageBuilder

WithMessageTypeId configures the builder to set the MessageTypeId field to v, then returns b.

type InvalidMessage_builder 

type InvalidMessage_builder struct {

	// MessageTypeId is the ID of the type of the invalid message.
	MessageTypeId *uuidpb.UUID
	// contains filtered or unexported fields
}

func (InvalidMessage_builder) Build 

func (b0 InvalidMessage_builder) Build() *InvalidMessage

type ListEventStreamsRequest 

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

ListEventStreamsRequest is the input to the [EventStreamConsumerAPI.ListEventStreams] method.

func (*ListEventStreamsRequest) Format 

func (x *ListEventStreamsRequest) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ListEventStreamsRequest) MarshalBinary 

func (x *ListEventStreamsRequest) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ListEventStreamsRequest to implement encoding.BinaryMarshaler.

func (*ListEventStreamsRequest) ProtoMessage 

func (*ListEventStreamsRequest) ProtoMessage()

func (*ListEventStreamsRequest) ProtoReflect 

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

func (*ListEventStreamsRequest) Reset 

func (x *ListEventStreamsRequest) Reset()

func (*ListEventStreamsRequest) String 

func (x *ListEventStreamsRequest) String() string

func (*ListEventStreamsRequest) UnmarshalBinary 

func (x *ListEventStreamsRequest) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ListEventStreamsRequest to implement encoding.BinaryUnmarshaler.

type ListEventStreamsRequestBuilder 

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

func NewListEventStreamsRequestBuilder 

func NewListEventStreamsRequestBuilder() *ListEventStreamsRequestBuilder

NewListEventStreamsRequestBuilder returns a builder that constructs ListEventStreamsRequest messages.

func (*ListEventStreamsRequestBuilder) Build 

func (b *ListEventStreamsRequestBuilder) Build() *ListEventStreamsRequest

Build returns a new ListEventStreamsRequest containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ListEventStreamsRequestBuilder) From 

func (b *ListEventStreamsRequestBuilder) From(x *ListEventStreamsRequest) *ListEventStreamsRequestBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

type ListEventStreamsRequest_builder 

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

func (ListEventStreamsRequest_builder) Build 

func (b0 ListEventStreamsRequest_builder) Build() *ListEventStreamsRequest

type ListEventStreamsResponse 

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

ListEventStreamsResponse is the output of the [EventStreamConsumerAPI.ListEventStreams] method.

func (*ListEventStreamsResponse) ClearEventStream 

func (x *ListEventStreamsResponse) ClearEventStream()

func (*ListEventStreamsResponse) Format 

func (x *ListEventStreamsResponse) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*ListEventStreamsResponse) GetEventStream 

func (x *ListEventStreamsResponse) GetEventStream() *EventStream

func (*ListEventStreamsResponse) HasEventStream 

func (x *ListEventStreamsResponse) HasEventStream() bool

func (*ListEventStreamsResponse) MarshalBinary 

func (x *ListEventStreamsResponse) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *ListEventStreamsResponse to implement encoding.BinaryMarshaler.

func (*ListEventStreamsResponse) ProtoMessage 

func (*ListEventStreamsResponse) ProtoMessage()

func (*ListEventStreamsResponse) ProtoReflect 

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

func (*ListEventStreamsResponse) Reset 

func (x *ListEventStreamsResponse) Reset()

func (*ListEventStreamsResponse) SetEventStream 

func (x *ListEventStreamsResponse) SetEventStream(v *EventStream)

func (*ListEventStreamsResponse) String 

func (x *ListEventStreamsResponse) String() string

func (*ListEventStreamsResponse) UnmarshalBinary 

func (x *ListEventStreamsResponse) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *ListEventStreamsResponse to implement encoding.BinaryUnmarshaler.

type ListEventStreamsResponseBuilder 

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

func NewListEventStreamsResponseBuilder 

func NewListEventStreamsResponseBuilder() *ListEventStreamsResponseBuilder

NewListEventStreamsResponseBuilder returns a builder that constructs ListEventStreamsResponse messages.

func (*ListEventStreamsResponseBuilder) Build 

func (b *ListEventStreamsResponseBuilder) Build() *ListEventStreamsResponse

Build returns a new ListEventStreamsResponse containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*ListEventStreamsResponseBuilder) From 

func (b *ListEventStreamsResponseBuilder) From(x *ListEventStreamsResponse) *ListEventStreamsResponseBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*ListEventStreamsResponseBuilder) WithEventStream 

func (b *ListEventStreamsResponseBuilder) WithEventStream(v *EventStream) *ListEventStreamsResponseBuilder

WithEventStream configures the builder to set the EventStream field to v, then returns b.

type ListEventStreamsResponse_builder 

type ListEventStreamsResponse_builder struct {

	// EventStream is an event stream offered by the server.
	EventStream *EventStream
	// contains filtered or unexported fields
}

func (ListEventStreamsResponse_builder) Build 

func (b0 ListEventStreamsResponse_builder) Build() *ListEventStreamsResponse

type MalformedMessage 

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

MalformedMessage is an error-details value for INVALID_ARGUMENT errors that occurred because a message's binary data could not be unmarshaled.

func (*MalformedMessage) ClearMessageTypeId 

func (x *MalformedMessage) ClearMessageTypeId()

func (*MalformedMessage) Format 

func (x *MalformedMessage) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*MalformedMessage) GetMessageTypeId 

func (x *MalformedMessage) GetMessageTypeId() *uuidpb.UUID

func (*MalformedMessage) HasMessageTypeId 

func (x *MalformedMessage) HasMessageTypeId() bool

func (*MalformedMessage) MarshalBinary 

func (x *MalformedMessage) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *MalformedMessage to implement encoding.BinaryMarshaler.

func (*MalformedMessage) ProtoMessage 

func (*MalformedMessage) ProtoMessage()

func (*MalformedMessage) ProtoReflect 

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

func (*MalformedMessage) Reset 

func (x *MalformedMessage) Reset()

func (*MalformedMessage) SetMessageTypeId 

func (x *MalformedMessage) SetMessageTypeId(v *uuidpb.UUID)

func (*MalformedMessage) String 

func (x *MalformedMessage) String() string

func (*MalformedMessage) UnmarshalBinary 

func (x *MalformedMessage) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *MalformedMessage to implement encoding.BinaryUnmarshaler.

type MalformedMessageBuilder 

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

func NewMalformedMessageBuilder 

func NewMalformedMessageBuilder() *MalformedMessageBuilder

NewMalformedMessageBuilder returns a builder that constructs MalformedMessage messages.

func (*MalformedMessageBuilder) Build 

func (b *MalformedMessageBuilder) Build() *MalformedMessage

Build returns a new MalformedMessage containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*MalformedMessageBuilder) From 

func (b *MalformedMessageBuilder) From(x *MalformedMessage) *MalformedMessageBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*MalformedMessageBuilder) WithMessageTypeId 

func (b *MalformedMessageBuilder) WithMessageTypeId(v *uuidpb.UUID) *MalformedMessageBuilder

WithMessageTypeId configures the builder to set the MessageTypeId field to v, then returns b.

type MalformedMessage_builder 

type MalformedMessage_builder struct {

	// MessageTypeId is the ID of the message type that the data could not be
	// unmarshaled as.
	MessageTypeId *uuidpb.UUID
	// contains filtered or unexported fields
}

func (MalformedMessage_builder) Build 

func (b0 MalformedMessage_builder) Build() *MalformedMessage

type UnimplementedCommandExecutorAPIServer 

type UnimplementedCommandExecutorAPIServer struct{}

UnimplementedCommandExecutorAPIServer should 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 (UnimplementedCommandExecutorAPIServer) ExecuteCommand 

func (UnimplementedCommandExecutorAPIServer) ExecuteCommand(*ExecuteCommandRequest, grpc.ServerStreamingServer[ExecuteCommandResponse]) error

type UnimplementedEventStreamConsumerAPIServer 

type UnimplementedEventStreamConsumerAPIServer struct{}

UnimplementedEventStreamConsumerAPIServer should 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 (UnimplementedEventStreamConsumerAPIServer) ConsumeEvents 

func (UnimplementedEventStreamConsumerAPIServer) ConsumeEvents(*ConsumeEventsRequest, grpc.ServerStreamingServer[ConsumeEventsResponse]) error

func (UnimplementedEventStreamConsumerAPIServer) ListEventStreams 

func (UnimplementedEventStreamConsumerAPIServer) ListEventStreams(*ListEventStreamsRequest, grpc.ServerStreamingServer[ListEventStreamsResponse]) error

type UnrecognizedApplication 

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

UnrecognizedApplication is an error-details value for NOT_FOUND errors that occurred because a client requested an application that is unknown to the server.

func (*UnrecognizedApplication) ClearApplicationKey 

func (x *UnrecognizedApplication) ClearApplicationKey()

func (*UnrecognizedApplication) Format 

func (x *UnrecognizedApplication) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*UnrecognizedApplication) GetApplicationKey 

func (x *UnrecognizedApplication) GetApplicationKey() *uuidpb.UUID

func (*UnrecognizedApplication) HasApplicationKey 

func (x *UnrecognizedApplication) HasApplicationKey() bool

func (*UnrecognizedApplication) MarshalBinary 

func (x *UnrecognizedApplication) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *UnrecognizedApplication to implement encoding.BinaryMarshaler.

func (*UnrecognizedApplication) ProtoMessage 

func (*UnrecognizedApplication) ProtoMessage()

func (*UnrecognizedApplication) ProtoReflect 

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

func (*UnrecognizedApplication) Reset 

func (x *UnrecognizedApplication) Reset()

func (*UnrecognizedApplication) SetApplicationKey 

func (x *UnrecognizedApplication) SetApplicationKey(v *uuidpb.UUID)

func (*UnrecognizedApplication) String 

func (x *UnrecognizedApplication) String() string

func (*UnrecognizedApplication) UnmarshalBinary 

func (x *UnrecognizedApplication) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *UnrecognizedApplication to implement encoding.BinaryUnmarshaler.

type UnrecognizedApplicationBuilder 

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

func NewUnrecognizedApplicationBuilder 

func NewUnrecognizedApplicationBuilder() *UnrecognizedApplicationBuilder

NewUnrecognizedApplicationBuilder returns a builder that constructs UnrecognizedApplication messages.

func (*UnrecognizedApplicationBuilder) Build 

func (b *UnrecognizedApplicationBuilder) Build() *UnrecognizedApplication

Build returns a new UnrecognizedApplication containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*UnrecognizedApplicationBuilder) From 

func (b *UnrecognizedApplicationBuilder) From(x *UnrecognizedApplication) *UnrecognizedApplicationBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*UnrecognizedApplicationBuilder) WithApplicationKey 

func (b *UnrecognizedApplicationBuilder) WithApplicationKey(v *uuidpb.UUID) *UnrecognizedApplicationBuilder

WithApplicationKey configures the builder to set the ApplicationKey field to v, then returns b.

type UnrecognizedApplication_builder 

type UnrecognizedApplication_builder struct {

	// ApplicationKey is the key of the unrecognized application.
	ApplicationKey *uuidpb.UUID
	// contains filtered or unexported fields
}

func (UnrecognizedApplication_builder) Build 

func (b0 UnrecognizedApplication_builder) Build() *UnrecognizedApplication

type UnrecognizedCommandType 

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

UnrecognizedCommandType is an error-details value for INVALID_ARGUMENT errors that occurred because a specific command type was not recognized by the server, or is not executable within the target application.

func (*UnrecognizedCommandType) ClearMessageTypeId 

func (x *UnrecognizedCommandType) ClearMessageTypeId()

func (*UnrecognizedCommandType) Format 

func (x *UnrecognizedCommandType) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*UnrecognizedCommandType) GetMessageTypeId 

func (x *UnrecognizedCommandType) GetMessageTypeId() *uuidpb.UUID

func (*UnrecognizedCommandType) HasMessageTypeId 

func (x *UnrecognizedCommandType) HasMessageTypeId() bool

func (*UnrecognizedCommandType) MarshalBinary 

func (x *UnrecognizedCommandType) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *UnrecognizedCommandType to implement encoding.BinaryMarshaler.

func (*UnrecognizedCommandType) ProtoMessage 

func (*UnrecognizedCommandType) ProtoMessage()

func (*UnrecognizedCommandType) ProtoReflect 

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

func (*UnrecognizedCommandType) Reset 

func (x *UnrecognizedCommandType) Reset()

func (*UnrecognizedCommandType) SetMessageTypeId 

func (x *UnrecognizedCommandType) SetMessageTypeId(v *uuidpb.UUID)

func (*UnrecognizedCommandType) String 

func (x *UnrecognizedCommandType) String() string

func (*UnrecognizedCommandType) UnmarshalBinary 

func (x *UnrecognizedCommandType) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *UnrecognizedCommandType to implement encoding.BinaryUnmarshaler.

type UnrecognizedCommandTypeBuilder 

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

func NewUnrecognizedCommandTypeBuilder 

func NewUnrecognizedCommandTypeBuilder() *UnrecognizedCommandTypeBuilder

NewUnrecognizedCommandTypeBuilder returns a builder that constructs UnrecognizedCommandType messages.

func (*UnrecognizedCommandTypeBuilder) Build 

func (b *UnrecognizedCommandTypeBuilder) Build() *UnrecognizedCommandType

Build returns a new UnrecognizedCommandType containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*UnrecognizedCommandTypeBuilder) From 

func (b *UnrecognizedCommandTypeBuilder) From(x *UnrecognizedCommandType) *UnrecognizedCommandTypeBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*UnrecognizedCommandTypeBuilder) WithMessageTypeId 

func (b *UnrecognizedCommandTypeBuilder) WithMessageTypeId(v *uuidpb.UUID) *UnrecognizedCommandTypeBuilder

WithMessageTypeId configures the builder to set the MessageTypeId field to v, then returns b.

type UnrecognizedCommandType_builder 

type UnrecognizedCommandType_builder struct {

	// MessageTypeId is the ID of the unrecognized command type.
	MessageTypeId *uuidpb.UUID
	// contains filtered or unexported fields
}

func (UnrecognizedCommandType_builder) Build 

func (b0 UnrecognizedCommandType_builder) Build() *UnrecognizedCommandType

type UnrecognizedEventStream 

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

UnrecognizedEventStream is an error-details value for NOT_FOUND errors that occurred because a client requested an unrecognized stream ID.

func (*UnrecognizedEventStream) ClearEventStreamId 

func (x *UnrecognizedEventStream) ClearEventStreamId()

func (*UnrecognizedEventStream) Format 

func (x *UnrecognizedEventStream) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*UnrecognizedEventStream) GetEventStreamId 

func (x *UnrecognizedEventStream) GetEventStreamId() *uuidpb.UUID

func (*UnrecognizedEventStream) HasEventStreamId 

func (x *UnrecognizedEventStream) HasEventStreamId() bool

func (*UnrecognizedEventStream) MarshalBinary 

func (x *UnrecognizedEventStream) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *UnrecognizedEventStream to implement encoding.BinaryMarshaler.

func (*UnrecognizedEventStream) ProtoMessage 

func (*UnrecognizedEventStream) ProtoMessage()

func (*UnrecognizedEventStream) ProtoReflect 

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

func (*UnrecognizedEventStream) Reset 

func (x *UnrecognizedEventStream) Reset()

func (*UnrecognizedEventStream) SetEventStreamId 

func (x *UnrecognizedEventStream) SetEventStreamId(v *uuidpb.UUID)

func (*UnrecognizedEventStream) String 

func (x *UnrecognizedEventStream) String() string

func (*UnrecognizedEventStream) UnmarshalBinary 

func (x *UnrecognizedEventStream) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *UnrecognizedEventStream to implement encoding.BinaryUnmarshaler.

type UnrecognizedEventStreamBuilder 

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

func NewUnrecognizedEventStreamBuilder 

func NewUnrecognizedEventStreamBuilder() *UnrecognizedEventStreamBuilder

NewUnrecognizedEventStreamBuilder returns a builder that constructs UnrecognizedEventStream messages.

func (*UnrecognizedEventStreamBuilder) Build 

func (b *UnrecognizedEventStreamBuilder) Build() *UnrecognizedEventStream

Build returns a new UnrecognizedEventStream containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*UnrecognizedEventStreamBuilder) From 

func (b *UnrecognizedEventStreamBuilder) From(x *UnrecognizedEventStream) *UnrecognizedEventStreamBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*UnrecognizedEventStreamBuilder) WithEventStreamId 

func (b *UnrecognizedEventStreamBuilder) WithEventStreamId(v *uuidpb.UUID) *UnrecognizedEventStreamBuilder

WithEventStreamId configures the builder to set the EventStreamId field to v, then returns b.

type UnrecognizedEventStream_builder 

type UnrecognizedEventStream_builder struct {

	// EventStreamId is the ID of the unrecognized stream.
	EventStreamId *uuidpb.UUID
	// contains filtered or unexported fields
}

func (UnrecognizedEventStream_builder) Build 

func (b0 UnrecognizedEventStream_builder) Build() *UnrecognizedEventStream

type UnrecognizedEventType 

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

UnrecognizedEventType is an error-details value for INVALID_ARGUMENT errors that occurred because a specific event type was not recognized by the server.

func (*UnrecognizedEventType) ClearMessageTypeId 

func (x *UnrecognizedEventType) ClearMessageTypeId()

func (*UnrecognizedEventType) Format 

func (x *UnrecognizedEventType) Format(f fmt.State, verb rune)

Format formats x according to the given fmt verb.

It implements fmt.Formatter, taking precedence over the String() method generated by the Protocol Buffers compiler.

For the %s and %q verbs it uses the string returned by x.AsString() if x provides such a method. For the %#v verb it uses the string returned by x.GoString() if x provides such a method. Otherwise it formats x as though this method were not defined.

AsString() and GoString() are called even when x is nil, since some message types handle a nil receiver themselves. If either method panics, the panic is formatted the same way the fmt package formats a panicking String() method.

func (*UnrecognizedEventType) GetMessageTypeId 

func (x *UnrecognizedEventType) GetMessageTypeId() *uuidpb.UUID

func (*UnrecognizedEventType) HasMessageTypeId 

func (x *UnrecognizedEventType) HasMessageTypeId() bool

func (*UnrecognizedEventType) MarshalBinary 

func (x *UnrecognizedEventType) MarshalBinary() ([]byte, error)

MarshalBinary returns the binary representation of the message, equivalent to calling proto.Marshal(x).

It allows *UnrecognizedEventType to implement encoding.BinaryMarshaler.

func (*UnrecognizedEventType) ProtoMessage 

func (*UnrecognizedEventType) ProtoMessage()

func (*UnrecognizedEventType) ProtoReflect 

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

func (*UnrecognizedEventType) Reset 

func (x *UnrecognizedEventType) Reset()

func (*UnrecognizedEventType) SetMessageTypeId 

func (x *UnrecognizedEventType) SetMessageTypeId(v *uuidpb.UUID)

func (*UnrecognizedEventType) String 

func (x *UnrecognizedEventType) String() string

func (*UnrecognizedEventType) UnmarshalBinary 

func (x *UnrecognizedEventType) UnmarshalBinary(data []byte) error

UnmarshalBinary populates x from its binary representation, equivalent to calling proto.Unmarshal(data, x).

It allows *UnrecognizedEventType to implement encoding.BinaryUnmarshaler.

type UnrecognizedEventTypeBuilder 

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

func NewUnrecognizedEventTypeBuilder 

func NewUnrecognizedEventTypeBuilder() *UnrecognizedEventTypeBuilder

NewUnrecognizedEventTypeBuilder returns a builder that constructs UnrecognizedEventType messages.

func (*UnrecognizedEventTypeBuilder) Build 

func (b *UnrecognizedEventTypeBuilder) Build() *UnrecognizedEventType

Build returns a new UnrecognizedEventType containing the values configured via the builder.

Each call returns a new message, such that future changes to the builder do not modify previously constructed messages.

func (*UnrecognizedEventTypeBuilder) From 

func (b *UnrecognizedEventTypeBuilder) From(x *UnrecognizedEventType) *UnrecognizedEventTypeBuilder

From configures the builder to use x as the prototype for new messages, then returns b.

It performs a shallow copy of x, such that any changes made via the builder do not modify x. It does not make a copy of the field values themselves.

func (*UnrecognizedEventTypeBuilder) WithMessageTypeId 

func (b *UnrecognizedEventTypeBuilder) WithMessageTypeId(v *uuidpb.UUID) *UnrecognizedEventTypeBuilder

WithMessageTypeId configures the builder to set the MessageTypeId field to v, then returns b.

type UnrecognizedEventType_builder 

type UnrecognizedEventType_builder struct {

	// MessageTypeId is the ID of the unrecognized event type.
	MessageTypeId *uuidpb.UUID
	// contains filtered or unexported fields
}

func (UnrecognizedEventType_builder) Build 

func (b0 UnrecognizedEventType_builder) Build() *UnrecognizedEventType

type UnsafeCommandExecutorAPIServer 

type UnsafeCommandExecutorAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeCommandExecutorAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandExecutorAPIServer will result in compilation errors.

type UnsafeEventStreamConsumerAPIServer 

type UnsafeEventStreamConsumerAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeEventStreamConsumerAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventStreamConsumerAPIServer 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.