store

Documentation

Index

• Constants
• type Config
• type EventStore
  • func New(ctx context.Context, cfg Config) (*EventStore, error)
  • func (e *EventStore) Events(typ string, idx []byte) ([]*messages.Event, error)
  • func (e *EventStore) Start() error
  • func (e *EventStore) Wait() chan error
• type Storage

Constants

const LoggerTag = "EVENTSTORE"

Types

type Config

type Config struct {
	Storage   Storage
	Transport transport.Transport
	Log       log.Logger
}

Config contains configuration parameters for EventStore.

type EventStore

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

EventStore listens for event messages using the transport and stores them for later use.

func New

func New(ctx context.Context, cfg Config) (*EventStore, error)

New returns a new instance of the EventStore struct.

func (*EventStore) Events

func (e *EventStore) Events(typ string, idx []byte) ([]*messages.Event, error)

func (*EventStore) Start

func (e *EventStore) Start() error

func (*EventStore) Wait

func (e *EventStore) Wait() chan error

Wait waits until the context is canceled or until an error occurs.

type Storage

type Storage interface {
	// Add adds a message to the store. If the message already exists, no error
	// will be returned. Method is thread safe.
	Add(msg *messages.Event) error
	// Get returns a message form the store. If the message does not exist,
	// nil will be returned. Method is thread safe.
	Get(typ string, idx []byte) ([]*messages.Event, error)
}