driver

Documentation

Overview

package driver defines interfaces to be used by driver implementations.

Index

• func GenerateStreamIDs(first, last uint64, after, count int64) ([]uint64, error)
• type Driver
• type EventLog
• type EventLogWithTruncate
• type EventLogWithUpdate
• type EventStream
• type Subscription

Functions

func GenerateStreamIDs

func GenerateStreamIDs(first, last uint64, after, count int64) ([]uint64, error)

Types

type Driver

type Driver interface {
	Open(ctx context.Context, dsn string) (Driver, error)
	EventLog(ctx context.Context, streamID string) (EventLog, error)
}

type EventLog

type EventLog interface {
	Read(ctx context.Context, after, count int64) (event.Events, error)
	ReadN(ctx context.Context, index ...uint64) (event.Events, error)
	Append(ctx context.Context, events event.Events, version uint64) (uint64, error)
	FirstIndex(context.Context) (uint64, error)
	LastIndex(context.Context) (uint64, error)
}

type EventLogWithTruncate

type EventLogWithTruncate interface {
	Truncate(context.Context, int64) error
}

type EventLogWithUpdate

type EventLogWithUpdate interface {
	LoadForUpdate(context.Context, event.Aggregate, func(context.Context, event.Aggregate) error) (uint64, error)
}

type EventStream

type EventStream interface {
	Subscribe(ctx context.Context, streamID string, start int64) (Subscription, error)
	Send(ctx context.Context, streamID string, events event.Events) error
}

type Subscription

type Subscription interface {
	Recv(context.Context) <-chan bool
	Events(context.Context) (event.Events, error)
	Close(context.Context) error
}