externalmetrics

Documentation

Index

• Constants
• func IsInvalidMetricRequestError(err error) bool
• func TimeSpan() string
• type AzureClientFactory
• type AzureExternalMetricClient
  • func NewMonitorClient(defaultsubscriptionID string) AzureExternalMetricClient
  • func NewServiceBusSubscriptionClient(defaultSubscriptionID string) AzureExternalMetricClient
• type AzureExternalMetricClientFactory
  • func (f AzureExternalMetricClientFactory) GetAzureExternalMetricClient(clientType string) (client AzureExternalMetricClient, err error)
• type AzureExternalMetricClientProvider
• type AzureExternalMetricRequest
  • func ParseAzureMetric(metricSelector labels.Selector, defaultSubscriptionID string) (AzureExternalMetricRequest, error)
  • func (amr AzureExternalMetricRequest) MetricResourceURI() string
  • func (amr AzureExternalMetricRequest) Validate() error
• type AzureExternalMetricResponse
• type InvalidMetricRequestError
  • func (i InvalidMetricRequestError) Error() string

Constants

const (
	Monitor                string = "azuremonitor"
	ServiceBusSubscription string = "servicebussubscription"
)

Functions

func IsInvalidMetricRequestError

func IsInvalidMetricRequestError(err error) bool

func TimeSpan

func TimeSpan() string

TimeSpan sets the default time to aggregate a metric

Types

type AzureClientFactory

type AzureClientFactory interface {
	GetAzureExternalMetricClient(clientType string) (AzureExternalMetricClient, error)
}

type AzureExternalMetricClient

type AzureExternalMetricClient interface {
	GetAzureMetric(azMetricRequest AzureExternalMetricRequest) (AzureExternalMetricResponse, error)
}

func NewMonitorClient

func NewMonitorClient(defaultsubscriptionID string) AzureExternalMetricClient

func NewServiceBusSubscriptionClient

func NewServiceBusSubscriptionClient(defaultSubscriptionID string) AzureExternalMetricClient

type AzureExternalMetricClientFactory

type AzureExternalMetricClientFactory struct {
	DefaultSubscriptionID string
}

func (AzureExternalMetricClientFactory) GetAzureExternalMetricClient

func (f AzureExternalMetricClientFactory) GetAzureExternalMetricClient(clientType string) (client AzureExternalMetricClient, err error)

type AzureExternalMetricClientProvider

type AzureExternalMetricClientProvider interface {
	NewClient(defaultSubscriptionID string)
}

type AzureExternalMetricRequest

type AzureExternalMetricRequest struct {
	MetricName                string
	SubscriptionID            string
	Type                      string
	ResourceName              string
	ResourceProviderNamespace string
	ResourceType              string
	Aggregation               string
	Timespan                  string
	Filter                    string
	ResourceGroup             string
	Namespace                 string
	Topic                     string
	Subscription              string
}

func ParseAzureMetric

func ParseAzureMetric(metricSelector labels.Selector, defaultSubscriptionID string) (AzureExternalMetricRequest, error)

func (AzureExternalMetricRequest) MetricResourceURI

func (amr AzureExternalMetricRequest) MetricResourceURI() string

func (AzureExternalMetricRequest) Validate

func (amr AzureExternalMetricRequest) Validate() error

type AzureExternalMetricResponse

type AzureExternalMetricResponse struct {
	Total float64
}

type InvalidMetricRequestError

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

func (InvalidMetricRequestError) Error

func (i InvalidMetricRequestError) Error() string