testv1

package

Go to main page

Versions in this module

v0

v0.1.5

Apr 13, 2026

v0.1.4

Apr 12, 2026

Changes in this version

+ var ProviderSet = wire.NewSet(ProvideRepository, wire.Bind(new(Repo), new(*Repository)))

+ type Repository struct

+ func ProvideRepository(store protosource.Store, serializer protosource.Serializer) *Repository

v0.1.3

Apr 11, 2026

v0.1.2

Apr 11, 2026

v0.1.1

Apr 10, 2026

Changes in this version

type Lock

+ func (m *Lock) GuardState(aggregate protosource.Aggregate) error

type Unlock

+ func (m *Unlock) GuardState(aggregate protosource.Aggregate) error

type Update

+ func (m *Update) GuardState(aggregate protosource.Aggregate) error

v0.1.0

Apr 7, 2026

v0.0.9

Apr 7, 2026

Changes in this version

type HTTPClient

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

type Handler

+ func (h *Handler) HandleQueryByState(ctx context.Context, request protosource.Request) protosource.Response

type TestClient

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

+ type TestGSI4SK struct

+ CreateAt int64

+ func (v TestGSI4SK) String() string

v0.0.8

Apr 6, 2026

Changes in this version

type Create

+ Color string

+ Number string

+ Shading string

+ Shape string

+ func (x *Create) GetColor() string

+ func (x *Create) GetNumber() string

+ func (x *Create) GetShading() string

+ func (x *Create) GetShape() string

type Created

+ Color string

+ Number string

+ Shading string

+ Shape string

+ func (x *Created) GetColor() string

+ func (x *Created) GetNumber() string

+ func (x *Created) GetShading() string

+ func (x *Created) GetShape() string

type HTTPClient

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

type Handler

+ 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

type Test

+ Color string

+ Number string

+ Shading string

+ Shape string

+ func (x *Test) GetColor() string

+ func (x *Test) GetNumber() string

+ func (x *Test) GetShading() string

+ func (x *Test) GetShape() string

type TestClient

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

+ 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 Update

+ Color string

+ Number string

+ Shading string

+ Shape string

+ func (x *Update) GetColor() string

+ func (x *Update) GetNumber() string

+ func (x *Update) GetShading() string

+ func (x *Update) GetShape() string

type Updated

+ Color string

+ Number string

+ Shading string

+ Shape string

+ func (x *Updated) GetColor() string

+ func (x *Updated) GetNumber() string

+ func (x *Updated) GetShading() string

+ func (x *Updated) GetShape() string

v0.0.7

Apr 6, 2026

v0.0.6

Apr 6, 2026

v0.0.5

Apr 6, 2026

v0.0.4

Apr 6, 2026

v0.0.3

Apr 6, 2026

v0.0.2

Apr 5, 2026

v0.0.1

Apr 5, 2026

Changes in this version

+ const EventTTLDuration

+ const SnapshotEveryNEvents

+ var File_example_app_test_v1_test_v1_proto protoreflect.FileDescriptor

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

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

+ type Create struct

+ Actor string

+ Body 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) GetBody() 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

+ Body 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) GetBody() 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) Create(ctx context.Context, id string, body string) (*responsev1.CommandResponse, 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.CommandResponse, error)

+ func (c *HTTPClient) Unlock(ctx context.Context, id string) (*responsev1.CommandResponse, error)

+ func (c *HTTPClient) Update(ctx context.Context, id string, body string) (*responsev1.CommandResponse, error)

+ type Handler struct

+ func NewHandler(repo Repo, client *TestClient) *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) HandleGetMaterialized(ctx context.Context, request protosource.Request) protosource.Response

+ func (h *Handler) HandleHistory(ctx context.Context, request protosource.Request) protosource.Response

+ func (h *Handler) HandleLock(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) Authorize(aggregate protosource.Aggregate) error

+ func (m *Lock) CommandName() string

+ func (m *Lock) EmitEvents(aggregate protosource.Aggregate) []protosource.Event

+ 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 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

+ CreateAt int64

+ CreateBy string

+ Id string

+ ModifyAt int64

+ ModifyBy 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) 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) 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) UpdateTest(ctx context.Context, d *Test, opts ...opaquedata.Option) error

+ 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) Authorize(aggregate protosource.Aggregate) error

+ func (m *Unlock) CommandName() string

+ func (m *Unlock) EmitEvents(aggregate protosource.Aggregate) []protosource.Event

+ 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

+ Id string

+ func (*Update) Descriptor() ([]byte, []int)

+ func (*Update) ProtoMessage()

+ func (m *Update) Authorize(aggregate protosource.Aggregate) error

+ func (m *Update) CommandName() string

+ func (m *Update) EmitEvents(aggregate protosource.Aggregate) []protosource.Event

+ 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) GetId() 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

+ Id 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) GetId() string

+ func (x *Updated) GetVersion() int64

+ func (x *Updated) ProtoReflect() protoreflect.Message

+ func (x *Updated) Reset()

+ func (x *Updated) String() string

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