sql

Documentation

Index

• Constants
• func NewSnapshotStore(tableName string, db DB, registry registry.Registry) esourcing.AggregateStoreMiddleware
• type DB
• type EventStore
  • func NewEventStore(tableName string, db DB, registry registry.Registry) EventStore
  • func (s EventStore) Load(ctx context.Context, aggregate esourcing.EventSourcedAggregate) (err error)
  • func (s EventStore) Save(ctx context.Context, aggregate esourcing.EventSourcedAggregate) (err error)
• type InboxStore
  • func NewInboxStore(tableName string, db DB) InboxStore
  • func (s InboxStore) Save(ctx context.Context, msg async.IncomingMessage) error
• type MySQLDB
  • func (m *MySQLDB) DBType() string
• type OutboxStore
  • func NewOutboxStore(tableName string, db DB) OutboxStore
  • func (s OutboxStore) FindUnpublished(ctx context.Context, limit int) ([]async.Message, error)
  • func (s OutboxStore) MarkPublished(ctx context.Context, ids ...string) (err error)
  • func (s OutboxStore) Save(ctx context.Context, msg async.Message) error
• type PostgresDB
  • func (p *PostgresDB) DBType() string
• type SagaStore
  • func NewSagaStore(tableName string, db DB, registry registry.Registry) SagaStore
  • func (s SagaStore) Load(ctx context.Context, sagaName, sagaID string) (*sec.SagaContext[[]byte], error)
  • func (s SagaStore) Save(ctx context.Context, sagaName string, sagaCtx *sec.SagaContext[[]byte]) error
• type SnapshotStore
  • func (s SnapshotStore) Load(ctx context.Context, aggregate esourcing.EventSourcedAggregate) error
  • func (s SnapshotStore) Save(ctx context.Context, aggregate esourcing.EventSourcedAggregate) error

Constants

const (
	DBTypePostgres = "PostgreSQL"
	DBTypeMySQL    = "MySQL"
)

Functions

func NewSnapshotStore

func NewSnapshotStore(tableName string, db DB, registry registry.Registry) esourcing.AggregateStoreMiddleware

Types

type DB

type DB interface {
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	ExecContext(context.Context, string, ...any) (sql.Result, error)
	QueryContext(context.Context, string, ...any) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...any) *sql.Row
	DBType() string
}

type EventStore

type EventStore struct {
	// contains filtered or unexported fields
}

func NewEventStore

func NewEventStore(tableName string, db DB, registry registry.Registry) EventStore

func (EventStore) Load

func (s EventStore) Load(ctx context.Context, aggregate esourcing.EventSourcedAggregate) (err error)

func (EventStore) Save

func (s EventStore) Save(ctx context.Context, aggregate esourcing.EventSourcedAggregate) (err error)

type InboxStore

type InboxStore struct {
	// contains filtered or unexported fields
}

func NewInboxStore

func NewInboxStore(tableName string, db DB) InboxStore

func (InboxStore) Save

func (s InboxStore) Save(ctx context.Context, msg async.IncomingMessage) error

type MySQLDB

type MySQLDB struct {
	sql.DB
}

func (*MySQLDB) DBType

func (m *MySQLDB) DBType() string

type OutboxStore

type OutboxStore struct {
	// contains filtered or unexported fields
}

func NewOutboxStore

func NewOutboxStore(tableName string, db DB) OutboxStore

func (OutboxStore) FindUnpublished

func (s OutboxStore) FindUnpublished(ctx context.Context, limit int) ([]async.Message, error)

func (OutboxStore) MarkPublished

func (s OutboxStore) MarkPublished(ctx context.Context, ids ...string) (err error)

func (OutboxStore) Save

func (s OutboxStore) Save(ctx context.Context, msg async.Message) error

type PostgresDB

type PostgresDB struct {
	sql.DB
}

func (*PostgresDB) DBType

func (p *PostgresDB) DBType() string

type SagaStore

type SagaStore struct {
	// contains filtered or unexported fields
}

func NewSagaStore

func NewSagaStore(tableName string, db DB, registry registry.Registry) SagaStore

func (SagaStore) Load

func (s SagaStore) Load(ctx context.Context, sagaName, sagaID string) (*sec.SagaContext[[]byte], error)

func (SagaStore) Save

func (s SagaStore) Save(ctx context.Context, sagaName string, sagaCtx *sec.SagaContext[[]byte]) error

type SnapshotStore

type SnapshotStore struct {
	esourcing.AggregateStore
	// contains filtered or unexported fields
}

func (SnapshotStore) Load

func (s SnapshotStore) Load(ctx context.Context, aggregate esourcing.EventSourcedAggregate) error

func (SnapshotStore) Save

func (s SnapshotStore) Save(ctx context.Context, aggregate esourcing.EventSourcedAggregate) error