event

Documentation

Index

• Variables
• func NewNonBlockingEvent(seqNo int64, payload event.NonBlockingPayload, context event.Context) *event.Event
• type Database
• type Logger
  • func NewLogger(lf *log.Factory) Logger
• type Resolver
• type ResolverImpl
  • func (r *ResolverImpl) Resolve(ctx context.Context, anything interface{}) (err error)
• type ResolverUserQueries
• type Service
  • func NewService(appID config.AppID, remoteIP httputil.RemoteIP, ...) *Service
  • func (s *Service) DidCommitTx(ctx context.Context)
  • func (s *Service) DispatchEventImmediately(ctx context.Context, payload event.NonBlockingPayload) (err error)
  • func (s *Service) DispatchEventOnCommit(ctx context.Context, payload event.Payload) (err error)
  • func (s *Service) WillCommitTx(ctx context.Context) (err error)
• type Sink
• type Store
• type StoreImpl
  • func NewStoreImpl(sqlBuilder *appdb.SQLBuilder, sqlExecutor *appdb.SQLExecutor) *StoreImpl
  • func (s *StoreImpl) NextSequenceNumber(ctx context.Context) (seq int64, err error)

Variables

var DependencySet = wire.NewSet(
	NewLogger,
	NewService,
	NewStoreImpl,
	wire.Struct(new(ResolverImpl), "*"),
	wire.Bind(new(Store), new(*StoreImpl)),
	wire.Bind(new(Resolver), new(*ResolverImpl)),
)

Functions

func NewNonBlockingEvent

func NewNonBlockingEvent(seqNo int64, payload event.NonBlockingPayload, context event.Context) *event.Event

Types

type Database

type Database interface {
	UseHook(ctx context.Context, hook db.TransactionHook)
}

type Logger

type Logger struct{ *log.Logger }

func NewLogger

func NewLogger(lf *log.Factory) Logger

type Resolver

type Resolver interface {
	Resolve(ctx context.Context, anything interface{}) (err error)
}

type ResolverImpl

type ResolverImpl struct {
	Users ResolverUserQueries
}

func (*ResolverImpl) Resolve

func (r *ResolverImpl) Resolve(ctx context.Context, anything interface{}) (err error)

type ResolverUserQueries

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

type Service

type Service struct {
	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:"-"`
}

func NewService

func NewService(
	appID config.AppID,
	remoteIP httputil.RemoteIP,
	userAgentString httputil.UserAgentString,
	logger Logger,
	database Database,
	clock clock.Clock,
	localization *config.LocalizationConfig,
	store Store,
	resolver Resolver,
	hookSink *hook.Sink,
	auditSink *audit.Sink,
	searchSink *reindex.Sink,
	userInfoSink *userinfo.Sink,
) *Service

func (*Service) DidCommitTx

func (s *Service) DidCommitTx(ctx context.Context)

func (*Service) DispatchEventImmediately

func (s *Service) DispatchEventImmediately(ctx context.Context, payload event.NonBlockingPayload) (err error)

DispatchEventImmediately dispatches the event immediately.

func (*Service) DispatchEventOnCommit

func (s *Service) DispatchEventOnCommit(ctx context.Context, payload event.Payload) (err error)

DispatchEventOnCommit dispatches the event according to the tranaction lifecycle.

func (*Service) WillCommitTx

func (s *Service) WillCommitTx(ctx context.Context) (err error)

type Sink

type Sink interface {
	ReceiveBlockingEvent(ctx context.Context, e *event.Event) error
	ReceiveNonBlockingEvent(ctx context.Context, e *event.Event) error
}

type Store

type Store interface {
	NextSequenceNumber(ctx context.Context) (int64, error)
}

type StoreImpl

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

func NewStoreImpl

func NewStoreImpl(
	sqlBuilder *appdb.SQLBuilder,
	sqlExecutor *appdb.SQLExecutor) *StoreImpl

func (*StoreImpl) NextSequenceNumber

func (s *StoreImpl) NextSequenceNumber(ctx context.Context) (seq int64, err error)