Documentation ¶
Index ¶
- Variables
- type DBTX
- type Event
- type InsertEventsBatchResults
- type InsertEventsParams
- type InsertSnapshotParams
- type ListEventsByAggregateIDAndVersionParams
- type Querier
- type Queries
- func (q *Queries) GetSnapshot(ctx context.Context, aggregateID uuid.UUID) (Snapshot, error)
- func (q *Queries) GetStream(ctx context.Context, id uuid.UUID) (Stream, error)
- func (q *Queries) InsertEvents(ctx context.Context, arg []InsertEventsParams) *InsertEventsBatchResults
- func (q *Queries) InsertSnapshot(ctx context.Context, arg InsertSnapshotParams) (Snapshot, error)
- func (q *Queries) ListEventsByAggregateID(ctx context.Context, aggregateID uuid.UUID) ([]Event, error)
- func (q *Queries) ListEventsByAggregateIDAndVersion(ctx context.Context, arg ListEventsByAggregateIDAndVersionParams) ([]Event, error)
- func (q *Queries) UpsertSteam(ctx context.Context, arg UpsertSteamParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Snapshot
- type Stream
- type UpsertSteamParams
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrBatchAlreadyClosed = errors.New("batch already closed")
)
Functions ¶
This section is empty.
Types ¶
type InsertEventsBatchResults ¶
type InsertEventsBatchResults struct {
// contains filtered or unexported fields
}
func (*InsertEventsBatchResults) Close ¶
func (b *InsertEventsBatchResults) Close() error
type InsertEventsParams ¶
type InsertSnapshotParams ¶ added in v0.2.0
type Querier ¶
type Querier interface { GetSnapshot(ctx context.Context, aggregateID uuid.UUID) (Snapshot, error) GetStream(ctx context.Context, id uuid.UUID) (Stream, error) InsertEvents(ctx context.Context, arg []InsertEventsParams) *InsertEventsBatchResults InsertSnapshot(ctx context.Context, arg InsertSnapshotParams) (Snapshot, error) ListEventsByAggregateID(ctx context.Context, aggregateID uuid.UUID) ([]Event, error) ListEventsByAggregateIDAndVersion(ctx context.Context, arg ListEventsByAggregateIDAndVersionParams) ([]Event, error) UpsertSteam(ctx context.Context, arg UpsertSteamParams) error }
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) GetSnapshot ¶ added in v0.2.0
func (*Queries) InsertEvents ¶
func (q *Queries) InsertEvents(ctx context.Context, arg []InsertEventsParams) *InsertEventsBatchResults
func (*Queries) InsertSnapshot ¶ added in v0.2.0
func (*Queries) ListEventsByAggregateID ¶
func (*Queries) ListEventsByAggregateIDAndVersion ¶
func (*Queries) UpsertSteam ¶
func (q *Queries) UpsertSteam(ctx context.Context, arg UpsertSteamParams) error
Click to show internal directories.
Click to hide internal directories.