Documentation
¶
Index ¶
- Constants
- type Kubernetes
- func (k *Kubernetes) CreateOperators(pipelineId string, inputs []pipe_lib.Operator, pipeConfig lib.PipelineConfig) (err error)
- func (k *Kubernetes) DeleteOperator(string, pipe_lib.Operator) (err error)
- func (k *Kubernetes) DeleteOperators(pipelineId string, operators []pipe_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 ¶
View Source
const (
DummyOperatorId = "v3-123456789"
)
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(r2cfg *config.Rancher2Config, debug bool) (kube *Kubernetes, err error)
func (*Kubernetes) CreateOperators ¶
func (k *Kubernetes) CreateOperators(pipelineId string, inputs []pipe_lib.Operator, pipeConfig lib.PipelineConfig) (err error)
func (*Kubernetes) DeleteOperator ¶
func (k *Kubernetes) DeleteOperator(string, pipe_lib.Operator) (err error)
func (*Kubernetes) DeleteOperators ¶
func (k *Kubernetes) DeleteOperators(pipelineId string, operators []pipe_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)
Click to show internal directories.
Click to hide internal directories.