file

Documentation

Index

• Variables
• type Config
• type File
  • func (f *File) Close() error
  • func (f *File) Init(ctx context.Context, cfg map[string]interface{}, opts ...outputs.Option) error
  • func (f *File) Metrics() []prometheus.Collector
  • func (f *File) SetEventProcessors(ps map[string]map[string]interface{}, log *log.Logger)
  • func (f *File) SetLogger(logger *log.Logger)
  • func (f *File) String() string
  • func (f *File) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Variables

var NumberOfReceivedMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Name: "number_of_received_messages_total",
	Help: "Number of messages received by file output",
}, []string{"file_name"})

var NumberOfWrittenBytes = prometheus.NewCounterVec(prometheus.CounterOpts{
	Name: "number_of_written_bytes_total",
	Help: "Number of bytes written to file",
}, []string{"file_name"})

var NumberOfWrittenMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Name: "number_of_written_messages_total",
	Help: "Number of messages written to file",
}, []string{"file_name"})

Types

type Config

type Config struct {
	FileName         string   `mapstructure:"filename,omitempty"`
	FileType         string   `mapstructure:"file-type,omitempty"`
	Format           string   `mapstructure:"format,omitempty"`
	Multiline        bool     `mapstructure:"multiline,omitempty"`
	Indent           string   `mapstructure:"indent,omitempty"`
	Separator        string   `mapstructure:"separator,omitempty"`
	EventProcessors  []string `mapstructure:"event-processors,omitempty"`
	ConcurrencyLimit int      `mapstructure:"concurrency-limit,omitempty"`
}

Config //

type File

type File struct {
	Cfg *Config
	// contains filtered or unexported fields
}

File //

func (*File) Close

func (f *File) Close() error

Close //

func (*File) Init

func (f *File) Init(ctx context.Context, cfg map[string]interface{}, opts ...outputs.Option) error

Init //

func (*File) Metrics

func (f *File) Metrics() []prometheus.Collector

Metrics //

func (*File) SetEventProcessors

func (f *File) SetEventProcessors(ps map[string]map[string]interface{}, log *log.Logger)

func (*File) SetLogger

func (f *File) SetLogger(logger *log.Logger)

func (*File) String

func (f *File) String() string

func (*File) Write

func (f *File) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Write //