encoding

Documentation

Index

• func CopyBlock(ctx context.Context, meta *backend.BlockMeta, from backend.Reader, ...) error
• func OpenBlock(meta *backend.BlockMeta, r backend.Reader) (common.BackendBlock, error)
• type VersionedEncoding
  • func DefaultEncoding() VersionedEncoding
  • func FromVersion(v string) (VersionedEncoding, error)

Functions

func CopyBlock

func CopyBlock(ctx context.Context, meta *backend.BlockMeta, from backend.Reader, to backend.Writer) error

CopyBlock from one backend to another. It automatically chooses the encoding for the given block.

func OpenBlock

func OpenBlock(meta *backend.BlockMeta, r backend.Reader) (common.BackendBlock, error)

OpenBlock for reading in the backend. It automatically chooes the encoding for the given block.

Types

type VersionedEncoding

type VersionedEncoding interface {
	Version() string

	// OpenBlock for reading
	OpenBlock(meta *backend.BlockMeta, r backend.Reader) (common.BackendBlock, error)

	// NewCompactor creates a Compactor that can be used to combine blocks of this
	// encoding. It is expected to use internal details for efficiency.
	NewCompactor(common.CompactionOptions) common.Compactor

	// CreateBlock with the given attributes and trace contents.
	// BlockMeta is used as a container for many options. Required fields:
	// * BlockID
	// * TenantID
	// * Encoding
	// * DataEncoding
	// * StartTime
	// * EndTime
	// * TotalObjects
	CreateBlock(ctx context.Context, cfg *common.BlockConfig, meta *backend.BlockMeta, i common.Iterator, dec model.ObjectDecoder, r backend.Reader, to backend.Writer) (*backend.BlockMeta, error)

	// CopyBlock from one backend to another.
	CopyBlock(ctx context.Context, meta *backend.BlockMeta, from backend.Reader, to backend.Writer) error
}

VersionedEncoding represents a backend block version, and the methods to read/write them.

func DefaultEncoding

func DefaultEncoding() VersionedEncoding

DefaultEncoding for newly written blocks.

func FromVersion

func FromVersion(v string) (VersionedEncoding, error)

FromVersion returns a versioned encoding for the provided string