Documentation ¶
Index ¶
- type ErrUnknownTx
- type Storage
- func (store *Storage) Begin(ctx context.Context) (store.Tx, error)
- func (store *Storage) DeleteSnapshot(ctx context.Context, id streams.Id, snapshotId string) error
- func (store *Storage) ReadRecords(ctx context.Context, id streams.Id, from int64, to, limit int64) ([]record.Record, error)
- func (store *Storage) ReadSnapshot(ctx context.Context, id streams.Id, snapshotId string) (record.Snapshot, error)
- func (store *Storage) SetSubscriptionPosition(storeTx store.Tx, id streams.Id, position store.SubscriptionPosition) error
- func (store *Storage) SubscriptionPositionLock(storeTx store.Tx, id streams.Id, subscriptionIds ...string) ([]store.SubscriptionPosition, error)
- func (store *Storage) UpdateSnapshot(ctx context.Context, id streams.Id, snapshotId string, ...) error
- func (store *Storage) WriteRecords(ctx context.Context, id streams.Id, data ...record.Data) ([]record.Record, error)
- func (store *Storage) WriteRecordsFrom(ctx context.Context, id streams.Id, position int64, data ...record.Data) ([]record.Record, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrUnknownTx ¶
type ErrUnknownTx struct {
// contains filtered or unexported fields
}
func (ErrUnknownTx) Error ¶
func (err ErrUnknownTx) Error() string
type Storage ¶ added in v0.8.0
type Storage struct {
// contains filtered or unexported fields
}
func NewFromUrl ¶
func (*Storage) DeleteSnapshot ¶ added in v0.8.0
func (*Storage) ReadRecords ¶ added in v0.8.0
func (*Storage) ReadSnapshot ¶ added in v0.8.0
func (*Storage) SetSubscriptionPosition ¶ added in v0.8.0
func (*Storage) SubscriptionPositionLock ¶ added in v0.8.0
func (*Storage) UpdateSnapshot ¶ added in v0.8.0
func (*Storage) WriteRecords ¶ added in v0.8.0
Source Files ¶
Click to show internal directories.
Click to hide internal directories.