repository

Documentation

Index

• func Start(ctx context.Context, instance *v1alpha1.Repository, duration time.Duration, ...) (repo.Entry, error)
• type Action
• type CommonAction
  • func (c *CommonAction) Create(component *v1alpha1.Component) error
  • func (c *CommonAction) Delete(component *v1alpha1.Component) error
  • func (c *CommonAction) Update(component *v1alpha1.Component) error
• type HTTPWatcher
  • func (c *HTTPWatcher) Poll()
  • func (c *HTTPWatcher) Start() error
  • func (c *HTTPWatcher) Stop()
• type IWatcher
  • func NewHTTPWatcher(instance *v1alpha1.Repository, c client.Client, ctx context.Context, ...) IWatcher
  • func NewOCIWatcher(instance *v1alpha1.Repository, c client.Client, ctx context.Context, ...) IWatcher
  • func NewWatcher(ctx context.Context, logger logr.Logger, c client.Client, ...) IWatcher
• type OCIWatcher
  • func (c *OCIWatcher) Poll()
  • func (c *OCIWatcher) Start() error
  • func (c *OCIWatcher) Stop()
• type Switch

Functions

func Start

func Start(ctx context.Context, instance *v1alpha1.Repository, duration time.Duration, repoName string, c client.Client, logger logr.Logger) (repo.Entry, error)

Start the Watcher

Types

type Action

type Action interface {
	Create(component *v1alpha1.Component) error
	Update(component *v1alpha1.Component) error
	Delete(component *v1alpha1.Component) error
}

Action defines the actiosn required to control the components

type CommonAction

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

CommonAction shared by the watchers

func (*CommonAction) Create

func (c *CommonAction) Create(component *v1alpha1.Component) error

Create the component and update it in the k8s client

func (*CommonAction) Delete

func (c *CommonAction) Delete(component *v1alpha1.Component) error

Delete the component in the k8s client

func (*CommonAction) Update

func (c *CommonAction) Update(component *v1alpha1.Component) error

Update the component in the k8s client

type HTTPWatcher

type HTTPWatcher struct {
	CommonAction
	// contains filtered or unexported fields
}

func (*HTTPWatcher) Poll

func (c *HTTPWatcher) Poll()

Poll the components

func (*HTTPWatcher) Start

func (c *HTTPWatcher) Start() error

func (*HTTPWatcher) Stop

func (c *HTTPWatcher) Stop()

type IWatcher

type IWatcher interface {
	Switch
	Action
}

func NewHTTPWatcher

func NewHTTPWatcher(
	instance *v1alpha1.Repository,
	c client.Client,
	ctx context.Context,
	logger logr.Logger,
	duration time.Duration,
	cancel context.CancelFunc,
	scheme *runtime.Scheme,
	fm map[string]v1alpha1.FilterCond,
) IWatcher

func NewOCIWatcher

func NewOCIWatcher(
	instance *v1alpha1.Repository,
	c client.Client,
	ctx context.Context,
	logger logr.Logger,
	duration time.Duration,
	cancel context.CancelFunc,
	scheme *runtime.Scheme,
	fm map[string]v1alpha1.FilterCond,
) IWatcher

func NewWatcher

func NewWatcher(
	ctx context.Context,
	logger logr.Logger,
	c client.Client,
	scheme *runtime.Scheme,
	instance *v1alpha1.Repository,
	cancel context.CancelFunc,
) IWatcher

type OCIWatcher

type OCIWatcher struct {
	CommonAction
	// contains filtered or unexported fields
}

func (*OCIWatcher) Poll

func (c *OCIWatcher) Poll()

Poll the components

func (*OCIWatcher) Start

func (c *OCIWatcher) Start() error

func (*OCIWatcher) Stop

func (c *OCIWatcher) Stop()

type Switch

type Switch interface {
	Start() error
	Stop()
	Poll()
}