impl

Documentation

Index

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

Types

type Container

type Container struct {
	InfluxDBConfig influxdb_repository.Config
}

Implement ContainerOperation interface

func (*Container) AddPods

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

func (*Container) DeletePods

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

func (*Container) ListAlamedaPods

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

type Controller

type Controller struct {
	InfluxDBConfig influxdb_repository.Config
}

func (*Controller) CreateControllers

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

func (*Controller) ListControllers

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

type Node

type Node struct {
	InfluxDBConfig influxdb_repository.Config
}

Implement Node interface

func (*Node) DeregisterAlamedaNodes

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

func (*Node) ListAlamedaNodes

func (node *Node) ListAlamedaNodes(timeRange *datahub_api.TimeRange) ([]*datahub_v1alpha1.Node, error)

func (*Node) ListNodes

func (node *Node) ListNodes(request cluster_status_dao.ListNodesRequest) ([]*datahub_v1alpha1.Node, error)

func (*Node) RegisterAlamedaNodes

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