eventstore

package
v0.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 5, 2024 License: Apache-2.0, UNKNOWN not legal advice Imports: 0 Imported by: 0

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

func (*Service) OnStart

func (is *Service) OnStart() error

func (*Service) OnStop

func (is *Service) OnStop()

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL