buntdb

Documentation

Index

• type Config
• type Storage
  • func NewStorage(cfg Config) *Storage
  • func (s *Storage) CreateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)
  • func (s *Storage) DeleteLogs(ctx context.Context, req storage.DeleteLogsRequest) (*solaris.DeleteLogsResult, error)
  • func (s *Storage) GetChunks(ctx context.Context, logID string) ([]logfs.ChunkInfo, error)
  • func (s *Storage) GetLastChunk(ctx context.Context, logID string) (logfs.ChunkInfo, error)
  • func (s *Storage) GetLogByID(ctx context.Context, id string) (*solaris.Log, error)
  • func (s *Storage) Init(ctx context.Context) error
  • func (s *Storage) QueryLogs(ctx context.Context, qr storage.QueryLogsRequest) (*solaris.QueryLogsResult, error)
  • func (s *Storage) Shutdown()
  • func (s *Storage) UpdateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)
  • func (s *Storage) UpsertChunkInfos(ctx context.Context, logID string, cis []logfs.ChunkInfo) error

Types

type Config

type Config struct {
	// DBFilePath specifies path to the DB file
	// if empty the in-mem version is used
	DBFilePath string
}

Config specifies configuration for logs meta storage based on BuntDB https://github.com/tidwall/buntdb

type Storage

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

Storage is the logs meta storage

func NewStorage

func NewStorage(cfg Config) *Storage

NewStorage creates new logs meta storage based on BuntDB

func (*Storage) CreateLog

func (s *Storage) CreateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

CreateLog implements storage.Logs

func (*Storage) DeleteLogs

func (s *Storage) DeleteLogs(ctx context.Context, req storage.DeleteLogsRequest) (*solaris.DeleteLogsResult, error)

DeleteLogs implements storage.Logs

func (*Storage) GetChunks

func (s *Storage) GetChunks(ctx context.Context, logID string) ([]logfs.ChunkInfo, error)

GetChunks implements logfs.LogsMetaStorage

func (*Storage) GetLastChunk

func (s *Storage) GetLastChunk(ctx context.Context, logID string) (logfs.ChunkInfo, error)

GetLastChunk implements logfs.LogsMetaStorage

func (*Storage) GetLogByID

func (s *Storage) GetLogByID(ctx context.Context, id string) (*solaris.Log, error)

GetLogByID implements storage.Logs

func (*Storage) Init

func (s *Storage) Init(ctx context.Context) error

Init implements linker.Initializer

func (*Storage) QueryLogs

func (s *Storage) QueryLogs(ctx context.Context, qr storage.QueryLogsRequest) (*solaris.QueryLogsResult, error)

QueryLogs implements storage.Logs

func (*Storage) Shutdown

func (s *Storage) Shutdown()

Shutdown implements linker.Shutdowner

func (*Storage) UpdateLog

func (s *Storage) UpdateLog(ctx context.Context, log *solaris.Log) (*solaris.Log, error)

UpdateLog implements storage.Logs

func (*Storage) UpsertChunkInfos

func (s *Storage) UpsertChunkInfos(ctx context.Context, logID string, cis []logfs.ChunkInfo) error

UpsertChunkInfos implements logfs.LogsMetaStorage