core

Documentation

Index

• type App
  • func NewApp(bunDB *bun.DB, fileStore FileStore) App
  • func (a App) Context(ctx context.Context) *Context
• type Bus
  • func NewBus() *Bus
• type Context
  • func (c *Context) Context() context.Context
• type EventEnvelopeCreated
• type EventEnvelopeDeleted
• type FileStore
  • func NewFileStore(dir string) FileStore

Types

type App

type App struct {
	Bus  *Bus
	DB   *bun.DB
	File FileStore
}

func NewApp

func NewApp(bunDB *bun.DB, fileStore FileStore) App

func (App) Context

func (a App) Context(ctx context.Context) *Context

type Bus

type Bus struct {
	Mutex           sync.Mutex
	EnvelopeCreated []func(cc *Context, evt EventEnvelopeCreated)
	EnvelopeDeleted []func(cc *Context, evt EventEnvelopeDeleted)
}

func NewBus

func NewBus() *Bus

type Context

type Context struct {
	Bus  *Bus
	DB   *bun.DB
	File FileStore
	// contains filtered or unexported fields
}

func (*Context) Context

func (c *Context) Context() context.Context

type EventEnvelopeCreated

type EventEnvelopeCreated struct {
	ID int64
}

type EventEnvelopeDeleted

type EventEnvelopeDeleted struct {
	IDS []int64
}

type FileStore

type FileStore struct {
	Dir string
	FS  fs.FS
}

func NewFileStore

func NewFileStore(dir string) FileStore