Documentation
¶
Index ¶
Constants ¶
View Source
const ( StatusOn = "on" StatusOff = "off" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
service.BaseService
// contains filtered or unexported fields
}
Service connects the event bus and event store together in order to store events coming from event bus
func NewEventStoreService ¶
func NewEventStoreService(idr TxEventStore, evsw events.EventSwitch) *Service
NewEventStoreService returns a new service instance
type TxEventStore ¶
type TxEventStore interface {
// Start starts the transaction event store
Start() error
// Stop stops the transaction event store
Stop() error
// GetType returns the event store type
GetType() string
// Append analyzes and appends a single transaction
// to the event store
Append(result types.TxResult) error
}
TxEventStore stores transaction events for later processing
Click to show internal directories.
Click to hide internal directories.