compression

Documentation

Index

• type CompressionStrategy
• type GzipCompression
  • func NewGzipCompression(level int, metrics *metrics.QuantumStorageMetrics, tracer tracing.Tracer) *GzipCompression
  • func (c *GzipCompression) Algorithm() string
  • func (c *GzipCompression) Compress(ctx context.Context, data []byte) ([]byte, error)
  • func (c *GzipCompression) Decompress(ctx context.Context, data []byte) ([]byte, error)
• type ZstdCompression
  • func NewZstdCompression(metrics *metrics.QuantumStorageMetrics, tracer tracing.Tracer) (*ZstdCompression, error)
  • func (c *ZstdCompression) Algorithm() string
  • func (c *ZstdCompression) Compress(ctx context.Context, data []byte) ([]byte, error)
  • func (c *ZstdCompression) Decompress(ctx context.Context, data []byte) ([]byte, error)

Types

type CompressionStrategy

type CompressionStrategy interface {
	Compress(ctx context.Context, data []byte) ([]byte, error)
	Decompress(ctx context.Context, data []byte) ([]byte, error)
	Algorithm() string
}

type GzipCompression

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

func NewGzipCompression

func NewGzipCompression(
	level int,
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
) *GzipCompression

func (*GzipCompression) Algorithm

func (c *GzipCompression) Algorithm() string

func (*GzipCompression) Compress

func (c *GzipCompression) Compress(ctx context.Context, data []byte) ([]byte, error)

func (*GzipCompression) Decompress

func (c *GzipCompression) Decompress(ctx context.Context, data []byte) ([]byte, error)

type ZstdCompression

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

func NewZstdCompression

func NewZstdCompression(
	metrics *metrics.QuantumStorageMetrics,
	tracer tracing.Tracer,
) (*ZstdCompression, error)

func (*ZstdCompression) Algorithm

func (c *ZstdCompression) Algorithm() string

func (*ZstdCompression) Compress

func (c *ZstdCompression) Compress(ctx context.Context, data []byte) ([]byte, error)

func (*ZstdCompression) Decompress

func (c *ZstdCompression) Decompress(ctx context.Context, data []byte) ([]byte, error)