recorder

Documentation

Index

• type EventStore
  • func NewEventStore(eventStore eh.EventStore) *EventStore
  • func (s *EventStore) GetRecord() []eh.Event
  • func (s *EventStore) ResetTrace()
  • func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersion int) error
  • func (s *EventStore) StartRecording()
  • func (s *EventStore) StopRecording()

Types

type EventStore

type EventStore struct {
	eh.EventStore
	// contains filtered or unexported fields
}

EventStore wraps an eventhorizon.EventStore and adds debug event recording.

func NewEventStore

func NewEventStore(eventStore eh.EventStore) *EventStore

NewEventStore creates a new EventStore.

func (*EventStore) GetRecord

func (s *EventStore) GetRecord() []eh.Event

GetRecord returns the events that happened during the recording.

func (*EventStore) ResetTrace

func (s *EventStore) ResetTrace()

ResetTrace resets the record.

func (*EventStore) Save

func (s *EventStore) Save(ctx context.Context, events []eh.Event, originalVersion int) error

Save implements the Save method of the eventhorizon.EventStore interface.

func (*EventStore) StartRecording

func (s *EventStore) StartRecording()

StartRecording starts recording of handled events.

func (*EventStore) StopRecording

func (s *EventStore) StopRecording()

StopRecording stops recording of handled events.