file

Documentation

Index

• Variables
• type Config
• type File
  • func (f *File) Close() error
  • func (f *File) Init(ctx context.Context, cfg map[string]interface{}, logger *log.Logger) error
  • func (f *File) Metrics() []prometheus.Collector
  • func (f *File) String() string
  • func (f *File) Write(_ 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"`
}

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{}, logger *log.Logger) error

Init //

func (*File) Metrics

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

Metrics //

func (*File) String

func (f *File) String() string

func (*File) Write

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

Write //