eventstore

Documentation

Index

• Constants
• func NewApiServer(store es.EventStore, bus es.EventBusPublisher) *apiServer
• func NewEventStore() (eventsourcing.EventStore, error)
• func NewEventStoreClient(ctx context.Context, eventStoreAddr string) (*grpc.ClientConn, esApi.EventStoreClient, error)
• type BackupManager
  • func NewBackupManager(store eventsourcing.EventStore, retention int) (*BackupManager, error)
  • func (bm *BackupManager) RunBackup(ctx context.Context) (*backup.BackupResult, error)
  • func (bm *BackupManager) RunPurge(ctx context.Context) (*backup.PurgeResult, error)
  • func (bm *BackupManager) RunRestore(ctx context.Context, backupIdentifier string) (*backup.RestoreResult, error)
• type TestEnv
  • func NewTestEnvWithParent(testEnv *test.TestEnv) (*TestEnv, error)
  • func (env *TestEnv) GetApiAddr() string
  • func (t *TestEnv) GetMessagingTestEnv() *rabbitmq.TestEnv
  • func (env *TestEnv) Shutdown() error

Constants

const BackupPath = "/etc/eventstore/backup"

Functions

func NewApiServer

func NewApiServer(store es.EventStore, bus es.EventBusPublisher) *apiServer

NewApiServer returns a new configured instance of apiServer

func NewEventStore

func NewEventStore() (eventsourcing.EventStore, error)

func NewEventStoreClient

func NewEventStoreClient(ctx context.Context, eventStoreAddr string) (*grpc.ClientConn, esApi.EventStoreClient, error)

Types

type BackupManager

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

func NewBackupManager

func NewBackupManager(store eventsourcing.EventStore, retention int) (*BackupManager, error)

NewBackupManager creates a new backup manager configured by config files taken from eventstore.BackupPath and environment config.

func (*BackupManager) RunBackup

func (bm *BackupManager) RunBackup(ctx context.Context) (*backup.BackupResult, error)

func (*BackupManager) RunPurge

func (bm *BackupManager) RunPurge(ctx context.Context) (*backup.PurgeResult, error)

func (*BackupManager) RunRestore

func (bm *BackupManager) RunRestore(ctx context.Context, backupIdentifier string) (*backup.RestoreResult, error)

type TestEnv

type TestEnv struct {
	*test.TestEnv

	MetricsListener net.Listener
	// contains filtered or unexported fields
}

func NewTestEnvWithParent

func NewTestEnvWithParent(testEnv *test.TestEnv) (*TestEnv, error)

func (*TestEnv) GetApiAddr

func (env *TestEnv) GetApiAddr() string

func (*TestEnv) GetMessagingTestEnv

func (t *TestEnv) GetMessagingTestEnv() *rabbitmq.TestEnv

func (*TestEnv) Shutdown

func (env *TestEnv) Shutdown() error