event

type Dispatcher ¶

type Dispatcher interface {
	Publish(evt interface{})
}

Dispatcher is an interface for event dispatcher

type EventManager ¶

type EventManager struct {
	// contains filtered or unexported fields
}

EventManager is a manager for event dispatch

func NewEventManager(store EventStore) *EventManager

func (em *EventManager) Call(evt interface{}, listener Listener)

func (em *EventManager) Listen(listeners ...Listener)

func (em *EventManager) Publish(evt interface{})

type EventStore ¶

type EventStore interface {
	Listen(eventName string, listener Listener)
	Publish(eventName string, evt interface{})
	SetManager(*EventManager)
}

EventStore is a interface for event store

type Listener ¶

type Listener interface{}

Listener is a event listener

type MemoryEventStore ¶

type MemoryEventStore struct {
	// contains filtered or unexported fields
}

MemoryEventStore is a event store for sync operations

func NewMemoryEventStore() *MemoryEventStore

func (eventStore *MemoryEventStore) Listen(evtType string, listener Listener)

func (eventStore *MemoryEventStore) Publish(evtType string, evt interface{})

func (eventStore *MemoryEventStore) SetManager(manager *EventManager)

type MigrationEndedEvent ¶

type MigrationEndedEvent struct {
	SQL string
}

type MigrationStartedEvent ¶

type MigrationStartedEvent struct {
	SQL string
}

type MigrationsEndedEvent ¶

type MigrationsEndedEvent struct{}

type MigrationsStartedEvent ¶

type MigrationsStartedEvent struct{}

type QueryExecutedEvent ¶

type QueryExecutedEvent struct {
	SQL      string
	Bindings []interface{}
	Time     time.Duration
}

QueryExecutedEvent each SQL query executed by your application will publish a QueryExecutedEvent

type TransactionBeginningEvent ¶

type TransactionBeginningEvent struct{}

TransactionBeginningEvent fired when a new transaction started

type TransactionCommittedEvent ¶

type TransactionCommittedEvent struct{}

TransactionCommittedEvent fired when a transaction has been committed

type TransactionRolledBackEvent ¶

type TransactionRolledBackEvent struct{}

TransactionRolledBackEvent fired when a transaction has been rollback