eventstore

package
v0.5.0-dev25 Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const BackupPath = "/etc/eventstore/backup"

Variables

This section is empty.

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

Directories

Path Synopsis
s3

Jump to

Keyboard shortcuts

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