gcppubsub

Documentation

Index

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

Variables

var (
	GCPPubSubProjectID = flag.String("gcp_pubsub_project_id", "", "GCP PubSub Project ID to use")
	GCPPubSubTopic     = flag.String("gcp_pubsub_topic", "", "GCP PubSub Topic to publish to")
)

Types

type GCPPubSub

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

func NewSink

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

func (*GCPPubSub) Close

func (s *GCPPubSub) Close()

func (*GCPPubSub) HttpInfo

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

func (*GCPPubSub) Init

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

func (*GCPPubSub) Send

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

type GCPPubSubMetric

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