trace

Documentation

Index

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

Types

type EventStore

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

EventStore wraps an EventStore and adds debug tracing.

func NewEventStore

func NewEventStore(eventStore eh.EventStore) *EventStore

NewEventStore creates a new EventStore.

func (*EventStore) GetTrace

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

GetTrace returns the events that happened during the tracing.

func (*EventStore) ResetTrace

func (s *EventStore) ResetTrace()

ResetTrace resets the trace.

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) StartTracing

func (s *EventStore) StartTracing()

StartTracing starts the tracing of events.

func (*EventStore) StopTracing

func (s *EventStore) StopTracing()

StopTracing stops the tracing of events.