file

Documentation

Index

• Variables
• type FileSink
  • func NewSink(log logger.Underlying, registry go_metrics.Registry) (*FileSink, error)
  • func (s *FileSink) Close()
  • func (s *FileSink) HttpInfo() map[string]float64
  • func (s *FileSink) Init(ctx context.Context, format formats.Format, compression kt.Compression, ...) error
  • func (s *FileSink) Send(ctx context.Context, payload *kt.Output)

Variables

var (
	FileDir     = flag.String("file_out", "./", "Write flows seen to log to this directory if set")
	FileWrite   = flag.Bool("file_on", false, "If true, start writting to file sink right away. Otherwise, wait for a USR1 signal")
	FlushDurSec = flag.Int("file_flush_sec", 60, "Create a new output file every this many seconds")
)

Types

type FileSink

type FileSink struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func NewSink

func NewSink(log logger.Underlying, registry go_metrics.Registry) (*FileSink, error)

func (*FileSink) Close

func (s *FileSink) Close()

func (*FileSink) HttpInfo

func (s *FileSink) HttpInfo() map[string]float64

func (*FileSink) Init

func (s *FileSink) Init(ctx context.Context, format formats.Format, compression kt.Compression, fmtr formats.Formatter) error

func (*FileSink) Send

func (s *FileSink) Send(ctx context.Context, payload *kt.Output)