strategy

Documentation

Index

• type KubernetesPodPullStrategy
  • func NewKubernetesPodPullStrategy(opts *KubernetesPodPullStrategyOpts) *KubernetesPodPullStrategy
  • func (kpps *KubernetesPodPullStrategy) ImagePullErrorCh() <-chan string
  • func (kpps *KubernetesPodPullStrategy) ImagePullSuccessCh() <-chan string
  • func (kpps *KubernetesPodPullStrategy) MonitorPods(ctx context.Context)
  • func (kpps *KubernetesPodPullStrategy) PullImage(ctx context.Context, image string) error
• type KubernetesPodPullStrategyOpts
• type PullStrategy

Types

type KubernetesPodPullStrategy

type KubernetesPodPullStrategy struct {
	OwnerReference v1.OwnerReference
	Client         kubernetes.Interface

	WardenImage string

	NodeName  string
	Namespace string
	PodName   string
	// contains filtered or unexported fields
}

func NewKubernetesPodPullStrategy

func NewKubernetesPodPullStrategy(opts *KubernetesPodPullStrategyOpts) *KubernetesPodPullStrategy

func (*KubernetesPodPullStrategy) ImagePullErrorCh

func (kpps *KubernetesPodPullStrategy) ImagePullErrorCh() <-chan string

func (*KubernetesPodPullStrategy) ImagePullSuccessCh

func (kpps *KubernetesPodPullStrategy) ImagePullSuccessCh() <-chan string

func (*KubernetesPodPullStrategy) MonitorPods

func (kpps *KubernetesPodPullStrategy) MonitorPods(ctx context.Context)

func (*KubernetesPodPullStrategy) PullImage

func (kpps *KubernetesPodPullStrategy) PullImage(ctx context.Context, image string) error

type KubernetesPodPullStrategyOpts

type KubernetesPodPullStrategyOpts struct {
	OwnerReference v1.OwnerReference
	Client         kubernetes.Interface

	WardenImage string

	NodeName  string
	Namespace string
	PodName   string
}

type PullStrategy

type PullStrategy interface {
	PullImage(context.Context, string) error

	ImagePullSuccessCh() <-chan string
	ImagePullErrorCh() <-chan string
}