scylla

Documentation

Index

• Variables
• func New(ctx context.Context, cfg *datastore.Configs) (datastore.Database, error)
• type Scylla
  • func (db *Scylla) Connect() error
  • func (db *Scylla) Disconnect() error
  • func (db *Scylla) Get(sample *entities.Event) (*entities.Event, error)
  • func (db *Scylla) Migrate(dirs []string) error
  • func (db *Scylla) Put(event *entities.Event) error
  • func (db *Scylla) Scan(sample *entities.Event, query *datastore.ScanQuery) (*datastore.ScanResult, error)

Variables

var (
	ErrConnectFailed      = errors.New("datastore.scylla: could not establish connection to hosts")
	ErrMigrationScanFiles = errors.New("datastore.scylla: got error when scanned migration file")
	ErrMigrationNoFile    = errors.New("datastore.scylla: no migration file was found")
	ErrMigrationRunFailed = errors.New("datastore.scylla: could not run migration")
)

Functions

func New

func New(ctx context.Context, cfg *datastore.Configs) (datastore.Database, error)

Types

type Scylla

type Scylla struct {
	Configs *datastore.Configs
	Logger  *zap.SugaredLogger
	// contains filtered or unexported fields
}

func (*Scylla) Connect

func (db *Scylla) Connect() error

func (*Scylla) Disconnect

func (db *Scylla) Disconnect() error

func (*Scylla) Get

func (db *Scylla) Get(sample *entities.Event) (*entities.Event, error)

func (*Scylla) Migrate

func (db *Scylla) Migrate(dirs []string) error

func (*Scylla) Put

func (db *Scylla) Put(event *entities.Event) error

func (*Scylla) Scan

func (db *Scylla) Scan(sample *entities.Event, query *datastore.ScanQuery) (*datastore.ScanResult, error)