Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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 ¶
Types ¶
type Database ¶
type Database interface {
UseHook(hook db.TransactionHook)
}
type ResolverImpl ¶
type ResolverImpl struct {
Users ResolverUserQueries
}
func (*ResolverImpl) Resolve ¶
func (r *ResolverImpl) Resolve(anything interface{}) (err error)
type ResolverUserQueries ¶
type Service ¶
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:"-"` }
func NewService ¶
func NewService( ctx 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, hookSink *hook.Sink, auditSink *audit.Sink, elasticSearchSink *elasticsearch.Sink, ) *Service
func (*Service) DidCommitTx ¶
func (s *Service) DidCommitTx()
func (*Service) DispatchEventImmediately ¶
func (s *Service) DispatchEventImmediately(payload event.NonBlockingPayload) (err error)
DispatchEventImmediately dispatches the event immediately.
func (*Service) DispatchEventOnCommit ¶
DispatchEventOnCommit dispatches the event according to the tranaction lifecycle.
func (*Service) WillCommitTx ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.