Versions in this module Expand all Collapse all v0 v0.5.5 May 22, 2026 v0.5.4 May 22, 2026 v0.5.3 May 22, 2026 v0.5.2 May 22, 2026 v0.5.1 May 22, 2026 v0.5.0 May 21, 2026 v0.4.4 May 21, 2026 v0.4.3 May 21, 2026 Changes in this version + const SnapshotEveryNEvents + var ErrItemAlreadyPresent = errors.New("order: item already present") + var File_example_app_order_v1_order_v1_proto protoreflect.FileDescriptor + var ProviderSet = wire.NewSet(ProvideRepository, wire.Bind(new(Repo), new(*Repository))) + var State_Display = map[State]string + var State_name = map[int32]string + var State_value = map[string]int32 + func NewRepository(store protosource.Store, serializer protosource.Serializer, ...) *protosource.Repository + type AddItem struct + Actor string + Id string + Item *LineItem + func (*AddItem) Descriptor() ([]byte, []int) + func (*AddItem) ProtoMessage() + func (c *AddItem) Evaluate(aggregate protosource.Aggregate) error + func (m *AddItem) CommandName() string + func (m *AddItem) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *AddItem) GuardState(aggregate protosource.Aggregate) error + func (m *AddItem) ProtoValidate() error + func (m *AddItem) ValidateVersion(version int64) error + func (x *AddItem) GetActor() string + func (x *AddItem) GetId() string + func (x *AddItem) GetItem() *LineItem + func (x *AddItem) ProtoReflect() protoreflect.Message + func (x *AddItem) Reset() + func (x *AddItem) String() string + type AddTag struct + Actor string + Id string + Tag *Tag + func (*AddTag) Descriptor() ([]byte, []int) + func (*AddTag) ProtoMessage() + func (m *AddTag) CommandName() string + func (m *AddTag) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *AddTag) GuardState(aggregate protosource.Aggregate) error + func (m *AddTag) ProtoValidate() error + func (m *AddTag) ValidateVersion(version int64) error + func (x *AddTag) GetActor() string + func (x *AddTag) GetId() string + func (x *AddTag) GetTag() *Tag + func (x *AddTag) ProtoReflect() protoreflect.Message + func (x *AddTag) Reset() + func (x *AddTag) String() string + type Builder struct + Events []protosource.Event + func NewBuilder(id string, version int64) *Builder + func (b *Builder) Cancelled(Actor string, Reason string) + func (b *Builder) Created(Actor string, CustomerId string, CustomerName string) + func (b *Builder) ItemAdded(Actor string, Item *LineItem) + func (b *Builder) ItemRemoved(Actor string, ItemId string) + func (b *Builder) Placed(Actor string, PlacedAt int64) + func (b *Builder) ShippingSet(Actor string, ShippingAddress string) + func (b *Builder) Snapshot(aggregate *Order) + func (b *Builder) TagAdded(Actor string, Tag *Tag) + func (b *Builder) TagRemoved(Actor string, Key string) + type Cancel struct + Actor string + Id string + Reason string + func (*Cancel) Descriptor() ([]byte, []int) + func (*Cancel) ProtoMessage() + func (m *Cancel) CommandName() string + func (m *Cancel) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Cancel) GuardState(aggregate protosource.Aggregate) error + func (m *Cancel) ProtoValidate() error + func (m *Cancel) ValidateVersion(version int64) error + func (x *Cancel) GetActor() string + func (x *Cancel) GetId() string + func (x *Cancel) GetReason() string + func (x *Cancel) ProtoReflect() protoreflect.Message + func (x *Cancel) Reset() + func (x *Cancel) String() string + type Cancelled struct + Actor string + At int64 + Id string + Reason string + Version int64 + func (*Cancelled) Descriptor() ([]byte, []int) + func (*Cancelled) ProtoMessage() + func (m *Cancelled) EventName() string + func (x *Cancelled) GetActor() string + func (x *Cancelled) GetAt() int64 + func (x *Cancelled) GetId() string + func (x *Cancelled) GetReason() string + func (x *Cancelled) GetVersion() int64 + func (x *Cancelled) ProtoReflect() protoreflect.Message + func (x *Cancelled) Reset() + func (x *Cancelled) String() string + type Create struct + Actor string + CustomerId string + CustomerName string + Id string + func (*Create) Descriptor() ([]byte, []int) + func (*Create) ProtoMessage() + func (m *Create) CommandName() string + func (m *Create) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Create) ProtoValidate() error + func (m *Create) ValidateVersion(version int64) error + func (x *Create) GetActor() string + func (x *Create) GetCustomerId() string + func (x *Create) GetCustomerName() string + func (x *Create) GetId() string + func (x *Create) ProtoReflect() protoreflect.Message + func (x *Create) Reset() + func (x *Create) String() string + type Created struct + Actor string + At int64 + CustomerId string + CustomerName string + Id string + Version int64 + func (*Created) Descriptor() ([]byte, []int) + func (*Created) ProtoMessage() + func (m *Created) EventName() string + func (x *Created) GetActor() string + func (x *Created) GetAt() int64 + func (x *Created) GetCustomerId() string + func (x *Created) GetCustomerName() string + func (x *Created) GetId() string + func (x *Created) GetVersion() int64 + func (x *Created) ProtoReflect() protoreflect.Message + func (x *Created) Reset() + func (x *Created) String() string + type HTTPClient struct + func NewHTTPClient(c httpclient.Doer) *HTTPClient + func (c *HTTPClient) AddItem(ctx context.Context, id string, item *LineItem) (responsev1.Responseer, error) + func (c *HTTPClient) AddTag(ctx context.Context, id string, tag *Tag) (responsev1.Responseer, error) + func (c *HTTPClient) Cancel(ctx context.Context, id string, reason string) (responsev1.Responseer, error) + func (c *HTTPClient) Create(ctx context.Context, id string, customerId string, customerName string) (responsev1.Responseer, error) + func (c *HTTPClient) Get(ctx context.Context, id string) (*Order, error) + func (c *HTTPClient) History(ctx context.Context, id string) (*historyv1.History, error) + func (c *HTTPClient) Load(ctx context.Context, id string) (*Order, error) + func (c *HTTPClient) Place(ctx context.Context, id string, placedAt int64) (responsev1.Responseer, error) + func (c *HTTPClient) QueryByCustomerId(ctx context.Context, customerId string) ([]*Order, error) + func (c *HTTPClient) QueryByCustomerIdBetweenCreateAt(ctx context.Context, customerId string, createAtFrom int64, createAtTo int64) ([]*Order, error) + func (c *HTTPClient) QueryByCustomerIdWithCreateAt(ctx context.Context, customerId string, skOp string, createAt int64) ([]*Order, error) + func (c *HTTPClient) RemoveItem(ctx context.Context, id string, itemId string) (responsev1.Responseer, error) + func (c *HTTPClient) RemoveTag(ctx context.Context, id string, key string) (responsev1.Responseer, error) + func (c *HTTPClient) SetShipping(ctx context.Context, id string, shippingAddress string) (responsev1.Responseer, error) + type Handler struct + func NewHandler(repo Repo, client *OrderClient, authorizer authz.Authorizer) *Handler + func (h *Handler) HandleAddItem(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleAddTag(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleCancel(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleCreate(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleGet(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleHistory(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleLoad(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandlePlace(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleQueryByCustomerId(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleRemoveItem(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleRemoveTag(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleSetShipping(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) RegisterRoutes(router *protosource.Router) + type ItemAdded struct + Actor string + At int64 + Id string + Item *LineItem + Version int64 + func (*ItemAdded) Descriptor() ([]byte, []int) + func (*ItemAdded) ProtoMessage() + func (m *ItemAdded) EventName() string + func (x *ItemAdded) GetActor() string + func (x *ItemAdded) GetAt() int64 + func (x *ItemAdded) GetId() string + func (x *ItemAdded) GetItem() *LineItem + func (x *ItemAdded) GetVersion() int64 + func (x *ItemAdded) ProtoReflect() protoreflect.Message + func (x *ItemAdded) Reset() + func (x *ItemAdded) String() string + type ItemRemoved struct + Actor string + At int64 + Id string + ItemId string + Version int64 + func (*ItemRemoved) Descriptor() ([]byte, []int) + func (*ItemRemoved) ProtoMessage() + func (m *ItemRemoved) EventName() string + func (x *ItemRemoved) GetActor() string + func (x *ItemRemoved) GetAt() int64 + func (x *ItemRemoved) GetId() string + func (x *ItemRemoved) GetItemId() string + func (x *ItemRemoved) GetVersion() int64 + func (x *ItemRemoved) ProtoReflect() protoreflect.Message + func (x *ItemRemoved) Reset() + func (x *ItemRemoved) String() string + type LineItem struct + Description string + ItemId string + PriceCents int64 + Quantity int32 + func (*LineItem) Descriptor() ([]byte, []int) + func (*LineItem) ProtoMessage() + func (x *LineItem) GetDescription() string + func (x *LineItem) GetItemId() string + func (x *LineItem) GetPriceCents() int64 + func (x *LineItem) GetQuantity() int32 + func (x *LineItem) ProtoReflect() protoreflect.Message + func (x *LineItem) Reset() + func (x *LineItem) String() string + type Order struct + CreateAt int64 + CreateBy string + CustomerId string + CustomerName string + Id string + ItemCount int32 + Items map[string]*LineItem + ModifyAt int64 + ModifyBy string + PlacedAt int64 + ShippingAddress string + State State + Tags map[string]*Tag + TotalCents int64 + Version int64 + func (*Order) Descriptor() ([]byte, []int) + func (*Order) ProtoMessage() + func (aggregate *Order) On(event protosource.Event) error + func (aggregate *Order) RestoreSnapshot(snapshot *Snapshot) + func (aggregate *Order) Snapshot(version int64) protosource.Event + func (aggregate *Order) SnapshotInterval() int32 + func (m *Order) GSI10PK() string + func (m *Order) GSI10SK() string + func (m *Order) GSI11PK() string + func (m *Order) GSI11SK() string + func (m *Order) GSI12PK() string + func (m *Order) GSI12SK() string + func (m *Order) GSI13PK() string + func (m *Order) GSI13SK() string + func (m *Order) GSI14PK() string + func (m *Order) GSI14SK() string + func (m *Order) GSI15PK() string + func (m *Order) GSI15SK() string + func (m *Order) GSI16PK() string + func (m *Order) GSI16SK() string + func (m *Order) GSI17PK() string + func (m *Order) GSI17SK() string + func (m *Order) GSI18PK() string + func (m *Order) GSI18SK() string + func (m *Order) GSI19PK() string + func (m *Order) GSI19SK() string + func (m *Order) GSI1PK() string + func (m *Order) GSI1SK() string + func (m *Order) GSI20PK() string + func (m *Order) GSI20SK() string + func (m *Order) GSI2PK() string + func (m *Order) GSI2SK() string + func (m *Order) GSI3PK() string + func (m *Order) GSI3SK() string + func (m *Order) GSI4PK() string + func (m *Order) GSI4SK() string + func (m *Order) GSI5PK() string + func (m *Order) GSI5SK() string + func (m *Order) GSI6PK() string + func (m *Order) GSI6SK() string + func (m *Order) GSI7PK() string + func (m *Order) GSI7SK() string + func (m *Order) GSI8PK() string + func (m *Order) GSI8SK() string + func (m *Order) GSI9PK() string + func (m *Order) GSI9SK() string + func (m *Order) Hydrate(body []byte) error + func (m *Order) PK() string + func (m *Order) ProjectOrderSummary() *OrderSummary + func (m *Order) Projections() []proto.Message + func (m *Order) SK() string + func (o *Order) AfterOn() + func (x *Order) GetCreateAt() int64 + func (x *Order) GetCreateBy() string + func (x *Order) GetCustomerId() string + func (x *Order) GetCustomerName() string + func (x *Order) GetId() string + func (x *Order) GetItemCount() int32 + func (x *Order) GetItems() map[string]*LineItem + func (x *Order) GetModifyAt() int64 + func (x *Order) GetModifyBy() string + func (x *Order) GetPlacedAt() int64 + func (x *Order) GetShippingAddress() string + func (x *Order) GetState() State + func (x *Order) GetTags() map[string]*Tag + func (x *Order) GetTotalCents() int64 + func (x *Order) GetVersion() int64 + func (x *Order) ProtoReflect() protoreflect.Message + func (x *Order) Reset() + func (x *Order) String() string + type OrderClient struct + func NewOrderClient(store opaquedata.OpaqueStore) *OrderClient + func (c *OrderClient) AddOrder(ctx context.Context, d *Order, opts ...opaquedata.Option) error + func (c *OrderClient) DeleteOrder(ctx context.Context, id string) error + func (c *OrderClient) GetOrder(ctx context.Context, id string) (*Order, error) + func (c *OrderClient) SelectOrderByCustomerId(ctx context.Context, customer_id string) ([]*Order, error) + func (c *OrderClient) SelectOrderByCustomerIdWithCreateAt(ctx context.Context, customer_id string, op opaquedata.SortOperator, ...) ([]*Order, error) + func (c *OrderClient) UpdateOrder(ctx context.Context, d *Order, opts ...opaquedata.Option) error + type OrderGSI1SK struct + CreateAt int64 + func (v OrderGSI1SK) String() string + type OrderList struct + Items []*Order + func (*OrderList) Descriptor() ([]byte, []int) + func (*OrderList) ProtoMessage() + func (x *OrderList) GetItems() []*Order + func (x *OrderList) ProtoReflect() protoreflect.Message + func (x *OrderList) Reset() + func (x *OrderList) String() string + type OrderSummary struct + CreateAt int64 + CustomerId string + CustomerName string + Id string + ItemCount int32 + PlacedAt int64 + State State + TotalCents int64 + func (*OrderSummary) Descriptor() ([]byte, []int) + func (*OrderSummary) ProtoMessage() + func (m *OrderSummary) GSI10PK() string + func (m *OrderSummary) GSI10SK() string + func (m *OrderSummary) GSI11PK() string + func (m *OrderSummary) GSI11SK() string + func (m *OrderSummary) GSI12PK() string + func (m *OrderSummary) GSI12SK() string + func (m *OrderSummary) GSI13PK() string + func (m *OrderSummary) GSI13SK() string + func (m *OrderSummary) GSI14PK() string + func (m *OrderSummary) GSI14SK() string + func (m *OrderSummary) GSI15PK() string + func (m *OrderSummary) GSI15SK() string + func (m *OrderSummary) GSI16PK() string + func (m *OrderSummary) GSI16SK() string + func (m *OrderSummary) GSI17PK() string + func (m *OrderSummary) GSI17SK() string + func (m *OrderSummary) GSI18PK() string + func (m *OrderSummary) GSI18SK() string + func (m *OrderSummary) GSI19PK() string + func (m *OrderSummary) GSI19SK() string + func (m *OrderSummary) GSI1PK() string + func (m *OrderSummary) GSI1SK() string + func (m *OrderSummary) GSI20PK() string + func (m *OrderSummary) GSI20SK() string + func (m *OrderSummary) GSI2PK() string + func (m *OrderSummary) GSI2SK() string + func (m *OrderSummary) GSI3PK() string + func (m *OrderSummary) GSI3SK() string + func (m *OrderSummary) GSI4PK() string + func (m *OrderSummary) GSI4SK() string + func (m *OrderSummary) GSI5PK() string + func (m *OrderSummary) GSI5SK() string + func (m *OrderSummary) GSI6PK() string + func (m *OrderSummary) GSI6SK() string + func (m *OrderSummary) GSI7PK() string + func (m *OrderSummary) GSI7SK() string + func (m *OrderSummary) GSI8PK() string + func (m *OrderSummary) GSI8SK() string + func (m *OrderSummary) GSI9PK() string + func (m *OrderSummary) GSI9SK() string + func (m *OrderSummary) Hydrate(body []byte) error + func (m *OrderSummary) PK() string + func (m *OrderSummary) SK() string + func (x *OrderSummary) GetCreateAt() int64 + func (x *OrderSummary) GetCustomerId() string + func (x *OrderSummary) GetCustomerName() string + func (x *OrderSummary) GetId() string + func (x *OrderSummary) GetItemCount() int32 + func (x *OrderSummary) GetPlacedAt() int64 + func (x *OrderSummary) GetState() State + func (x *OrderSummary) GetTotalCents() int64 + func (x *OrderSummary) ProtoReflect() protoreflect.Message + func (x *OrderSummary) Reset() + func (x *OrderSummary) String() string + type OrderSummaryClient struct + func NewOrderSummaryClient(store opaquedata.OpaqueStore) *OrderSummaryClient + func (c *OrderSummaryClient) AddOrderSummary(ctx context.Context, d *OrderSummary, opts ...opaquedata.Option) error + func (c *OrderSummaryClient) DeleteOrderSummary(ctx context.Context, id string) error + func (c *OrderSummaryClient) GetOrderSummary(ctx context.Context, id string) (*OrderSummary, error) + func (c *OrderSummaryClient) SelectOrderSummaryByCustomerId(ctx context.Context, customer_id string) ([]*OrderSummary, error) + func (c *OrderSummaryClient) SelectOrderSummaryByCustomerIdWithCreateAt(ctx context.Context, customer_id string, op opaquedata.SortOperator, ...) ([]*OrderSummary, error) + func (c *OrderSummaryClient) SelectOrderSummaryByState(ctx context.Context, state State) ([]*OrderSummary, error) + func (c *OrderSummaryClient) SelectOrderSummaryByStateWithPlacedAt(ctx context.Context, state State, op opaquedata.SortOperator, ...) ([]*OrderSummary, error) + func (c *OrderSummaryClient) UpdateOrderSummary(ctx context.Context, d *OrderSummary, opts ...opaquedata.Option) error + type OrderSummaryGSI1SK struct + CreateAt int64 + func (v OrderSummaryGSI1SK) String() string + type OrderSummaryGSI2SK struct + PlacedAt int64 + func (v OrderSummaryGSI2SK) String() string + type Place struct + Actor string + Id string + PlacedAt int64 + func (*Place) Descriptor() ([]byte, []int) + func (*Place) ProtoMessage() + func (m *Place) CommandName() string + func (m *Place) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Place) GuardState(aggregate protosource.Aggregate) error + func (m *Place) ProtoValidate() error + func (m *Place) ValidateVersion(version int64) error + func (x *Place) GetActor() string + func (x *Place) GetId() string + func (x *Place) GetPlacedAt() int64 + func (x *Place) ProtoReflect() protoreflect.Message + func (x *Place) Reset() + func (x *Place) String() string + type Placed struct + Actor string + At int64 + Id string + PlacedAt int64 + Version int64 + func (*Placed) Descriptor() ([]byte, []int) + func (*Placed) ProtoMessage() + func (m *Placed) EventName() string + func (x *Placed) GetActor() string + func (x *Placed) GetAt() int64 + func (x *Placed) GetId() string + func (x *Placed) GetPlacedAt() int64 + func (x *Placed) GetVersion() int64 + func (x *Placed) ProtoReflect() protoreflect.Message + func (x *Placed) Reset() + func (x *Placed) String() string + type RemoveItem struct + Actor string + Id string + ItemId string + func (*RemoveItem) Descriptor() ([]byte, []int) + func (*RemoveItem) ProtoMessage() + func (c *RemoveItem) Evaluate(aggregate protosource.Aggregate) error + func (m *RemoveItem) CommandName() string + func (m *RemoveItem) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *RemoveItem) GuardState(aggregate protosource.Aggregate) error + func (m *RemoveItem) ProtoValidate() error + func (m *RemoveItem) ValidateVersion(version int64) error + func (x *RemoveItem) GetActor() string + func (x *RemoveItem) GetId() string + func (x *RemoveItem) GetItemId() string + func (x *RemoveItem) ProtoReflect() protoreflect.Message + func (x *RemoveItem) Reset() + func (x *RemoveItem) String() string + type RemoveTag struct + Actor string + Id string + Key string + func (*RemoveTag) Descriptor() ([]byte, []int) + func (*RemoveTag) ProtoMessage() + func (m *RemoveTag) CommandName() string + func (m *RemoveTag) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *RemoveTag) GuardState(aggregate protosource.Aggregate) error + func (m *RemoveTag) ProtoValidate() error + func (m *RemoveTag) ValidateVersion(version int64) error + func (x *RemoveTag) GetActor() string + func (x *RemoveTag) GetId() string + func (x *RemoveTag) GetKey() string + func (x *RemoveTag) ProtoReflect() protoreflect.Message + func (x *RemoveTag) Reset() + func (x *RemoveTag) String() string + type Repo interface + type Repository struct + func ProvideRepository(store protosource.Store, serializer protosource.Serializer) *Repository + type SetShipping struct + Actor string + Id string + ShippingAddress string + func (*SetShipping) Descriptor() ([]byte, []int) + func (*SetShipping) ProtoMessage() + func (m *SetShipping) CommandName() string + func (m *SetShipping) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *SetShipping) GuardState(aggregate protosource.Aggregate) error + func (m *SetShipping) ProtoValidate() error + func (m *SetShipping) ValidateVersion(version int64) error + func (x *SetShipping) GetActor() string + func (x *SetShipping) GetId() string + func (x *SetShipping) GetShippingAddress() string + func (x *SetShipping) ProtoReflect() protoreflect.Message + func (x *SetShipping) Reset() + func (x *SetShipping) String() string + type ShippingSet struct + Actor string + At int64 + Id string + ShippingAddress string + Version int64 + func (*ShippingSet) Descriptor() ([]byte, []int) + func (*ShippingSet) ProtoMessage() + func (m *ShippingSet) EventName() string + func (x *ShippingSet) GetActor() string + func (x *ShippingSet) GetAt() int64 + func (x *ShippingSet) GetId() string + func (x *ShippingSet) GetShippingAddress() string + func (x *ShippingSet) GetVersion() int64 + func (x *ShippingSet) ProtoReflect() protoreflect.Message + func (x *ShippingSet) Reset() + func (x *ShippingSet) String() string + type Snapshot struct + Actor string + At int64 + Id string + Snapshot *Order + Version int64 + func (*Snapshot) Descriptor() ([]byte, []int) + func (*Snapshot) ProtoMessage() + func (m *Snapshot) EventName() string + func (x *Snapshot) GetActor() string + func (x *Snapshot) GetAt() int64 + func (x *Snapshot) GetId() string + func (x *Snapshot) GetSnapshot() *Order + func (x *Snapshot) GetVersion() int64 + func (x *Snapshot) ProtoReflect() protoreflect.Message + func (x *Snapshot) Reset() + func (x *Snapshot) String() string + type State int32 + const State_STATE_CANCELLED + const State_STATE_DELIVERED + const State_STATE_DRAFT + const State_STATE_PAID + const State_STATE_PLACED + const State_STATE_SHIPPED + const State_STATE_UNSPECIFIED + func (State) Descriptor() protoreflect.EnumDescriptor + func (State) EnumDescriptor() ([]byte, []int) + func (State) Type() protoreflect.EnumType + func (x State) Enum() *State + func (x State) Number() protoreflect.EnumNumber + func (x State) String() string + type Tag struct + Key string + Value string + func (*Tag) Descriptor() ([]byte, []int) + func (*Tag) ProtoMessage() + func (x *Tag) GetKey() string + func (x *Tag) GetValue() string + func (x *Tag) ProtoReflect() protoreflect.Message + func (x *Tag) Reset() + func (x *Tag) String() string + type TagAdded struct + Actor string + At int64 + Id string + Tag *Tag + Version int64 + func (*TagAdded) Descriptor() ([]byte, []int) + func (*TagAdded) ProtoMessage() + func (m *TagAdded) EventName() string + func (x *TagAdded) GetActor() string + func (x *TagAdded) GetAt() int64 + func (x *TagAdded) GetId() string + func (x *TagAdded) GetTag() *Tag + func (x *TagAdded) GetVersion() int64 + func (x *TagAdded) ProtoReflect() protoreflect.Message + func (x *TagAdded) Reset() + func (x *TagAdded) String() string + type TagRemoved struct + Actor string + At int64 + Id string + Key string + Version int64 + func (*TagRemoved) Descriptor() ([]byte, []int) + func (*TagRemoved) ProtoMessage() + func (m *TagRemoved) EventName() string + func (x *TagRemoved) GetActor() string + func (x *TagRemoved) GetAt() int64 + func (x *TagRemoved) GetId() string + func (x *TagRemoved) GetKey() string + func (x *TagRemoved) GetVersion() int64 + func (x *TagRemoved) ProtoReflect() protoreflect.Message + func (x *TagRemoved) Reset() + func (x *TagRemoved) String() string