Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

orderv1

package

Go to main page

Versions in this module

v0

v0.8.0

Jun 26, 2026

v0.7.1

Jun 26, 2026

v0.7.0

Jun 26, 2026

v0.6.1

Jun 4, 2026

v0.6.0

May 29, 2026

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