optionsv1

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Apr 13, 2026 License: MIT Imports: 6 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

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

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

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

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

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

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

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

func (CollectionAction) EnumDescriptor deprecated

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

Deprecated: Use CollectionAction.Descriptor instead.

func (CollectionAction) Number

func (CollectionAction) String

func (x CollectionAction) String() string

func (CollectionAction) Type

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

func (CommandLifecycle) EnumDescriptor deprecated

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

Deprecated: Use CommandLifecycle.Descriptor instead.

func (CommandLifecycle) Number

func (CommandLifecycle) String

func (x CommandLifecycle) String() string

func (CommandLifecycle) Type

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

func (x OpaqueKeyType) Enum() *OpaqueKeyType

func (OpaqueKeyType) EnumDescriptor deprecated

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

Deprecated: Use OpaqueKeyType.Descriptor instead.

func (OpaqueKeyType) Number

func (OpaqueKeyType) String

func (x OpaqueKeyType) String() string

func (OpaqueKeyType) Type

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL