source

Documentation

Index

• type ArgoTemplateSource
  • func (t *ArgoTemplateSource) HasSynced() bool
  • func (t *ArgoTemplateSource) ImageCh() <-chan string
  • func (t *ArgoTemplateSource) Images() []string
  • func (ats *ArgoTemplateSource) Name() string
  • func (t *ArgoTemplateSource) Run(ctx context.Context)
• type ArgoTemplateSourceOpts
• type ConfigMapSource
  • func (cms *ConfigMapSource) HasSynced() bool
  • func (cms *ConfigMapSource) ImageCh() <-chan string
  • func (cms *ConfigMapSource) Images() []string
  • func (*ConfigMapSource) Name() string
  • func (cms *ConfigMapSource) Run(ctx context.Context)
• type ImageSource
  • func NewArgoTemplateSource(opts *ArgoTemplateSourceOpts) ImageSource
  • func NewClusterWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource
  • func NewConfigMapSource(client kubernetes.Interface, resyncPeriod time.Duration, opts ...OptFn) ImageSource
  • func NewCronWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource
  • func NewStaticImageSource(images []string, resyncPeriod time.Duration) ImageSource
  • func NewWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource
• type OptFn
  • func WithConfigMapSelector(selector string) OptFn
  • func WithLogger(logger *logrus.Logger) OptFn
• type StaticImageSource
  • func (sis *StaticImageSource) ImageCh() <-chan string
  • func (sis *StaticImageSource) Images() []string
  • func (StaticImageSource) Name() string
  • func (sis *StaticImageSource) Run(ctx context.Context)

Types

type ArgoTemplateSource

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

func (*ArgoTemplateSource) HasSynced

func (t *ArgoTemplateSource) HasSynced() bool

func (*ArgoTemplateSource) ImageCh

func (t *ArgoTemplateSource) ImageCh() <-chan string

func (*ArgoTemplateSource) Images

func (t *ArgoTemplateSource) Images() []string

func (*ArgoTemplateSource) Name

func (ats *ArgoTemplateSource) Name() string

func (*ArgoTemplateSource) Run

func (t *ArgoTemplateSource) Run(ctx context.Context)

type ArgoTemplateSourceOpts

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

type ConfigMapSource

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

func (*ConfigMapSource) HasSynced

func (cms *ConfigMapSource) HasSynced() bool

func (*ConfigMapSource) ImageCh

func (cms *ConfigMapSource) ImageCh() <-chan string

func (*ConfigMapSource) Images

func (cms *ConfigMapSource) Images() []string

func (*ConfigMapSource) Name

func (*ConfigMapSource) Name() string

func (*ConfigMapSource) Run

func (cms *ConfigMapSource) Run(ctx context.Context)

type ImageSource

type ImageSource interface {
	ImageCh() <-chan string
	Images() []string
	Name() string
	Run(context.Context)
}

func NewArgoTemplateSource

func NewArgoTemplateSource(opts *ArgoTemplateSourceOpts) ImageSource

func NewClusterWorkflowTemplateSource

func NewClusterWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource

func NewConfigMapSource

func NewConfigMapSource(client kubernetes.Interface, resyncPeriod time.Duration, opts ...OptFn) ImageSource

func NewCronWorkflowTemplateSource

func NewCronWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource

func NewStaticImageSource

func NewStaticImageSource(images []string, resyncPeriod time.Duration) ImageSource

func NewWorkflowTemplateSource

func NewWorkflowTemplateSource(client argoclientset.Interface, resyncPeriod time.Duration) ImageSource

type OptFn

type OptFn func(cms *ConfigMapSource)

func WithConfigMapSelector

func WithConfigMapSelector(selector string) OptFn

func WithLogger

func WithLogger(logger *logrus.Logger) OptFn

type StaticImageSource

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

func (*StaticImageSource) ImageCh

func (sis *StaticImageSource) ImageCh() <-chan string

func (*StaticImageSource) Images

func (sis *StaticImageSource) Images() []string

func (StaticImageSource) Name

func (StaticImageSource) Name() string

func (*StaticImageSource) Run

func (sis *StaticImageSource) Run(ctx context.Context)