logs

Documentation

Index

• func AddK8SLogTransportWrapper(config *rest.Config) *rest.Config
• func LogPods(ctx context.Context, kubernetesClient kubernetes.Interface, ...) error
• func WorkflowLogs(ctx context.Context, wfClient versioned.Interface, ...) error
• type Callback

Functions

func AddK8SLogTransportWrapper

func AddK8SLogTransportWrapper(config *rest.Config) *rest.Config

func LogPods

func LogPods(ctx context.Context, kubernetesClient kubernetes.Interface, namespace, labelSelector, grep string, podLogOptions *corev1.PodLogOptions, callback Callback) error

func WorkflowLogs

func WorkflowLogs(ctx context.Context, wfClient versioned.Interface, kubeClient kubernetes.Interface, req request, sender sender) error

Types

type Callback

type Callback func(pod *corev1.Pod, data []byte) error