compression

type Compressor ¶

type Compressor interface {
	Compress(prefix, data []byte) ([]byte, error)
	Decompress(data []byte) ([]byte, error)
	ID() byte
}

Compressor defines interface for compression and decompression.

func ZStd() Compressor

type Marshaler ¶

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

Marshaler compresses and decompresses data from the underlying marshaler.

Marshaler also handles case when the underlying data is not compressed.

The trick used is that `0x00` can't start a valid protobuf message, so we use `0x00` as a marker for compressed data.

func NewMarshaler(m store.Marshaler, c Compressor, minSize int) *Marshaler

func (m *Marshaler) MarshalResource(r resource.Resource) ([]byte, error)

func (m *Marshaler) UnmarshalResource(b []byte) (resource.Resource, error)