publisher

package
v0.0.0-...-0e8e12d Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AmazonCloudWatchPublisher

type AmazonCloudWatchPublisher struct {
	Client *cloudwatch.Client
}

func NewAmazonCloudEatchPublisher

func NewAmazonCloudEatchPublisher() (*AmazonCloudWatchPublisher, error)

func (*AmazonCloudWatchPublisher) Publish

func (p *AmazonCloudWatchPublisher) Publish(ctx context.Context, metrics types.Metrics)

type Publisher

type Publisher interface {
	Publish(context.Context, types.Metrics)
}

type PublisherManager

type PublisherManager struct {
	Publishers []Publisher
}

func (*PublisherManager) Run

func (p *PublisherManager) Run(ctx context.Context, recieve <-chan types.Metrics)

type StdoutPublisher

type StdoutPublisher struct{}

func (*StdoutPublisher) Publish

func (p *StdoutPublisher) Publish(ctx context.Context, metrics types.Metrics)

Jump to

Keyboard shortcuts

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