collector

Documentation

Index

• Constants
• type Collector
  • func DefaultCollector(kubeClient client.Client, restConfig *rest.Config, ...) Collector
• type ComposeCollector
  • func (it *ComposeCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)
• type ExitCodeCollector
  • func NewExitCodeCollector(kubeClient client.Client, namespace string, podName string, ...) *ExitCodeCollector
  • func (it *ExitCodeCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)
• type StdoutCollector
  • func NewStdoutCollector(restConfig *rest.Config, namespace string, podName string, ...) *StdoutCollector
  • func (it *StdoutCollector) CollectContext(ctx context.Context) (env map[string]interface{}, err error)
• type ValuedCollector
  • func NewValuedCollector(status v1alpha1.ConditionalBranchesStatus) *ValuedCollector
  • func (it *ValuedCollector) CollectContext() (env map[string]interface{}, err error)

Constants

const ExitCode string = "exitCode"

const Stdout string = "stdout"

Types

type Collector

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

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

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)