...

Package collector

import "github.com/chaos-mesh/chaos-mesh/pkg/workflow/task/collector"
Overview
Index

Overview ▾

Constants

const ExitCode string = "exitCode"
const Stdout string = "stdout"

type Collector

Collector is a set of tools for collecting parameters/context from user defined task

type Collector interface {
    CollectContext(ctx context.Context) (env map[string]interface{}, err error)
}

func DefaultCollector

func DefaultCollector(kubeClient client.Client, restConfig *rest.Config, namespace, podName, containerName string) Collector

type ComposeCollector

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

func (*ComposeCollector) CollectContext

func (it *ComposeCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)

type ExitCodeCollector

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

func NewExitCodeCollector

func NewExitCodeCollector(kubeClient client.Client, namespace string, podName string, containerName string) *ExitCodeCollector

func (*ExitCodeCollector) CollectContext

func (it *ExitCodeCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)

type StdoutCollector

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

func NewStdoutCollector

func NewStdoutCollector(restConfig *rest.Config, namespace string, podName string, containerName string) *StdoutCollector

func (*StdoutCollector) CollectContext

func (it *StdoutCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)

type ValuedCollector

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

func NewValuedCollector

func NewValuedCollector(status v1alpha1.ConditionalBranchesStatus) *ValuedCollector

func (*ValuedCollector) CollectContext

func (it *ValuedCollector) CollectContext() (env map[string]interface{}, err error)