Function NewEncoder

tsdb/compression/compression.go:48–56

NewEncoder creates a new Encoder. Returns an error if the zstd encoder cannot be initialized.

()

// NewEncoder creates a new Encoder. Returns an error if the zstd encoder cannot
// be initialized.
func NewEncoder() (*Encoder, error) {
	e := &Encoder{}
	w, err := zstd.NewWriter(nil)
	if err != nil {
		return nil, err
	}
	e.w = w
	return e, nil
}

// Encode returns the encoded form of src for the given compression type. It also
// returns the indicator if the compression was performed. Encode may skip