datastore

Documentation

Index

• Variables
• type Configs
• type Database
• type ScanQuery
• type ScanResult

Variables

var ErrEmptyMigrateDirs = errors.New("datastore: empty migration directory list")

Types

type Configs

type Configs struct {
	Hosts    []string `json:"hosts"`
	Keyspace string   `json:"keyspace"`
	Table    string   `json:"table"`
}

type Database

type Database interface {
	Put(event *entities.Event) error
	Get(sample *entities.Event) (*entities.Event, error)
	Scan(sample *entities.Event, query *ScanQuery) (*ScanResult, error)

	Connect() error
	Disconnect() error
	Migrate(dirs []string) error
}

type ScanQuery

type ScanQuery struct {
	Cursor string
	Filter string
}

type ScanResult

type ScanResult struct {
	Errors []error
	Events []*entities.Event
	Cursor string
}