cloudprovider

Documentation

Index

• type CachedCloudProvider
  • func NewCachedCloudProvider(logger logrus.FieldLogger, limiter *rate.Limiter, ...) *CachedCloudProvider
  • func (ccp *CachedCloudProvider) EstimatedTags() int
  • func (ccp *CachedCloudProvider) InfoSource() <-chan gostatsd.InstanceInfo
  • func (ccp *CachedCloudProvider) IpSink() chan<- gostatsd.Source
  • func (ccp *CachedCloudProvider) Peek(ip gostatsd.Source) (*gostatsd.Instance, bool)
  • func (ccp *CachedCloudProvider) Run(ctx context.Context)
  • func (ccp *CachedCloudProvider) RunMetrics(ctx context.Context, statser stats.Statser)

Types

type CachedCloudProvider

type CachedCloudProvider struct {
	// contains filtered or unexported fields
}

func NewCachedCloudProvider

func NewCachedCloudProvider(logger logrus.FieldLogger, limiter *rate.Limiter, cloudProvider gostatsd.CloudProvider, cacheOpts gostatsd.CacheOptions) *CachedCloudProvider

func (*CachedCloudProvider) EstimatedTags

func (ccp *CachedCloudProvider) EstimatedTags() int

func (*CachedCloudProvider) InfoSource

func (ccp *CachedCloudProvider) InfoSource() <-chan gostatsd.InstanceInfo

func (*CachedCloudProvider) IpSink

func (ccp *CachedCloudProvider) IpSink() chan<- gostatsd.Source

func (*CachedCloudProvider) Peek

func (ccp *CachedCloudProvider) Peek(ip gostatsd.Source) (*gostatsd.Instance, bool)

func (*CachedCloudProvider) Run

func (ccp *CachedCloudProvider) Run(ctx context.Context)

func (*CachedCloudProvider) RunMetrics

func (ccp *CachedCloudProvider) RunMetrics(ctx context.Context, statser stats.Statser)