planning

Documentation

Index

• Constants
• type ContainerRepository
  • func NewContainerRepository(influxDBCfg *InternalInflux.Config) *ContainerRepository
  • func (c *ContainerRepository) CreateContainerPlannings(in *DatahubV1alpha1.CreatePodPlanningsRequest) error
  • func (c *ContainerRepository) IsTag(column string) bool
  • func (c *ContainerRepository) ListContainerPlannings(in *DatahubV1alpha1.ListPodPlanningsRequest) ([]*DatahubV1alpha1.PodPlanning, error)
• type ControllerRepository
  • func NewControllerRepository(influxDBCfg *InternalInflux.Config) *ControllerRepository
  • func (c *ControllerRepository) CreateControllerPlannings(controllerPlannings []*DatahubV1alpha1.ControllerPlanning) error
  • func (c *ControllerRepository) ListControllerPlannings(in *DatahubV1alpha1.ListControllerPlanningsRequest) ([]*DatahubV1alpha1.ControllerPlanning, error)

Constants

const (
	Container  influxdb.Measurement = "container"
	Controller influxdb.Measurement = "controller"
)

Types

type ContainerRepository

type ContainerRepository struct {
	// contains filtered or unexported fields
}

ContainerRepository is used to operate container measurement of planning database

func NewContainerRepository

func NewContainerRepository(influxDBCfg *InternalInflux.Config) *ContainerRepository

NewContainerRepository creates the ContainerRepository instance

func (*ContainerRepository) CreateContainerPlannings

func (c *ContainerRepository) CreateContainerPlannings(in *DatahubV1alpha1.CreatePodPlanningsRequest) error

CreateContainerPlannings add containers plannings

func (*ContainerRepository) IsTag

func (c *ContainerRepository) IsTag(column string) bool

IsTag checks the column is tag or not

func (*ContainerRepository) ListContainerPlannings

func (c *ContainerRepository) ListContainerPlannings(in *DatahubV1alpha1.ListPodPlanningsRequest) ([]*DatahubV1alpha1.PodPlanning, error)

ListContainerPlannings list container plannings

type ControllerRepository

type ControllerRepository struct {
	// contains filtered or unexported fields
}

func NewControllerRepository

func NewControllerRepository(influxDBCfg *InternalInflux.Config) *ControllerRepository

func (*ControllerRepository) CreateControllerPlannings

func (c *ControllerRepository) CreateControllerPlannings(controllerPlannings []*DatahubV1alpha1.ControllerPlanning) error

func (*ControllerRepository) ListControllerPlannings

func (c *ControllerRepository) ListControllerPlannings(in *DatahubV1alpha1.ListControllerPlanningsRequest) ([]*DatahubV1alpha1.ControllerPlanning, error)