core: go.gazette.dev/core/broker/codecs Index | Files

package codecs

import "go.gazette.dev/core/broker/codecs"

Index

Package Files

codecs.go zstandard_enable.go

type Compressor Uses

type Compressor io.WriteCloser

Compressor is a WriteCloser where Close closes and releases Compressor state, potentially flushing final content to the underlying Writer, but does not Close or otherwise affect the underlying Writer.

func NewCodecWriter Uses

func NewCodecWriter(w io.Writer, codec pb.CompressionCodec) (Compressor, error)

NewCodecWriter returns a Compressor wrapping the Writer encoding with CompressionCodec.

type Decompressor Uses

type Decompressor io.ReadCloser

Decompressor is a ReadCloser where Close closes and releases Decompressor state, but does not Close or affect the underlying Reader.

func NewCodecReader Uses

func NewCodecReader(r io.Reader, codec pb.CompressionCodec) (Decompressor, error)

NewCodecReader returns a Decompressor of the Reader encoded with CompressionCodec.

Package codecs imports 7 packages (graph) and is imported by 6 packages. Updated 2019-09-12. Refresh now. Tools for package owners.