collector

Documentation

Index

• type CloudWatchCollector
  • func (cw *CloudWatchCollector) Close() error
  • func (cw *CloudWatchCollector) Collect(ctx context.Context) ([]metrics.Metric, error)
• type CloudWatchCollectorDriver
  • func (cw *CloudWatchCollectorDriver) GetCollectInterval() int
  • func (cw *CloudWatchCollectorDriver) GetName() string
  • func (cw *CloudWatchCollectorDriver) NewCollector(instanceInfo brokerinfo.InstanceInfo) (MetricsCollector, error)
  • func (cw *CloudWatchCollectorDriver) SupportedTypes() []string
• type MetricsCollector
• type MetricsCollectorDriver
  • func NewCloudWatchCollectorDriver(intervalSeconds int, session client.ConfigProvider, ...) MetricsCollectorDriver
  • func NewMysqlMetricsCollectorDriver(brokerInfo brokerinfo.BrokerInfo, intervalSeconds int, timeout int, TLS string, ...) MetricsCollectorDriver
  • func NewPostgresMetricsCollectorDriver(brokerInfo brokerinfo.BrokerInfo, intervalSeconds int, timeout int, ...) MetricsCollectorDriver

Types

type CloudWatchCollector

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

CloudWatchCollector ...

func (*CloudWatchCollector) Close

func (cw *CloudWatchCollector) Close() error

Close ...

func (*CloudWatchCollector) Collect

func (cw *CloudWatchCollector) Collect(ctx context.Context) ([]metrics.Metric, error)

Collect ...

type CloudWatchCollectorDriver

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

CloudWatchCollectorDriver ...

func (*CloudWatchCollectorDriver) GetCollectInterval

func (cw *CloudWatchCollectorDriver) GetCollectInterval() int

func (*CloudWatchCollectorDriver) GetName

func (cw *CloudWatchCollectorDriver) GetName() string

GetName ...

func (*CloudWatchCollectorDriver) NewCollector

func (cw *CloudWatchCollectorDriver) NewCollector(instanceInfo brokerinfo.InstanceInfo) (MetricsCollector, error)

NewCollector ...

func (*CloudWatchCollectorDriver) SupportedTypes

func (cw *CloudWatchCollectorDriver) SupportedTypes() []string

type MetricsCollector

type MetricsCollector interface {
	Collect(ctx context.Context) ([]metrics.Metric, error)
	Close() error
}

MetricsCollector ...

type MetricsCollectorDriver

type MetricsCollectorDriver interface {
	NewCollector(instanceInfo brokerinfo.InstanceInfo) (MetricsCollector, error)
	GetName() string
	SupportedTypes() []string
	GetCollectInterval() int
}

MetricsCollectorDriver ...

func NewCloudWatchCollectorDriver

func NewCloudWatchCollectorDriver(intervalSeconds int, session client.ConfigProvider, brokerInfo brokerinfo.BrokerInfo, logger lager.Logger) MetricsCollectorDriver

NewCloudWatchCollectorDriver ...

func NewMysqlMetricsCollectorDriver

func NewMysqlMetricsCollectorDriver(
	brokerInfo brokerinfo.BrokerInfo,
	intervalSeconds int,
	timeout int,
	TLS string,
	logger lager.Logger,
) MetricsCollectorDriver

NewMysqlMetricsCollectorDriver ...

func NewPostgresMetricsCollectorDriver

func NewPostgresMetricsCollectorDriver(
	brokerInfo brokerinfo.BrokerInfo,
	intervalSeconds int,
	timeout int,
	SSLMode string,
	logger lager.Logger,
) MetricsCollectorDriver

NewPostgresMetricsCollectorDriver ...