event

type Database interface {
	UseHook(hook db.TransactionHook)
}

type Logger struct{ *log.Logger }

type Resolver interface {
	Resolve(anything interface{}) (err error)
}

type ResolverImpl struct {
	Users ResolverUserQueries
}

type ResolverUserQueries interface {
	Get(id string, role accesscontrol.Role) (*model.User, error)
}

type Service struct {
	Context         context.Context
	AppID           config.AppID
	RemoteIP        httputil.RemoteIP
	UserAgentString httputil.UserAgentString
	Logger          Logger
	Database        Database
	Clock           clock.Clock
	Localization    *config.LocalizationConfig
	Store           Store
	Resolver        Resolver
	Sinks           []Sink

	NonBlockingPayloads []event.NonBlockingPayload `wire:"-"`
	NonBlockingEvents   []*event.Event             `wire:"-"`
	DatabaseHooked      bool                       `wire:"-"`
	IsDispatchEventErr  bool                       `wire:"-"`
}

type Sink interface {
	ReceiveBlockingEvent(e *event.Event) error
	ReceiveNonBlockingEvent(e *event.Event) error
}

type Store interface {
	NextSequenceNumber() (int64, error)
}

type StoreImpl struct {
	SQLBuilder  *appdb.SQLBuilder
	SQLExecutor *appdb.SQLExecutor
}