gcloud

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	GCloudBucket      = flag.String("gcloud_bucket", "", "GCloud Storage Bucket to write flows to")
	GCloudPrefix      = flag.String("gcloud_prefix", "/kentik", "GCloud Storage object prefix")
	GCloudContentType = flag.String("gcloud_content_type", "application/json", "GCloud Storage Content Type")
	FlushDurSec       = flag.Int("gcloud_flush_sec", 60, "Create a new output file every this many seconds")
)

Functions

This section is empty.

Types

type GCloudMetric

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

type GCloudSink

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

func NewSink

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

func (*GCloudSink) Close

func (s *GCloudSink) Close()

func (*GCloudSink) HttpInfo

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

func (*GCloudSink) Init

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

func (*GCloudSink) Send

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL