local

Documentation

Index

• func New(cfg *Config) (backend.Reader, backend.Writer, backend.Compactor, error)
• type Backend
  • func NewBackend(cfg *Config) (*Backend, error)
  • func (rw *Backend) Append(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) (backend.AppendTracker, error)
  • func (rw *Backend) BlockMeta(ctx context.Context, blockID uuid.UUID, tenantID string) (*backend.BlockMeta, error)
  • func (rw *Backend) Blocks(ctx context.Context, tenantID string) ([]uuid.UUID, error)
  • func (rw *Backend) ClearBlock(blockID uuid.UUID, tenantID string) error
  • func (rw *Backend) CloseAppend(ctx context.Context, tracker backend.AppendTracker) error
  • func (rw *Backend) CompactedBlockMeta(blockID uuid.UUID, tenantID string) (*backend.CompactedBlockMeta, error)
  • func (rw *Backend) MarkBlockCompacted(blockID uuid.UUID, tenantID string) error
  • func (rw *Backend) Read(ctx context.Context, name string, blockID uuid.UUID, tenantID string) ([]byte, error)
  • func (rw *Backend) ReadRange(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error
  • func (rw *Backend) ReadReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string) (io.ReadCloser, int64, error)
  • func (rw *Backend) Shutdown()
  • func (rw *Backend) Tenants(ctx context.Context) ([]string, error)
  • func (rw *Backend) Write(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error
  • func (rw *Backend) WriteBlockMeta(ctx context.Context, meta *backend.BlockMeta) error
  • func (rw *Backend) WriteReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error
• type Config

Functions

func New

func New(cfg *Config) (backend.Reader, backend.Writer, backend.Compactor, error)

Types

type Backend

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

func NewBackend

func NewBackend(cfg *Config) (*Backend, error)

func (*Backend) Append

func (rw *Backend) Append(ctx context.Context, name string, blockID uuid.UUID, tenantID string, tracker backend.AppendTracker, buffer []byte) (backend.AppendTracker, error)

Append implements backend.Writer

func (*Backend) BlockMeta

func (rw *Backend) BlockMeta(ctx context.Context, blockID uuid.UUID, tenantID string) (*backend.BlockMeta, error)

BlockMeta implements backend.Reader

func (*Backend) Blocks

func (rw *Backend) Blocks(ctx context.Context, tenantID string) ([]uuid.UUID, error)

Blocks implements backend.Reader

func (*Backend) ClearBlock

func (rw *Backend) ClearBlock(blockID uuid.UUID, tenantID string) error

func (*Backend) CloseAppend

func (rw *Backend) CloseAppend(ctx context.Context, tracker backend.AppendTracker) error

CloseAppend implements backend.Writer

func (*Backend) CompactedBlockMeta

func (rw *Backend) CompactedBlockMeta(blockID uuid.UUID, tenantID string) (*backend.CompactedBlockMeta, error)

func (*Backend) MarkBlockCompacted

func (rw *Backend) MarkBlockCompacted(blockID uuid.UUID, tenantID string) error

func (*Backend) Read

func (rw *Backend) Read(ctx context.Context, name string, blockID uuid.UUID, tenantID string) ([]byte, error)

Read implements backend.Reader

func (*Backend) ReadRange

func (rw *Backend) ReadRange(ctx context.Context, name string, blockID uuid.UUID, tenantID string, offset uint64, buffer []byte) error

ReadRange implements backend.Reader

func (*Backend) ReadReader

func (rw *Backend) ReadReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string) (io.ReadCloser, int64, error)

func (*Backend) Shutdown

func (rw *Backend) Shutdown()

Shutdown implements backend.Reader

func (*Backend) Tenants

func (rw *Backend) Tenants(ctx context.Context) ([]string, error)

Tenants implements backend.Reader

func (*Backend) Write

func (rw *Backend) Write(ctx context.Context, name string, blockID uuid.UUID, tenantID string, buffer []byte) error

Write implements backend.Writer

func (*Backend) WriteBlockMeta

func (rw *Backend) WriteBlockMeta(ctx context.Context, meta *backend.BlockMeta) error

WriteBlockMeta implements backend.Writer

func (*Backend) WriteReader

func (rw *Backend) WriteReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string, data io.Reader, _ int64) error

WriteReader implements backend.Writer

type Config

type Config struct {
	Path string `yaml:"path"`
}