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 EventTTLDuration + const SnapshotEveryNEvents + var File_example_app_test_v1_test_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 Builder struct + Events []protosource.Event + func NewBuilder(id string, version int64) *Builder + func (b *Builder) Created(Actor string, Body string, Color string, Shape string, Number string, ...) + func (b *Builder) Locked(Actor string) + func (b *Builder) Snapshot(aggregate *Test) + func (b *Builder) Unlocked(Actor string) + func (b *Builder) Updated(Actor string, Body string, Color string, Shape string, Number string, ...) + type Create struct + Actor string + Body string + Color string + Id string + Number string + Shading string + Shape 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) GetBody() string + func (x *Create) GetColor() string + func (x *Create) GetId() string + func (x *Create) GetNumber() string + func (x *Create) GetShading() string + func (x *Create) GetShape() string + func (x *Create) ProtoReflect() protoreflect.Message + func (x *Create) Reset() + func (x *Create) String() string + type Created struct + Actor string + At int64 + Body string + Color string + Id string + Number string + Shading string + Shape 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) GetBody() string + func (x *Created) GetColor() string + func (x *Created) GetId() string + func (x *Created) GetNumber() string + func (x *Created) GetShading() string + func (x *Created) GetShape() 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) Create(ctx context.Context, id string, body string, color string, shape string, ...) (responsev1.Responseer, error) + func (c *HTTPClient) Get(ctx context.Context, id string) (*Test, error) + func (c *HTTPClient) History(ctx context.Context, id string) (*historyv1.History, error) + func (c *HTTPClient) Load(ctx context.Context, id string) (*Test, error) + func (c *HTTPClient) Lock(ctx context.Context, id string) (responsev1.Responseer, error) + func (c *HTTPClient) QueryByColor(ctx context.Context, color string) ([]*Test, error) + func (c *HTTPClient) QueryByColorBetweenNumber(ctx context.Context, color string, numberFrom string, numberTo string) ([]*Test, error) + func (c *HTTPClient) QueryByColorBetweenShape(ctx context.Context, color string, shapeFrom string, shapeTo string) ([]*Test, error) + func (c *HTTPClient) QueryByColorViaGSI2(ctx context.Context, color string) ([]*Test, error) + func (c *HTTPClient) QueryByColorWithNumber(ctx context.Context, color string, skOp string, number string) ([]*Test, error) + func (c *HTTPClient) QueryByColorWithShape(ctx context.Context, color string, skOp string, shape string) ([]*Test, error) + func (c *HTTPClient) QueryByNumberAndShading(ctx context.Context, number string, shading string) ([]*Test, error) + func (c *HTTPClient) QueryByNumberAndShadingBetweenShapeAndCreateBy(ctx context.Context, number string, shading string, shapeFrom string, ...) ([]*Test, error) + func (c *HTTPClient) QueryByNumberAndShadingWithShapeAndCreateBy(ctx context.Context, number string, shading string, skOp string, shape string, ...) ([]*Test, error) + func (c *HTTPClient) QueryByState(ctx context.Context, state State) ([]*Test, error) + func (c *HTTPClient) QueryByStateBetweenCreateAt(ctx context.Context, state State, createAtFrom int64, createAtTo int64) ([]*Test, error) + func (c *HTTPClient) QueryByStateWithCreateAt(ctx context.Context, state State, skOp string, createAt int64) ([]*Test, error) + func (c *HTTPClient) Unlock(ctx context.Context, id string) (responsev1.Responseer, error) + func (c *HTTPClient) Update(ctx context.Context, id string, body string, color string, shape string, ...) (responsev1.Responseer, error) + type Handler struct + func NewHandler(repo Repo, client *TestClient, authorizer authz.Authorizer) *Handler + 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) HandleLock(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleQueryByColor(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleQueryByColorWithNumber(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleQueryByNumberAndShading(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleQueryByState(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleUnlock(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) HandleUpdate(ctx context.Context, request protosource.Request) protosource.Response + func (h *Handler) RegisterRoutes(router *protosource.Router) + type Lock struct + Actor string + Id string + func (*Lock) Descriptor() ([]byte, []int) + func (*Lock) ProtoMessage() + func (m *Lock) CommandName() string + func (m *Lock) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Lock) GuardState(aggregate protosource.Aggregate) error + func (m *Lock) ProtoValidate() error + func (m *Lock) ValidateVersion(version int64) error + func (x *Lock) GetActor() string + func (x *Lock) GetId() string + func (x *Lock) ProtoReflect() protoreflect.Message + func (x *Lock) Reset() + func (x *Lock) String() string + type Locked struct + Actor string + At int64 + Id string + Version int64 + func (*Locked) Descriptor() ([]byte, []int) + func (*Locked) ProtoMessage() + func (m *Locked) EventName() string + func (x *Locked) GetActor() string + func (x *Locked) GetAt() int64 + func (x *Locked) GetId() string + func (x *Locked) GetVersion() int64 + func (x *Locked) ProtoReflect() protoreflect.Message + func (x *Locked) Reset() + func (x *Locked) String() string + type Repo interface + type Repository struct + func ProvideRepository(store protosource.Store, serializer protosource.Serializer) *Repository + type Snapshot struct + Actor string + At int64 + Id string + Snapshot *Test + 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() *Test + 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_LOCKED + const State_STATE_UNLOCKED + 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 Test struct + Body string + Color string + CreateAt int64 + CreateBy string + Id string + ModifyAt int64 + ModifyBy string + Number string + Shading string + Shape string + State State + Version int64 + func (*Test) Descriptor() ([]byte, []int) + func (*Test) ProtoMessage() + func (aggregate *Test) EventTTLSeconds() int64 + func (aggregate *Test) On(event protosource.Event) error + func (aggregate *Test) RestoreSnapshot(snapshot *Snapshot) + func (aggregate *Test) Snapshot(version int64) protosource.Event + func (aggregate *Test) SnapshotInterval() int32 + func (m *Test) GSI10PK() string + func (m *Test) GSI10SK() string + func (m *Test) GSI11PK() string + func (m *Test) GSI11SK() string + func (m *Test) GSI12PK() string + func (m *Test) GSI12SK() string + func (m *Test) GSI13PK() string + func (m *Test) GSI13SK() string + func (m *Test) GSI14PK() string + func (m *Test) GSI14SK() string + func (m *Test) GSI15PK() string + func (m *Test) GSI15SK() string + func (m *Test) GSI16PK() string + func (m *Test) GSI16SK() string + func (m *Test) GSI17PK() string + func (m *Test) GSI17SK() string + func (m *Test) GSI18PK() string + func (m *Test) GSI18SK() string + func (m *Test) GSI19PK() string + func (m *Test) GSI19SK() string + func (m *Test) GSI1PK() string + func (m *Test) GSI1SK() string + func (m *Test) GSI20PK() string + func (m *Test) GSI20SK() string + func (m *Test) GSI2PK() string + func (m *Test) GSI2SK() string + func (m *Test) GSI3PK() string + func (m *Test) GSI3SK() string + func (m *Test) GSI4PK() string + func (m *Test) GSI4SK() string + func (m *Test) GSI5PK() string + func (m *Test) GSI5SK() string + func (m *Test) GSI6PK() string + func (m *Test) GSI6SK() string + func (m *Test) GSI7PK() string + func (m *Test) GSI7SK() string + func (m *Test) GSI8PK() string + func (m *Test) GSI8SK() string + func (m *Test) GSI9PK() string + func (m *Test) GSI9SK() string + func (m *Test) Hydrate(body []byte) error + func (m *Test) PK() string + func (m *Test) SK() string + func (x *Test) GetBody() string + func (x *Test) GetColor() string + func (x *Test) GetCreateAt() int64 + func (x *Test) GetCreateBy() string + func (x *Test) GetId() string + func (x *Test) GetModifyAt() int64 + func (x *Test) GetModifyBy() string + func (x *Test) GetNumber() string + func (x *Test) GetShading() string + func (x *Test) GetShape() string + func (x *Test) GetState() State + func (x *Test) GetVersion() int64 + func (x *Test) ProtoReflect() protoreflect.Message + func (x *Test) Reset() + func (x *Test) String() string + type TestClient struct + func NewTestClient(store opaquedata.OpaqueStore) *TestClient + func (c *TestClient) AddTest(ctx context.Context, d *Test, opts ...opaquedata.Option) error + func (c *TestClient) DeleteTest(ctx context.Context, id string) error + func (c *TestClient) GetTest(ctx context.Context, id string) (*Test, error) + func (c *TestClient) SelectTestByColor(ctx context.Context, color string) ([]*Test, error) + func (c *TestClient) SelectTestByColorViaGSI2(ctx context.Context, color string) ([]*Test, error) + func (c *TestClient) SelectTestByColorWithNumber(ctx context.Context, color string, op opaquedata.SortOperator, ...) ([]*Test, error) + func (c *TestClient) SelectTestByColorWithShape(ctx context.Context, color string, op opaquedata.SortOperator, ...) ([]*Test, error) + func (c *TestClient) SelectTestByNumberAndShading(ctx context.Context, number string, shading string) ([]*Test, error) + func (c *TestClient) SelectTestByNumberAndShadingWithShapeAndCreateBy(ctx context.Context, number string, shading string, op opaquedata.SortOperator, ...) ([]*Test, error) + func (c *TestClient) SelectTestByState(ctx context.Context, state State) ([]*Test, error) + func (c *TestClient) SelectTestByStateWithCreateAt(ctx context.Context, state State, op opaquedata.SortOperator, ...) ([]*Test, error) + func (c *TestClient) UpdateTest(ctx context.Context, d *Test, opts ...opaquedata.Option) error + type TestGSI1SK struct + Shape string + func (v TestGSI1SK) String() string + type TestGSI2SK struct + Number string + func (v TestGSI2SK) String() string + type TestGSI3SK struct + CreateBy string + Shape string + func (v TestGSI3SK) String() string + type TestGSI4SK struct + CreateAt int64 + func (v TestGSI4SK) String() string + type TestList struct + Items []*Test + func (*TestList) Descriptor() ([]byte, []int) + func (*TestList) ProtoMessage() + func (x *TestList) GetItems() []*Test + func (x *TestList) ProtoReflect() protoreflect.Message + func (x *TestList) Reset() + func (x *TestList) String() string + type Unlock struct + Actor string + Id string + func (*Unlock) Descriptor() ([]byte, []int) + func (*Unlock) ProtoMessage() + func (m *Unlock) CommandName() string + func (m *Unlock) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Unlock) GuardState(aggregate protosource.Aggregate) error + func (m *Unlock) ProtoValidate() error + func (m *Unlock) ValidateVersion(version int64) error + func (x *Unlock) GetActor() string + func (x *Unlock) GetId() string + func (x *Unlock) ProtoReflect() protoreflect.Message + func (x *Unlock) Reset() + func (x *Unlock) String() string + type Unlocked struct + Actor string + At int64 + Id string + Version int64 + func (*Unlocked) Descriptor() ([]byte, []int) + func (*Unlocked) ProtoMessage() + func (m *Unlocked) EventName() string + func (x *Unlocked) GetActor() string + func (x *Unlocked) GetAt() int64 + func (x *Unlocked) GetId() string + func (x *Unlocked) GetVersion() int64 + func (x *Unlocked) ProtoReflect() protoreflect.Message + func (x *Unlocked) Reset() + func (x *Unlocked) String() string + type Update struct + Actor string + Body string + Color string + Id string + Number string + Shading string + Shape string + func (*Update) Descriptor() ([]byte, []int) + func (*Update) ProtoMessage() + func (m *Update) CommandName() string + func (m *Update) EmitEvents(aggregate protosource.Aggregate) []protosource.Event + func (m *Update) GuardState(aggregate protosource.Aggregate) error + func (m *Update) ProtoValidate() error + func (m *Update) ValidateVersion(version int64) error + func (x *Update) GetActor() string + func (x *Update) GetBody() string + func (x *Update) GetColor() string + func (x *Update) GetId() string + func (x *Update) GetNumber() string + func (x *Update) GetShading() string + func (x *Update) GetShape() string + func (x *Update) ProtoReflect() protoreflect.Message + func (x *Update) Reset() + func (x *Update) String() string + type Updated struct + Actor string + At int64 + Body string + Color string + Id string + Number string + Shading string + Shape string + Version int64 + func (*Updated) Descriptor() ([]byte, []int) + func (*Updated) ProtoMessage() + func (m *Updated) EventName() string + func (x *Updated) GetActor() string + func (x *Updated) GetAt() int64 + func (x *Updated) GetBody() string + func (x *Updated) GetColor() string + func (x *Updated) GetId() string + func (x *Updated) GetNumber() string + func (x *Updated) GetShading() string + func (x *Updated) GetShape() string + func (x *Updated) GetVersion() int64 + func (x *Updated) ProtoReflect() protoreflect.Message + func (x *Updated) Reset() + func (x *Updated) String() string
Go to main page