Documentation
¶
Index ¶
- Variables
- type AggregateOptions
- func (*AggregateOptions) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateOptions) GetEventTtlSeconds() int64
- func (x *AggregateOptions) GetStreamPrefix() string
- func (*AggregateOptions) ProtoMessage()
- func (x *AggregateOptions) ProtoReflect() protoreflect.Message
- func (x *AggregateOptions) Reset()
- func (x *AggregateOptions) String() string
- type CollectionAction
- func (CollectionAction) Descriptor() protoreflect.EnumDescriptor
- func (x CollectionAction) Enum() *CollectionAction
- func (CollectionAction) EnumDescriptor() ([]byte, []int)deprecated
- func (x CollectionAction) Number() protoreflect.EnumNumber
- func (x CollectionAction) String() string
- func (CollectionAction) Type() protoreflect.EnumType
- type CollectionMapping
- func (*CollectionMapping) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionMapping) GetAction() CollectionAction
- func (x *CollectionMapping) GetKeyField() string
- func (x *CollectionMapping) GetTarget() string
- func (*CollectionMapping) ProtoMessage()
- func (x *CollectionMapping) ProtoReflect() protoreflect.Message
- func (x *CollectionMapping) Reset()
- func (x *CollectionMapping) String() string
- type CommandLifecycle
- func (CommandLifecycle) Descriptor() protoreflect.EnumDescriptor
- func (x CommandLifecycle) Enum() *CommandLifecycle
- func (CommandLifecycle) EnumDescriptor() ([]byte, []int)deprecated
- func (x CommandLifecycle) Number() protoreflect.EnumNumber
- func (x CommandLifecycle) String() string
- func (CommandLifecycle) Type() protoreflect.EnumType
- type CommandOptions
- func (*CommandOptions) Descriptor() ([]byte, []int)deprecated
- func (x *CommandOptions) GetAllowedStates() []string
- func (x *CommandOptions) GetLifecycle() CommandLifecycle
- func (x *CommandOptions) GetProducesEvents() []string
- func (*CommandOptions) ProtoMessage()
- func (x *CommandOptions) ProtoReflect() protoreflect.Message
- func (x *CommandOptions) Reset()
- func (x *CommandOptions) String() string
- type EventOptions
- func (*EventOptions) Descriptor() ([]byte, []int)deprecated
- func (x *EventOptions) GetAggregateType() string
- func (x *EventOptions) GetCollection() *CollectionMapping
- func (x *EventOptions) GetSetsState() string
- func (*EventOptions) ProtoMessage()
- func (x *EventOptions) ProtoReflect() protoreflect.Message
- func (x *EventOptions) Reset()
- func (x *EventOptions) String() string
- type FileOptions
- type MessageOptions
- func (*MessageOptions) Descriptor() ([]byte, []int)deprecated
- func (x *MessageOptions) GetAggregate() *AggregateOptions
- func (x *MessageOptions) GetCommand() *CommandOptions
- func (x *MessageOptions) GetEvent() *EventOptions
- func (x *MessageOptions) GetProjection() *ProjectionOptions
- func (x *MessageOptions) GetRole() isMessageOptions_Role
- func (x *MessageOptions) GetSnapshot() *SnapshotOptions
- func (*MessageOptions) ProtoMessage()
- func (x *MessageOptions) ProtoReflect() protoreflect.Message
- func (x *MessageOptions) Reset()
- func (x *MessageOptions) String() string
- type MessageOptions_Aggregate
- type MessageOptions_Command
- type MessageOptions_Event
- type MessageOptions_Projection
- type MessageOptions_Snapshot
- type OpaqueFieldOptions
- func (*OpaqueFieldOptions) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueFieldOptions) GetAttributes() []*OpaqueKeyMapping
- func (*OpaqueFieldOptions) ProtoMessage()
- func (x *OpaqueFieldOptions) ProtoReflect() protoreflect.Message
- func (x *OpaqueFieldOptions) Reset()
- func (x *OpaqueFieldOptions) String() string
- type OpaqueKeyMapping
- func (*OpaqueKeyMapping) Descriptor() ([]byte, []int)deprecated
- func (x *OpaqueKeyMapping) GetOrder() int32
- func (x *OpaqueKeyMapping) GetType() OpaqueKeyType
- func (*OpaqueKeyMapping) ProtoMessage()
- func (x *OpaqueKeyMapping) ProtoReflect() protoreflect.Message
- func (x *OpaqueKeyMapping) Reset()
- func (x *OpaqueKeyMapping) String() string
- type OpaqueKeyType
- func (OpaqueKeyType) Descriptor() protoreflect.EnumDescriptor
- func (x OpaqueKeyType) Enum() *OpaqueKeyType
- func (OpaqueKeyType) EnumDescriptor() ([]byte, []int)deprecated
- func (x OpaqueKeyType) Number() protoreflect.EnumNumber
- func (x OpaqueKeyType) String() string
- func (OpaqueKeyType) Type() protoreflect.EnumType
- type ProjectionOptions
- func (*ProjectionOptions) Descriptor() ([]byte, []int)deprecated
- func (x *ProjectionOptions) GetSourceAggregates() []string
- func (*ProjectionOptions) ProtoMessage()
- func (x *ProjectionOptions) ProtoReflect() protoreflect.Message
- func (x *ProjectionOptions) Reset()
- func (x *ProjectionOptions) String() string
- type SnapshotOptions
- func (*SnapshotOptions) Descriptor() ([]byte, []int)deprecated
- func (x *SnapshotOptions) GetDisabled() bool
- func (x *SnapshotOptions) GetEveryNEvents() uint32
- func (*SnapshotOptions) ProtoMessage()
- func (x *SnapshotOptions) ProtoReflect() protoreflect.Message
- func (x *SnapshotOptions) Reset()
- func (x *SnapshotOptions) String() string
Constants ¶
This section is empty.
Variables ¶
var ( CommandLifecycle_name = map[int32]string{ 0: "COMMAND_LIFECYCLE_UNSPECIFIED", 1: "COMMAND_LIFECYCLE_CREATION", 2: "COMMAND_LIFECYCLE_MUTATION", } CommandLifecycle_value = map[string]int32{ "COMMAND_LIFECYCLE_UNSPECIFIED": 0, "COMMAND_LIFECYCLE_CREATION": 1, "COMMAND_LIFECYCLE_MUTATION": 2, } )
Enum value maps for CommandLifecycle.
var ( CollectionAction_name = map[int32]string{ 0: "COLLECTION_ACTION_UNSPECIFIED", 1: "COLLECTION_ACTION_ADD", 2: "COLLECTION_ACTION_REMOVE", } CollectionAction_value = map[string]int32{ "COLLECTION_ACTION_UNSPECIFIED": 0, "COLLECTION_ACTION_ADD": 1, "COLLECTION_ACTION_REMOVE": 2, } )
Enum value maps for CollectionAction.
var ( OpaqueKeyType_name = map[int32]string{ 0: "OPAQUE_KEY_TYPE_UNSPECIFIED", 1: "OPAQUE_KEY_TYPE_PK", 2: "OPAQUE_KEY_TYPE_SK", 3: "OPAQUE_KEY_TYPE_GSI1PK", 4: "OPAQUE_KEY_TYPE_GSI1SK", 5: "OPAQUE_KEY_TYPE_GSI2PK", 6: "OPAQUE_KEY_TYPE_GSI2SK", 7: "OPAQUE_KEY_TYPE_GSI3PK", 8: "OPAQUE_KEY_TYPE_GSI3SK", 9: "OPAQUE_KEY_TYPE_GSI4PK", 10: "OPAQUE_KEY_TYPE_GSI4SK", 11: "OPAQUE_KEY_TYPE_GSI5PK", 12: "OPAQUE_KEY_TYPE_GSI5SK", 13: "OPAQUE_KEY_TYPE_GSI6PK", 14: "OPAQUE_KEY_TYPE_GSI6SK", 15: "OPAQUE_KEY_TYPE_GSI7PK", 16: "OPAQUE_KEY_TYPE_GSI7SK", 17: "OPAQUE_KEY_TYPE_GSI8PK", 18: "OPAQUE_KEY_TYPE_GSI8SK", 19: "OPAQUE_KEY_TYPE_GSI9PK", 20: "OPAQUE_KEY_TYPE_GSI9SK", 21: "OPAQUE_KEY_TYPE_GSI10PK", 22: "OPAQUE_KEY_TYPE_GSI10SK", 23: "OPAQUE_KEY_TYPE_GSI11PK", 24: "OPAQUE_KEY_TYPE_GSI11SK", 25: "OPAQUE_KEY_TYPE_GSI12PK", 26: "OPAQUE_KEY_TYPE_GSI12SK", 27: "OPAQUE_KEY_TYPE_GSI13PK", 28: "OPAQUE_KEY_TYPE_GSI13SK", 29: "OPAQUE_KEY_TYPE_GSI14PK", 30: "OPAQUE_KEY_TYPE_GSI14SK", 31: "OPAQUE_KEY_TYPE_GSI15PK", 32: "OPAQUE_KEY_TYPE_GSI15SK", 33: "OPAQUE_KEY_TYPE_GSI16PK", 34: "OPAQUE_KEY_TYPE_GSI16SK", 35: "OPAQUE_KEY_TYPE_GSI17PK", 36: "OPAQUE_KEY_TYPE_GSI17SK", 37: "OPAQUE_KEY_TYPE_GSI18PK", 38: "OPAQUE_KEY_TYPE_GSI18SK", 39: "OPAQUE_KEY_TYPE_GSI19PK", 40: "OPAQUE_KEY_TYPE_GSI19SK", 41: "OPAQUE_KEY_TYPE_GSI20PK", 42: "OPAQUE_KEY_TYPE_GSI20SK", } OpaqueKeyType_value = map[string]int32{ "OPAQUE_KEY_TYPE_UNSPECIFIED": 0, "OPAQUE_KEY_TYPE_PK": 1, "OPAQUE_KEY_TYPE_SK": 2, "OPAQUE_KEY_TYPE_GSI1PK": 3, "OPAQUE_KEY_TYPE_GSI1SK": 4, "OPAQUE_KEY_TYPE_GSI2PK": 5, "OPAQUE_KEY_TYPE_GSI2SK": 6, "OPAQUE_KEY_TYPE_GSI3PK": 7, "OPAQUE_KEY_TYPE_GSI3SK": 8, "OPAQUE_KEY_TYPE_GSI4PK": 9, "OPAQUE_KEY_TYPE_GSI4SK": 10, "OPAQUE_KEY_TYPE_GSI5PK": 11, "OPAQUE_KEY_TYPE_GSI5SK": 12, "OPAQUE_KEY_TYPE_GSI6PK": 13, "OPAQUE_KEY_TYPE_GSI6SK": 14, "OPAQUE_KEY_TYPE_GSI7PK": 15, "OPAQUE_KEY_TYPE_GSI7SK": 16, "OPAQUE_KEY_TYPE_GSI8PK": 17, "OPAQUE_KEY_TYPE_GSI8SK": 18, "OPAQUE_KEY_TYPE_GSI9PK": 19, "OPAQUE_KEY_TYPE_GSI9SK": 20, "OPAQUE_KEY_TYPE_GSI10PK": 21, "OPAQUE_KEY_TYPE_GSI10SK": 22, "OPAQUE_KEY_TYPE_GSI11PK": 23, "OPAQUE_KEY_TYPE_GSI11SK": 24, "OPAQUE_KEY_TYPE_GSI12PK": 25, "OPAQUE_KEY_TYPE_GSI12SK": 26, "OPAQUE_KEY_TYPE_GSI13PK": 27, "OPAQUE_KEY_TYPE_GSI13SK": 28, "OPAQUE_KEY_TYPE_GSI14PK": 29, "OPAQUE_KEY_TYPE_GSI14SK": 30, "OPAQUE_KEY_TYPE_GSI15PK": 31, "OPAQUE_KEY_TYPE_GSI15SK": 32, "OPAQUE_KEY_TYPE_GSI16PK": 33, "OPAQUE_KEY_TYPE_GSI16SK": 34, "OPAQUE_KEY_TYPE_GSI17PK": 35, "OPAQUE_KEY_TYPE_GSI17SK": 36, "OPAQUE_KEY_TYPE_GSI18PK": 37, "OPAQUE_KEY_TYPE_GSI18SK": 38, "OPAQUE_KEY_TYPE_GSI19PK": 39, "OPAQUE_KEY_TYPE_GSI19SK": 40, "OPAQUE_KEY_TYPE_GSI20PK": 41, "OPAQUE_KEY_TYPE_GSI20SK": 42, } )
Enum value maps for OpaqueKeyType.
var (
// optional funinthecloud.protosource.options.v1.FileOptions protosource_file = 1298;
E_ProtosourceFile = &file_funinthecloud_protosource_options_v1_options_v1_proto_extTypes[0]
)
Extension fields to descriptorpb.FileOptions.
var (
// optional funinthecloud.protosource.options.v1.MessageOptions protosource_message_type = 1297;
E_ProtosourceMessageType = &file_funinthecloud_protosource_options_v1_options_v1_proto_extTypes[1]
)
Extension fields to descriptorpb.MessageOptions.
var (
// optional funinthecloud.protosource.options.v1.OpaqueFieldOptions protosource_opaque_field = 1296;
E_ProtosourceOpaqueField = &file_funinthecloud_protosource_options_v1_options_v1_proto_extTypes[2]
)
Extension fields to descriptorpb.FieldOptions.
var File_funinthecloud_protosource_options_v1_options_v1_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AggregateOptions ¶
type AggregateOptions struct {
// Prefix for the event stream ID. e.g. "order-" → stream ID = "order-{id}"
StreamPrefix string `protobuf:"bytes,1,opt,name=stream_prefix,json=streamPrefix,proto3" json:"stream_prefix,omitempty"`
// TTL for events in this aggregate's stream, in seconds.
// 0 (default) = events persist indefinitely.
// > 0 = all events (including snapshots) expire after this duration.
// Use for ephemeral/temporary aggregates whose entire history can be discarded.
EventTtlSeconds int64 `protobuf:"varint,2,opt,name=event_ttl_seconds,json=eventTtlSeconds,proto3" json:"event_ttl_seconds,omitempty"`
// contains filtered or unexported fields
}
func (*AggregateOptions) Descriptor
deprecated
func (*AggregateOptions) Descriptor() ([]byte, []int)
Deprecated: Use AggregateOptions.ProtoReflect.Descriptor instead.
func (*AggregateOptions) GetEventTtlSeconds ¶
func (x *AggregateOptions) GetEventTtlSeconds() int64
func (*AggregateOptions) GetStreamPrefix ¶
func (x *AggregateOptions) GetStreamPrefix() string
func (*AggregateOptions) ProtoMessage ¶
func (*AggregateOptions) ProtoMessage()
func (*AggregateOptions) ProtoReflect ¶
func (x *AggregateOptions) ProtoReflect() protoreflect.Message
func (*AggregateOptions) Reset ¶
func (x *AggregateOptions) Reset()
func (*AggregateOptions) String ¶
func (x *AggregateOptions) String() string
type CollectionAction ¶
type CollectionAction int32
CollectionAction describes what an event does to a repeated field on the aggregate.
const ( CollectionAction_COLLECTION_ACTION_UNSPECIFIED CollectionAction = 0 CollectionAction_COLLECTION_ACTION_ADD CollectionAction = 1 // append element to the repeated field CollectionAction_COLLECTION_ACTION_REMOVE CollectionAction = 2 // remove element by key field )
func (CollectionAction) Descriptor ¶
func (CollectionAction) Descriptor() protoreflect.EnumDescriptor
func (CollectionAction) Enum ¶
func (x CollectionAction) Enum() *CollectionAction
func (CollectionAction) EnumDescriptor
deprecated
func (CollectionAction) EnumDescriptor() ([]byte, []int)
Deprecated: Use CollectionAction.Descriptor instead.
func (CollectionAction) Number ¶
func (x CollectionAction) Number() protoreflect.EnumNumber
func (CollectionAction) String ¶
func (x CollectionAction) String() string
func (CollectionAction) Type ¶
func (CollectionAction) Type() protoreflect.EnumType
type CollectionMapping ¶
type CollectionMapping struct {
// The name of the map field on the aggregate (e.g. "items").
Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
// What this event does to the collection.
Action CollectionAction `protobuf:"varint,2,opt,name=action,proto3,enum=funinthecloud.protosource.options.v1.CollectionAction" json:"action,omitempty"`
// Required for both ADD and REMOVE. The string field on the collection
// element used as the map key (e.g. "item_id"). For ADD, the key is
// extracted from the embedded element to insert into the map (re-adding
// the same key overwrites — idempotent). For REMOVE, the event must have
// a field with the same name whose value identifies which element to delete.
KeyField string `protobuf:"bytes,3,opt,name=key_field,json=keyField,proto3" json:"key_field,omitempty"`
// contains filtered or unexported fields
}
CollectionMapping declares that an event modifies a collection (map field) on the aggregate rather than copying scalar fields. Collections use map<string, Message> on the aggregate — the map key is a string field on the element message identified by key_field.
func (*CollectionMapping) Descriptor
deprecated
func (*CollectionMapping) Descriptor() ([]byte, []int)
Deprecated: Use CollectionMapping.ProtoReflect.Descriptor instead.
func (*CollectionMapping) GetAction ¶
func (x *CollectionMapping) GetAction() CollectionAction
func (*CollectionMapping) GetKeyField ¶
func (x *CollectionMapping) GetKeyField() string
func (*CollectionMapping) GetTarget ¶
func (x *CollectionMapping) GetTarget() string
func (*CollectionMapping) ProtoMessage ¶
func (*CollectionMapping) ProtoMessage()
func (*CollectionMapping) ProtoReflect ¶
func (x *CollectionMapping) ProtoReflect() protoreflect.Message
func (*CollectionMapping) Reset ¶
func (x *CollectionMapping) Reset()
func (*CollectionMapping) String ¶
func (x *CollectionMapping) String() string
type CommandLifecycle ¶
type CommandLifecycle int32
CommandLifecycle describes when a command is valid relative to the aggregate's existence. UNSPECIFIED skips version validation entirely, giving authors full control. CREATION requires the aggregate to be new (version == 0). MUTATION requires the aggregate to already exist (version > 0).
const ( CommandLifecycle_COMMAND_LIFECYCLE_UNSPECIFIED CommandLifecycle = 0 CommandLifecycle_COMMAND_LIFECYCLE_CREATION CommandLifecycle = 1 CommandLifecycle_COMMAND_LIFECYCLE_MUTATION CommandLifecycle = 2 )
func (CommandLifecycle) Descriptor ¶
func (CommandLifecycle) Descriptor() protoreflect.EnumDescriptor
func (CommandLifecycle) Enum ¶
func (x CommandLifecycle) Enum() *CommandLifecycle
func (CommandLifecycle) EnumDescriptor
deprecated
func (CommandLifecycle) EnumDescriptor() ([]byte, []int)
Deprecated: Use CommandLifecycle.Descriptor instead.
func (CommandLifecycle) Number ¶
func (x CommandLifecycle) Number() protoreflect.EnumNumber
func (CommandLifecycle) String ¶
func (x CommandLifecycle) String() string
func (CommandLifecycle) Type ¶
func (CommandLifecycle) Type() protoreflect.EnumType
type CommandOptions ¶
type CommandOptions struct {
// The event message names this command produces upon successful execution.
// Typically one. Two is uncommon but valid.
// More than two is a signal the command is doing too much.
ProducesEvents []string `protobuf:"bytes,1,rep,name=produces_events,json=producesEvents,proto3" json:"produces_events,omitempty"`
// When this command is valid relative to the aggregate's lifecycle.
// UNSPECIFIED (default) skips version validation.
// CREATION requires version == 0 (new aggregate).
// MUTATION requires version > 0 (existing aggregate).
Lifecycle CommandLifecycle `` /* 131-byte string literal not displayed */
// The aggregate states in which this command is allowed. When specified,
// the plugin generates a GuardState(aggregate) method that rejects the
// command if the aggregate's current state is not in this list — this is
// a state-machine transition guard, not an authorization (AAA) check.
//
// Values must be valid enum value names defined in the same proto file.
// The plugin validates this at generation time.
//
// When empty (default), no GuardState method is generated — the command
// is allowed in any state. Hand-written GuardState methods can still be
// used for guards that need to inspect fields beyond State.
AllowedStates []string `protobuf:"bytes,3,rep,name=allowed_states,json=allowedStates,proto3" json:"allowed_states,omitempty"`
// contains filtered or unexported fields
}
func (*CommandOptions) Descriptor
deprecated
func (*CommandOptions) Descriptor() ([]byte, []int)
Deprecated: Use CommandOptions.ProtoReflect.Descriptor instead.
func (*CommandOptions) GetAllowedStates ¶
func (x *CommandOptions) GetAllowedStates() []string
func (*CommandOptions) GetLifecycle ¶
func (x *CommandOptions) GetLifecycle() CommandLifecycle
func (*CommandOptions) GetProducesEvents ¶
func (x *CommandOptions) GetProducesEvents() []string
func (*CommandOptions) ProtoMessage ¶
func (*CommandOptions) ProtoMessage()
func (*CommandOptions) ProtoReflect ¶
func (x *CommandOptions) ProtoReflect() protoreflect.Message
func (*CommandOptions) Reset ¶
func (x *CommandOptions) Reset()
func (*CommandOptions) String ¶
func (x *CommandOptions) String() string
type EventOptions ¶
type EventOptions struct {
// The aggregate type that owns this event's stream. e.g. "Order"
AggregateType string `protobuf:"bytes,1,opt,name=aggregate_type,json=aggregateType,proto3" json:"aggregate_type,omitempty"`
// If set, the generated On method will assign this state enum value to the
// aggregate's State field when this event is applied. Use the full enum value
// name, e.g. "STATE_LOCKED". The plugin validates that the value exists in
// the same proto file at generation time.
SetsState string `protobuf:"bytes,2,opt,name=sets_state,json=setsState,proto3" json:"sets_state,omitempty"`
// If set, this event modifies a collection on the aggregate instead of
// copying scalar fields. An event either does collection work or scalar
// field copying — not both.
Collection *CollectionMapping `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"`
// contains filtered or unexported fields
}
func (*EventOptions) Descriptor
deprecated
func (*EventOptions) Descriptor() ([]byte, []int)
Deprecated: Use EventOptions.ProtoReflect.Descriptor instead.
func (*EventOptions) GetAggregateType ¶
func (x *EventOptions) GetAggregateType() string
func (*EventOptions) GetCollection ¶
func (x *EventOptions) GetCollection() *CollectionMapping
func (*EventOptions) GetSetsState ¶
func (x *EventOptions) GetSetsState() string
func (*EventOptions) ProtoMessage ¶
func (*EventOptions) ProtoMessage()
func (*EventOptions) ProtoReflect ¶
func (x *EventOptions) ProtoReflect() protoreflect.Message
func (*EventOptions) Reset ¶
func (x *EventOptions) Reset()
func (*EventOptions) String ¶
func (x *EventOptions) String() string
type FileOptions ¶
type FileOptions struct {
Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
// contains filtered or unexported fields
}
func (*FileOptions) Descriptor
deprecated
func (*FileOptions) Descriptor() ([]byte, []int)
Deprecated: Use FileOptions.ProtoReflect.Descriptor instead.
func (*FileOptions) GetEnabled ¶
func (x *FileOptions) GetEnabled() bool
func (*FileOptions) ProtoMessage ¶
func (*FileOptions) ProtoMessage()
func (*FileOptions) ProtoReflect ¶
func (x *FileOptions) ProtoReflect() protoreflect.Message
func (*FileOptions) Reset ¶
func (x *FileOptions) Reset()
func (*FileOptions) String ¶
func (x *FileOptions) String() string
type MessageOptions ¶
type MessageOptions struct {
// Types that are valid to be assigned to Role:
//
// *MessageOptions_Command
// *MessageOptions_Event
// *MessageOptions_Aggregate
// *MessageOptions_Projection
// *MessageOptions_Snapshot
Role isMessageOptions_Role `protobuf_oneof:"role"`
// contains filtered or unexported fields
}
func (*MessageOptions) Descriptor
deprecated
func (*MessageOptions) Descriptor() ([]byte, []int)
Deprecated: Use MessageOptions.ProtoReflect.Descriptor instead.
func (*MessageOptions) GetAggregate ¶
func (x *MessageOptions) GetAggregate() *AggregateOptions
func (*MessageOptions) GetCommand ¶
func (x *MessageOptions) GetCommand() *CommandOptions
func (*MessageOptions) GetEvent ¶
func (x *MessageOptions) GetEvent() *EventOptions
func (*MessageOptions) GetProjection ¶
func (x *MessageOptions) GetProjection() *ProjectionOptions
func (*MessageOptions) GetRole ¶
func (x *MessageOptions) GetRole() isMessageOptions_Role
func (*MessageOptions) GetSnapshot ¶
func (x *MessageOptions) GetSnapshot() *SnapshotOptions
func (*MessageOptions) ProtoMessage ¶
func (*MessageOptions) ProtoMessage()
func (*MessageOptions) ProtoReflect ¶
func (x *MessageOptions) ProtoReflect() protoreflect.Message
func (*MessageOptions) Reset ¶
func (x *MessageOptions) Reset()
func (*MessageOptions) String ¶
func (x *MessageOptions) String() string
type MessageOptions_Aggregate ¶
type MessageOptions_Aggregate struct {
Aggregate *AggregateOptions `protobuf:"bytes,3,opt,name=aggregate,proto3,oneof"`
}
type MessageOptions_Command ¶
type MessageOptions_Command struct {
Command *CommandOptions `protobuf:"bytes,1,opt,name=command,proto3,oneof"`
}
type MessageOptions_Event ¶
type MessageOptions_Event struct {
Event *EventOptions `protobuf:"bytes,2,opt,name=event,proto3,oneof"`
}
type MessageOptions_Projection ¶
type MessageOptions_Projection struct {
Projection *ProjectionOptions `protobuf:"bytes,4,opt,name=projection,proto3,oneof"`
}
type MessageOptions_Snapshot ¶
type MessageOptions_Snapshot struct {
Snapshot *SnapshotOptions `protobuf:"bytes,5,opt,name=snapshot,proto3,oneof"`
}
type OpaqueFieldOptions ¶
type OpaqueFieldOptions struct {
Attributes []*OpaqueKeyMapping `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes,omitempty"`
// contains filtered or unexported fields
}
func (*OpaqueFieldOptions) Descriptor
deprecated
func (*OpaqueFieldOptions) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueFieldOptions.ProtoReflect.Descriptor instead.
func (*OpaqueFieldOptions) GetAttributes ¶
func (x *OpaqueFieldOptions) GetAttributes() []*OpaqueKeyMapping
func (*OpaqueFieldOptions) ProtoMessage ¶
func (*OpaqueFieldOptions) ProtoMessage()
func (*OpaqueFieldOptions) ProtoReflect ¶
func (x *OpaqueFieldOptions) ProtoReflect() protoreflect.Message
func (*OpaqueFieldOptions) Reset ¶
func (x *OpaqueFieldOptions) Reset()
func (*OpaqueFieldOptions) String ¶
func (x *OpaqueFieldOptions) String() string
type OpaqueKeyMapping ¶
type OpaqueKeyMapping struct {
Type OpaqueKeyType `protobuf:"varint,1,opt,name=type,proto3,enum=funinthecloud.protosource.options.v1.OpaqueKeyType" json:"type,omitempty"`
Order int32 `protobuf:"varint,2,opt,name=order,proto3" json:"order,omitempty"` // 1-based ordering within a composite key; 0 = sole field
// contains filtered or unexported fields
}
func (*OpaqueKeyMapping) Descriptor
deprecated
func (*OpaqueKeyMapping) Descriptor() ([]byte, []int)
Deprecated: Use OpaqueKeyMapping.ProtoReflect.Descriptor instead.
func (*OpaqueKeyMapping) GetOrder ¶
func (x *OpaqueKeyMapping) GetOrder() int32
func (*OpaqueKeyMapping) GetType ¶
func (x *OpaqueKeyMapping) GetType() OpaqueKeyType
func (*OpaqueKeyMapping) ProtoMessage ¶
func (*OpaqueKeyMapping) ProtoMessage()
func (*OpaqueKeyMapping) ProtoReflect ¶
func (x *OpaqueKeyMapping) ProtoReflect() protoreflect.Message
func (*OpaqueKeyMapping) Reset ¶
func (x *OpaqueKeyMapping) Reset()
func (*OpaqueKeyMapping) String ¶
func (x *OpaqueKeyMapping) String() string
type OpaqueKeyType ¶
type OpaqueKeyType int32
OpaqueKeyType identifies which DynamoDB key slot a field maps to.
const ( OpaqueKeyType_OPAQUE_KEY_TYPE_UNSPECIFIED OpaqueKeyType = 0 OpaqueKeyType_OPAQUE_KEY_TYPE_PK OpaqueKeyType = 1 OpaqueKeyType_OPAQUE_KEY_TYPE_SK OpaqueKeyType = 2 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI1PK OpaqueKeyType = 3 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI1SK OpaqueKeyType = 4 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI2PK OpaqueKeyType = 5 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI2SK OpaqueKeyType = 6 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI3PK OpaqueKeyType = 7 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI3SK OpaqueKeyType = 8 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI4PK OpaqueKeyType = 9 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI4SK OpaqueKeyType = 10 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI5PK OpaqueKeyType = 11 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI5SK OpaqueKeyType = 12 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI6PK OpaqueKeyType = 13 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI6SK OpaqueKeyType = 14 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI7PK OpaqueKeyType = 15 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI7SK OpaqueKeyType = 16 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI8PK OpaqueKeyType = 17 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI8SK OpaqueKeyType = 18 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI9PK OpaqueKeyType = 19 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI9SK OpaqueKeyType = 20 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI10PK OpaqueKeyType = 21 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI10SK OpaqueKeyType = 22 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI11PK OpaqueKeyType = 23 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI11SK OpaqueKeyType = 24 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI12PK OpaqueKeyType = 25 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI12SK OpaqueKeyType = 26 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI13PK OpaqueKeyType = 27 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI13SK OpaqueKeyType = 28 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI14PK OpaqueKeyType = 29 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI14SK OpaqueKeyType = 30 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI15PK OpaqueKeyType = 31 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI15SK OpaqueKeyType = 32 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI16PK OpaqueKeyType = 33 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI16SK OpaqueKeyType = 34 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI17PK OpaqueKeyType = 35 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI17SK OpaqueKeyType = 36 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI18PK OpaqueKeyType = 37 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI18SK OpaqueKeyType = 38 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI19PK OpaqueKeyType = 39 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI19SK OpaqueKeyType = 40 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI20PK OpaqueKeyType = 41 OpaqueKeyType_OPAQUE_KEY_TYPE_GSI20SK OpaqueKeyType = 42 )
func (OpaqueKeyType) Descriptor ¶
func (OpaqueKeyType) Descriptor() protoreflect.EnumDescriptor
func (OpaqueKeyType) Enum ¶
func (x OpaqueKeyType) Enum() *OpaqueKeyType
func (OpaqueKeyType) EnumDescriptor
deprecated
func (OpaqueKeyType) EnumDescriptor() ([]byte, []int)
Deprecated: Use OpaqueKeyType.Descriptor instead.
func (OpaqueKeyType) Number ¶
func (x OpaqueKeyType) Number() protoreflect.EnumNumber
func (OpaqueKeyType) String ¶
func (x OpaqueKeyType) String() string
func (OpaqueKeyType) Type ¶
func (OpaqueKeyType) Type() protoreflect.EnumType
type ProjectionOptions ¶
type ProjectionOptions struct {
// The aggregate types this projection subscribes to.
SourceAggregates []string `protobuf:"bytes,1,rep,name=source_aggregates,json=sourceAggregates,proto3" json:"source_aggregates,omitempty"`
// contains filtered or unexported fields
}
func (*ProjectionOptions) Descriptor
deprecated
func (*ProjectionOptions) Descriptor() ([]byte, []int)
Deprecated: Use ProjectionOptions.ProtoReflect.Descriptor instead.
func (*ProjectionOptions) GetSourceAggregates ¶
func (x *ProjectionOptions) GetSourceAggregates() []string
func (*ProjectionOptions) ProtoMessage ¶
func (*ProjectionOptions) ProtoMessage()
func (*ProjectionOptions) ProtoReflect ¶
func (x *ProjectionOptions) ProtoReflect() protoreflect.Message
func (*ProjectionOptions) Reset ¶
func (x *ProjectionOptions) Reset()
func (*ProjectionOptions) String ¶
func (x *ProjectionOptions) String() string
type SnapshotOptions ¶
type SnapshotOptions struct {
// How frequently to write a snapshot, and the exact lookback window on
// replay. 0 = defer to runtime default.
EveryNEvents uint32 `protobuf:"varint,1,opt,name=every_n_events,json=everyNEvents,proto3" json:"every_n_events,omitempty"`
// Explicit opt-out for low-velocity aggregates where replay is always cheap.
// Prefer this over omitting the annotation entirely — intent is explicit.
Disabled bool `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
// contains filtered or unexported fields
}
func (*SnapshotOptions) Descriptor
deprecated
func (*SnapshotOptions) Descriptor() ([]byte, []int)
Deprecated: Use SnapshotOptions.ProtoReflect.Descriptor instead.
func (*SnapshotOptions) GetDisabled ¶
func (x *SnapshotOptions) GetDisabled() bool
func (*SnapshotOptions) GetEveryNEvents ¶
func (x *SnapshotOptions) GetEveryNEvents() uint32
func (*SnapshotOptions) ProtoMessage ¶
func (*SnapshotOptions) ProtoMessage()
func (*SnapshotOptions) ProtoReflect ¶
func (x *SnapshotOptions) ProtoReflect() protoreflect.Message
func (*SnapshotOptions) Reset ¶
func (x *SnapshotOptions) Reset()
func (*SnapshotOptions) String ¶
func (x *SnapshotOptions) String() string