encoder

package

v0.84.0 Latest Latest Go to latest Published: Jul 31, 2026 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

View Source

const (
	EncoderTypeJSON = "json"
	EncoderTypeRaw  = "raw"
)

View Source

var ErrFieldNotFound = errors.New("field not found")

This section is empty.

type Encoder interface {
	Encode(event *pipeline.Event, buf []byte) ([]byte, error)
}

func NewEncoder(cfg EncodingConfig) (Encoder, error)

type EncodingConfig struct {
	Type   string          `json:"type" default:"json" options:"json|raw"`
	Params json.RawMessage `json:"params"`
}

type JSONEncoder struct{}

func (e *JSONEncoder) Encode(event *pipeline.Event, buf []byte) ([]byte, error)

type JSONEncoderParams struct{}

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

func (e *RawEncoder) Encode(event *pipeline.Event, buf []byte) ([]byte, error)

type RawEncoderParams struct {
	Field string `json:"field"`
}