s3

Documentation

Index

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

Variables

var (
	S3Bucket    = flag.String("s3_bucket", "", "AWS S3 Bucket to write flows to")
	S3Prefix    = flag.String("s3_prefix", "/kentik", "AWS S3 Object prefix")
	FlushDurSec = flag.Int("s3_flush_sec", 60, "Create a new output file every this many seconds")
)

Types

type S3Metric

type S3Metric struct {
	DeliveryErr go_metrics.Meter
	DeliveryWin go_metrics.Meter
}

type S3Sink

type S3Sink struct {
	logger.ContextL
	Bucket string
	// contains filtered or unexported fields
}

func NewSink

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

func (*S3Sink) Close

func (s *S3Sink) Close()

func (*S3Sink) HttpInfo

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

func (*S3Sink) Init

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

func (*S3Sink) Send

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