Documentation
¶
Index ¶
- type ArgoTemplateSource
- type ArgoTemplateSourceOpts
- type ConfigMapSource
- 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
- type StaticImageSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 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)
Source Files
Click to show internal directories.
Click to hide internal directories.