influxdb

Documentation

Index

• func ListControllers(config InfluxDB.Config, request *DaoClusterTypes.ListControllersRequest) ([]*DaoClusterTypes.Controller, error)
• func ListPods(config InfluxDB.Config, request *DaoClusterTypes.ListPodsRequest) ([]*DaoClusterTypes.Pod, error)
• func NewAppMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.AppMetricsDAO
• func NewClusterMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.ClusterMetricsDAO
• func NewControllerMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.ControllerMetricsDAO
• func NewFunction(functionType common.FunctionType) *common.Function
• func NewNamespaceMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.NamespaceMetricsDAO
• func NewNodeMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.NodeMetricsDAO
• func NewPodMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.PodMetricsDAO
• type AppMetrics
  • func (n AppMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.AppMetricMap) error
  • func (n AppMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)
• type ClusterMetrics
  • func (n ClusterMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.ClusterMetricMap) error
  • func (n ClusterMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)
• type ControllerMetrics
  • func (n ControllerMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.ControllerMetricMap) error
  • func (n ControllerMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)
• type NamespaceMetrics
  • func (n NamespaceMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.NamespaceMetricMap) error
  • func (n NamespaceMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)
• type NodeMetrics
  • func (p *NodeMetrics) CreateMetrics(ctx context.Context, metrics DaoMetricTypes.NodeMetricMap) error
  • func (p *NodeMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListNodeMetricsRequest) (DaoMetricTypes.NodeMetricMap, error)
• type PodMetrics
  • func (p *PodMetrics) CreateMetrics(ctx context.Context, metrics DaoMetricTypes.PodMetricMap) error
  • func (p *PodMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListPodMetricsRequest) (DaoMetricTypes.PodMetricMap, error)

Functions

func ListControllers

func ListControllers(config InfluxDB.Config, request *DaoClusterTypes.ListControllersRequest) ([]*DaoClusterTypes.Controller, error)

func ListPods

func ListPods(config InfluxDB.Config, request *DaoClusterTypes.ListPodsRequest) ([]*DaoClusterTypes.Pod, error)

func NewAppMetricsWithConfig

func NewAppMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.AppMetricsDAO

func NewClusterMetricsWithConfig

func NewClusterMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.ClusterMetricsDAO

func NewControllerMetricsWithConfig

func NewControllerMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.ControllerMetricsDAO

func NewFunction

func NewFunction(functionType common.FunctionType) *common.Function

func NewNamespaceMetricsWithConfig

func NewNamespaceMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.NamespaceMetricsDAO

func NewNodeMetricsWithConfig

func NewNodeMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.NodeMetricsDAO

func NewPodMetricsWithConfig

func NewPodMetricsWithConfig(config InfluxDB.Config) DaoMetricTypes.PodMetricsDAO

Types

type AppMetrics

type AppMetrics struct {
	InfluxDBConfig  InfluxDB.Config
	ApplicationDAO  DaoClusterStatusTypes.ApplicationDAO
	ApplicationRepo *RepoInfluxMetric.Application
}

func (AppMetrics) CreateMetrics

func (n AppMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.AppMetricMap) error

func (AppMetrics) ListMetrics

func (n AppMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)

type ClusterMetrics

type ClusterMetrics struct {
	InfluxDBConfig InfluxDB.Config
	ClusterDAO     DaoClusterStatusTypes.ClusterDAO
	ClusterRepo    *RepoInfluxMetric.Cluster
}

func (ClusterMetrics) CreateMetrics

func (n ClusterMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.ClusterMetricMap) error

func (ClusterMetrics) ListMetrics

func (n ClusterMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)

type ControllerMetrics

type ControllerMetrics struct {
	InfluxDBConfig InfluxDB.Config
	ControllerDAO  DaoClusterStatusTypes.ControllerDAO
	ControllerRepo *RepoInfluxMetric.Controller
}

func (ControllerMetrics) CreateMetrics

func (n ControllerMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.ControllerMetricMap) error

func (ControllerMetrics) ListMetrics

func (n ControllerMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)

type NamespaceMetrics

type NamespaceMetrics struct {
	InfluxDBConfig InfluxDB.Config
}

func (NamespaceMetrics) CreateMetrics

func (n NamespaceMetrics) CreateMetrics(ctx context.Context, m DaoMetricTypes.NamespaceMetricMap) error

func (NamespaceMetrics) ListMetrics

func (n NamespaceMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)

type NodeMetrics

type NodeMetrics struct {
	InfluxDBConfig InfluxDB.Config
}

func (*NodeMetrics) CreateMetrics

func (p *NodeMetrics) CreateMetrics(ctx context.Context, metrics DaoMetricTypes.NodeMetricMap) error

func (*NodeMetrics) ListMetrics

func (p *NodeMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListNodeMetricsRequest) (DaoMetricTypes.NodeMetricMap, error)

type PodMetrics

type PodMetrics struct {
	InfluxDBConfig InfluxDB.Config
}

func (*PodMetrics) CreateMetrics

func (p *PodMetrics) CreateMetrics(ctx context.Context, metrics DaoMetricTypes.PodMetricMap) error

func (*PodMetrics) ListMetrics

func (p *PodMetrics) ListMetrics(ctx context.Context, req DaoMetricTypes.ListPodMetricsRequest) (DaoMetricTypes.PodMetricMap, error)