influxdb

Documentation

Index

• type Container
  • func (container *Container) AddPods(pods []*ApiResources.Pod) error
  • func (container *Container) DeletePods(pods []*ApiResources.Pod) error
  • func (container *Container) ListAlamedaPods(ns, name string, kind ApiResources.Kind, timeRange *ApiCommon.TimeRange) ([]*ApiResources.Pod, error)
• type Controller
  • func (c *Controller) CreateControllers(controllers []*ApiResources.Controller) error
  • func (c *Controller) DeleteControllers(in *ApiResources.DeleteControllersRequest) error
  • func (c *Controller) ListControllers(in *ApiResources.ListControllersRequest) ([]*ApiResources.Controller, error)
• type Node
  • func (node *Node) DeregisterAlamedaNodes(alamedaNodes []*ApiResources.Node) error
  • func (node *Node) ListAlamedaNodes(timeRange *ApiCommon.TimeRange) ([]*ApiResources.Node, error)
  • func (node *Node) ListNodes(request DaoClusterStatus.ListNodesRequest) ([]*ApiResources.Node, error)
  • func (node *Node) RegisterAlamedaNodes(alamedaNodes []*ApiResources.Node) error

Types

type Container

type Container struct {
	InfluxDBConfig InternalInflux.Config
}

Implement ContainerOperation interface

func (*Container) AddPods

func (container *Container) AddPods(pods []*ApiResources.Pod) error

func (*Container) DeletePods

func (container *Container) DeletePods(pods []*ApiResources.Pod) error

func (*Container) ListAlamedaPods

func (container *Container) ListAlamedaPods(ns, name string, kind ApiResources.Kind, timeRange *ApiCommon.TimeRange) ([]*ApiResources.Pod, error)

type Controller

type Controller struct {
	InfluxDBConfig InternalInflux.Config
}

func (*Controller) CreateControllers

func (c *Controller) CreateControllers(controllers []*ApiResources.Controller) error

func (*Controller) DeleteControllers

func (c *Controller) DeleteControllers(in *ApiResources.DeleteControllersRequest) error

func (*Controller) ListControllers

func (c *Controller) ListControllers(in *ApiResources.ListControllersRequest) ([]*ApiResources.Controller, error)

type Node

type Node struct {
	InfluxDBConfig InternalInflux.Config
}

Implement Node interface

func (*Node) DeregisterAlamedaNodes

func (node *Node) DeregisterAlamedaNodes(alamedaNodes []*ApiResources.Node) error

func (*Node) ListAlamedaNodes

func (node *Node) ListAlamedaNodes(timeRange *ApiCommon.TimeRange) ([]*ApiResources.Node, error)

func (*Node) ListNodes

func (node *Node) ListNodes(request DaoClusterStatus.ListNodesRequest) ([]*ApiResources.Node, error)

func (*Node) RegisterAlamedaNodes

func (node *Node) RegisterAlamedaNodes(alamedaNodes []*ApiResources.Node) error