uploads

Documentation

Index

• type Config
• type IndexSet
  • func NewIndexSet(tableName, userID string, baseIndexSet storage.IndexSet, logger log.Logger) (IndexSet, error)
• type Table
  • func NewTable(name string, storageClient storage.Client) Table
• type TableManager
  • func NewTableManager(cfg Config, storageClient storage.Client, reg prometheus.Registerer, ...) (TableManager, error)

Types

type Config

type Config struct {
	UploadInterval time.Duration
	DBRetainPeriod time.Duration
}

type IndexSet

type IndexSet interface {
	Add(idx index.Index)
	Upload(ctx context.Context) error
	Cleanup(indexRetainPeriod time.Duration) error
	ForEach(callback index.ForEachIndexCallback) error
	Close()
}

func NewIndexSet

func NewIndexSet(tableName, userID string, baseIndexSet storage.IndexSet, logger log.Logger) (IndexSet, error)

type Table

type Table interface {
	Name() string
	AddIndex(userID string, idx index.Index) error
	ForEach(userID string, callback index.ForEachIndexCallback) error
	Upload(ctx context.Context) error
	Cleanup(indexRetainPeriod time.Duration) error
	Stop()
}

func NewTable

func NewTable(name string, storageClient storage.Client) Table

NewTable create a new table instance.

type TableManager

type TableManager interface {
	Stop()
	AddIndex(tableName, userID string, index index.Index) error
	ForEach(tableName, userID string, callback index.ForEachIndexCallback) error
}

func NewTableManager

func NewTableManager(cfg Config, storageClient storage.Client, reg prometheus.Registerer, logger log.Logger) (TableManager, error)