type github.com/klauspost/compress/zstd.Encoder

30 uses

	github.com/klauspost/compress/zstd (current package)
		enc_jobs.go#L48: func (e *Encoder) startJobWorkers() {
		enc_jobs.go#L69: func (e *Encoder) jobWorker() {
		enc_jobs.go#L80: func (e *Encoder) compressJob(enc encoder, job *encJob) {
		enc_jobs.go#L180: func (e *Encoder) jobFlusher() {
		enc_jobs.go#L226: func (e *Encoder) shutdownJobWorkers() {
		enc_jobs.go#L239: func (e *Encoder) waitAllJobs() {
		enc_jobs.go#L251: func (e *Encoder) dispatchJob(final bool) error {
		encoder.go#L25: type Encoder struct {
		encoder.go#L71: func NewWriter(w io.Writer, opts ...EOption) (*Encoder, error) {
		encoder.go#L73: 	var e Encoder
		encoder.go#L90: func (e *Encoder) initialize() {
		encoder.go#L103: func (e *Encoder) Reset(w io.Writer) {
		encoder.go#L164: func (e *Encoder) ResetWithOptions(w io.Writer, opts ...EOption) error {
		encoder.go#L191: func (e *Encoder) ResetContentSize(w io.Writer, size int64) {
		encoder.go#L203: func (e *Encoder) Write(p []byte) (n int, err error) {
		encoder.go#L214: func (e *Encoder) writeJobs(p []byte) (n int, err error) {
		encoder.go#L249: func (e *Encoder) writeBlocks(p []byte) (n int, err error) {
		encoder.go#L285: func (e *Encoder) nextBlock(final bool) error {
		encoder.go#L444: func (e *Encoder) ReadFrom(r io.Reader) (n int64, err error) {
		encoder.go#L498: func (e *Encoder) readFromJobs(r io.Reader) (n int64, err error) {
		encoder.go#L547: func (e *Encoder) Flush() error {
		encoder.go#L572: func (e *Encoder) flushJobs() error {
		encoder.go#L589: func (e *Encoder) Close() error {
		encoder.go#L654: func (e *Encoder) closeJobs() error {
		encoder.go#L722: func (e *Encoder) EncodeAll(src, dst []byte) []byte {
		encoder.go#L731: func (e *Encoder) encodeAll(enc encoder, src, dst []byte) []byte {
		encoder.go#L843: func (e *Encoder) MaxEncodedSize(size int) int {
		simple_go124.go#L16: var simpleEnc weak.Pointer[Encoder]
		zip.go#L90: 	enc  *Encoder
		zip.go#L120: 		enc, ok := pool.Get().(*Encoder)