file

Documentation

Index

• type FileOutput
  • func (fo *FileOutput) Process(_ context.Context, entry *entry.Entry) error
  • func (fo *FileOutput) Start() error
  • func (fo *FileOutput) Stop() error
• type FileOutputConfig
  • func NewFileOutputConfig(operatorID string) *FileOutputConfig
  • func (c FileOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type FileOutput

type FileOutput struct {
	helper.OutputOperator
	// contains filtered or unexported fields
}

FileOutput is an operator that writes logs to a file.

func (*FileOutput) Process

func (fo *FileOutput) Process(_ context.Context, entry *entry.Entry) error

Process will write an entry to the output file.

func (*FileOutput) Start

func (fo *FileOutput) Start() error

Start will open the output file.

func (*FileOutput) Stop

func (fo *FileOutput) Stop() error

Stop will close the output file.

type FileOutputConfig

type FileOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`

	Path   string `json:"path" yaml:"path"`
	Format string `json:"format,omitempty" path:"format,omitempty"`
}

FileOutputConfig is the configuration of a file output operatorn.

func NewFileOutputConfig

func NewFileOutputConfig(operatorID string) *FileOutputConfig

NewFileOutputConfig creates a new file output config with default values

func (FileOutputConfig) Build

func (c FileOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a file output operator.