inputs

Documentation

Overview

Package inputs implements data inputs used by the application

Index

• func GetAllInputsData(inputs []Input, clusterIDs []string) (map[string]*Cluster, []error)
• func GetAllInputsDataWithMaxGoRoutines(inputs []Input, clusterIDs []string, maxGoRoutines int) (map[string]*Cluster, []error)
• func NewK8sAPIInputBuilder(ctx context.Context, apiVersions []string) *k8sInputBuilder
• func NewMetricsInputBuilder(ctx context.Context, queries []clients.MetricQuery) *metricsInputBuilder
• type Cluster
• type Input
  • func NewGKEApiInput(ctx context.Context) (Input, error)
  • func NewGKEApiInputWithCredentials(ctx context.Context, credentialsFile string) (Input, error)
  • func NewGKELocalInput(dumpFile string) Input
  • func NewRestInput(ctx context.Context, endpoint string) Input

Functions

func GetAllInputsData

func GetAllInputsData(inputs []Input, clusterIDs []string) (map[string]*Cluster, []error)

GetAllInputsData fetches data from given inputs for all given clusters in a concurrent manner

func GetAllInputsDataWithMaxGoRoutines

func GetAllInputsDataWithMaxGoRoutines(inputs []Input, clusterIDs []string, maxGoRoutines int) (map[string]*Cluster, []error)

GetAllInputsDataWithMaxGoRoutines fetches data from given inputs for all given clusters in a concurrent manner. The maxGoRoutines parameter determines concurrency level

func NewK8sAPIInputBuilder

func NewK8sAPIInputBuilder(ctx context.Context, apiVersions []string) *k8sInputBuilder

func NewMetricsInputBuilder

func NewMetricsInputBuilder(ctx context.Context, queries []clients.MetricQuery) *metricsInputBuilder

Types

type Cluster

type Cluster struct {
	Name string                 `json:"name"`
	Data map[string]interface{} `json:"data"`
}

type Input

type Input interface {
	GetID() string
	GetDataSourceName() string
	GetDescription() string
	GetData(clusterID string) (interface{}, error)
	Close() error
}

func NewGKEApiInput

func NewGKEApiInput(ctx context.Context) (Input, error)

func NewGKEApiInputWithCredentials

func NewGKEApiInputWithCredentials(ctx context.Context, credentialsFile string) (Input, error)

func NewGKELocalInput

func NewGKELocalInput(dumpFile string) Input

func NewRestInput

func NewRestInput(ctx context.Context, endpoint string) Input