Documentation
¶
Index ¶
- type Kubernetes
- func (k *Kubernetes) CreateOperators(pipelineId string, inputs []lib.Operator, pipeConfig lib.PipelineConfig) (err error)
- func (k *Kubernetes) DeleteOperator(pipelineId string, operator lib.Operator) (err error)
- func (k *Kubernetes) DeleteOperators(pipelineId string, operators []lib.Operator) (err error)
- func (k *Kubernetes) GetPipelineStatus(pipelineId string) (pipeStatus lib.PipelineStatus, err error)
- func (k *Kubernetes) GetPipelinesStatus() (pipeStatus []lib.PipelineStatus, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Kubernetes ¶
type Kubernetes struct {
// contains filtered or unexported fields
}
func NewKubernetes ¶
func NewKubernetes() (kube *Kubernetes, err error)
func (*Kubernetes) CreateOperators ¶
func (k *Kubernetes) CreateOperators(pipelineId string, inputs []lib.Operator, pipeConfig lib.PipelineConfig) (err error)
func (*Kubernetes) DeleteOperator ¶
func (k *Kubernetes) DeleteOperator(pipelineId string, operator lib.Operator) (err error)
func (*Kubernetes) DeleteOperators ¶
func (k *Kubernetes) DeleteOperators(pipelineId string, operators []lib.Operator) (err error)
func (*Kubernetes) GetPipelineStatus ¶
func (k *Kubernetes) GetPipelineStatus(pipelineId string) (pipeStatus lib.PipelineStatus, err error)
func (*Kubernetes) GetPipelinesStatus ¶
func (k *Kubernetes) GetPipelinesStatus() (pipeStatus []lib.PipelineStatus, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.