store

Documentation

Index

• type SubscriptionPosition
• type Tx
• type WriteConflictError
  • func (err WriteConflictError) Error() string
  • func (err WriteConflictError) Is(target error) bool

Types

type SubscriptionPosition

type SubscriptionPosition struct {
	SubscriptionId string
	Position       int64
}

type Tx

type Tx interface {
	Commit() error
	Rollback() error
}

type WriteConflictError

type WriteConflictError struct {
	StreamId streams.Id
	Position int64 // position attempted to write
	Err      error // possible underlying storage engine error
}

Error type used when optimistic locking hits a write conflict

func (WriteConflictError) Error

func (err WriteConflictError) Error() string

func (WriteConflictError) Is

func (err WriteConflictError) Is(target error) bool