util

Documentation

Index

• func CompactedMetaFileName(blockID uuid.UUID, tenantID string) string
• func FileExists(filename string) error
• func MetaFileName(blockID uuid.UUID, tenantID string) string
• func ObjectFileName(blockID uuid.UUID, tenantID string, name string) string
• func RootPath(blockID uuid.UUID, tenantID string) string
• type MockReader
  • func (m *MockReader) BlockMeta(ctx context.Context, blockID uuid.UUID, tenantID string) (*backend.BlockMeta, error)
  • func (m *MockReader) Blocks(ctx context.Context, tenantID string) ([]uuid.UUID, error)
  • func (m *MockReader) Read(ctx context.Context, name string, blockID uuid.UUID, tenantID string) ([]byte, error)
  • func (m *MockReader) ReadRange(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error
  • func (m *MockReader) ReadReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string) (io.ReadCloser, int64, error)
  • func (m *MockReader) Shutdown()
  • func (m *MockReader) Tenants(ctx context.Context) ([]string, error)
• type MockWriter
  • func (m *MockWriter) Append(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) (backend.AppendTracker, error)
  • func (m *MockWriter) CloseAppend(ctx context.Context, tracker backend.AppendTracker) error
  • func (m *MockWriter) Write(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error
  • func (m *MockWriter) WriteBlockMeta(ctx context.Context, meta *backend.BlockMeta) error
  • func (m *MockWriter) WriteReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string, ...) error

Functions

func CompactedMetaFileName

func CompactedMetaFileName(blockID uuid.UUID, tenantID string) string

func FileExists

func FileExists(filename string) error

func MetaFileName

func MetaFileName(blockID uuid.UUID, tenantID string) string

func ObjectFileName

func ObjectFileName(blockID uuid.UUID, tenantID string, name string) string

func RootPath

func RootPath(blockID uuid.UUID, tenantID string) string

nolint:interfacer

Types

type MockReader

type MockReader struct {
	T      []string
	B      []uuid.UUID        // blocks
	M      *backend.BlockMeta // meta
	R      []byte             // read
	Range  []byte             // ReadRange
	ReadFn func(name string, blockID uuid.UUID, tenantID string) ([]byte, error)
}

func (*MockReader) BlockMeta

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

func (*MockReader) Blocks

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

func (*MockReader) Read

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

func (*MockReader) ReadRange

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

func (*MockReader) ReadReader

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

func (*MockReader) Shutdown

func (m *MockReader) Shutdown()

func (*MockReader) Tenants

func (m *MockReader) Tenants(ctx context.Context) ([]string, error)

type MockWriter

type MockWriter struct {
}

func (*MockWriter) Append

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

func (*MockWriter) CloseAppend

func (m *MockWriter) CloseAppend(ctx context.Context, tracker backend.AppendTracker) error

func (*MockWriter) Write

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

func (*MockWriter) WriteBlockMeta

func (m *MockWriter) WriteBlockMeta(ctx context.Context, meta *backend.BlockMeta) error

func (*MockWriter) WriteReader

func (m *MockWriter) WriteReader(ctx context.Context, name string, blockID uuid.UUID, tenantID string, data io.Reader, size int64) error