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 Node
  • func (node *Node) DeregisterAlamedaNodes(alamedaNodes []*datahub_v1alpha1.Node) error
  • func (node *Node) ListAlamedaNodes() ([]*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) ([]*datahub_v1alpha1.Pod, 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() ([]*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