internal

Documentation

Index

• Variables
• func Get(id string, _db *bolt.DB) (users.User, error)
• func New(file string, opts *bolt.Options) (*bolt.DB, error)
• type Event
  • func NewCreateEvent(u users.User) (Event, error)
  • func NewDeleteEvent(u users.User, v uint32) (Event, error)
  • func NewUpdateEvent(u users.User, v uint32) (Event, error)
• type Snapshot
  • func GetSnap(id []byte, _db *bolt.DB) (*Snapshot, error)

Variables

var (
	// MainBucket ...
	MainBucket = []byte("users_main")
	// ErrEmptyID is returned if Get is called without an ID set.
	ErrEmptyID = errors.New("id cannot be empty")
)

var ErrNotImplemented = errors.New("not implemented")

ErrNotImplemented is returned if Apply is attempted on an internal event type.

var SnapshotBucket = []byte("users_snapshots")

SnapshotBucket ...

Functions

func Get

func Get(id string, _db *bolt.DB) (users.User, error)

Get ...

func New

func New(file string, opts *bolt.Options) (*bolt.DB, error)

New creates a new bolt database with the provided config.

Types

type Event

type Event interface {
	Apply(ctx context.Context, _db *bolt.DB) (users.User, error)
}

Event represents a database event.

func NewCreateEvent

func NewCreateEvent(u users.User) (Event, error)

NewCreateEvent ...

func NewDeleteEvent

func NewDeleteEvent(u users.User, v uint32) (Event, error)

NewDeleteEvent ...

func NewUpdateEvent

func NewUpdateEvent(u users.User, v uint32) (Event, error)

NewUpdateEvent ...

type Snapshot

type Snapshot struct {
	ID      string
	User    users.User
	Version uint32
}

Snapshot represents a snapshot of a value in a database.

func GetSnap

func GetSnap(id []byte, _db *bolt.DB) (*Snapshot, error)

GetSnap ...