v1alpha1

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 16, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GitrepositorySubscriber

type GitrepositorySubscriber struct {
}

func NewGitrepositorySubscriber

func NewGitrepositorySubscriber() *GitrepositorySubscriber

func (GitrepositorySubscriber) CalculateCurrentState added in v0.2.1

func (gitrepositorySubscriber GitrepositorySubscriber) CalculateCurrentState(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList tektondevv1.PipelineRunList) bool

func (GitrepositorySubscriber) CreatePipelineRunResource

func (gitrepositorySubscriber GitrepositorySubscriber) CreatePipelineRunResource(pipelineTrigger *pipelinev1alpha1.PipelineTrigger, r *runtime.Scheme) []*tektondevv1.PipelineRun

func (GitrepositorySubscriber) Exists

func (gitrepositorySubscriber GitrepositorySubscriber) Exists(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) error

func (GitrepositorySubscriber) GetLatestEvent

func (gitrepositorySubscriber GitrepositorySubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) (bool, error)

func (*GitrepositorySubscriber) HasIntersection added in v0.2.5

func (gitrepositorySubscriber *GitrepositorySubscriber) HasIntersection(map1 map[string]string, map2 map[string]string) bool

func (GitrepositorySubscriber) IsFinished

func (gitrepositorySubscriber GitrepositorySubscriber) IsFinished(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) bool

func (*GitrepositorySubscriber) ManageError added in v0.2.1

func (gitrepositorySubscriber *GitrepositorySubscriber) ManageError(context context.Context, obj *pipelinev1alpha1.PipelineTrigger, req ctrl.Request, r client.Client, message error) (reconcile.Result, error)

func (GitrepositorySubscriber) SetCurrentPipelineRunStatus added in v0.2.1

func (gitrepositorySubscriber GitrepositorySubscriber) SetCurrentPipelineRunStatus(pipelineRunList tektondevv1.PipelineRunList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (GitrepositorySubscriber) Subscribes

func (gitrepositorySubscriber GitrepositorySubscriber) Subscribes(pipelineTrigger pipelinev1alpha1.PipelineTrigger) error

type ImagepolicySubscriber

type ImagepolicySubscriber struct {
}

func NewImagepolicySubscriber

func NewImagepolicySubscriber() *ImagepolicySubscriber

func (ImagepolicySubscriber) CalculateCurrentState added in v0.2.1

func (imagepolicySubscriber ImagepolicySubscriber) CalculateCurrentState(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList tektondevv1.PipelineRunList) bool

func (ImagepolicySubscriber) CreatePipelineRunResource

func (imagepolicySubscriber ImagepolicySubscriber) CreatePipelineRunResource(pipelineTrigger *pipelinev1alpha1.PipelineTrigger, r *runtime.Scheme) []*tektondevv1.PipelineRun

func (ImagepolicySubscriber) Exists

func (imagepolicySubscriber ImagepolicySubscriber) Exists(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) error

func (ImagepolicySubscriber) GetLatestEvent

func (imagepolicySubscriber ImagepolicySubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) (bool, error)

func (*ImagepolicySubscriber) HasIntersection added in v0.2.5

func (imagepolicySubscriber *ImagepolicySubscriber) HasIntersection(map1 map[string]string, map2 map[string]string) bool

func (ImagepolicySubscriber) IsFinished

func (imagepolicySubscriber ImagepolicySubscriber) IsFinished(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) bool

func (*ImagepolicySubscriber) ManageError added in v0.2.1

func (imagepolicySubscriber *ImagepolicySubscriber) ManageError(context context.Context, obj *pipelinev1alpha1.PipelineTrigger, req ctrl.Request, r client.Client, message error) (reconcile.Result, error)

func (ImagepolicySubscriber) SetCurrentPipelineRunStatus added in v0.2.1

func (imagepolicySubscriber ImagepolicySubscriber) SetCurrentPipelineRunStatus(pipelineRunList tektondevv1.PipelineRunList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (ImagepolicySubscriber) Subscribes

func (imagepolicySubscriber ImagepolicySubscriber) Subscribes(pipelineTrigger pipelinev1alpha1.PipelineTrigger) error

type PullrequestSubscriber

type PullrequestSubscriber struct {
}

func NewPullrequestSubscriber

func NewPullrequestSubscriber() *PullrequestSubscriber

func (PullrequestSubscriber) CalculateCurrentState added in v0.2.1

func (pullrequestSubscriber PullrequestSubscriber) CalculateCurrentState(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList tektondevv1.PipelineRunList) bool

func (PullrequestSubscriber) CreatePipelineRunResource

func (pullrequestSubscriber PullrequestSubscriber) CreatePipelineRunResource(pipelineTrigger *pipelinev1alpha1.PipelineTrigger, r *runtime.Scheme) []*tektondevv1.PipelineRun

func (PullrequestSubscriber) Exists

func (pullrequestSubscriber PullrequestSubscriber) Exists(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) error

func (PullrequestSubscriber) GetLatestEvent

func (pullrequestSubscriber PullrequestSubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) (bool, error)

func (*PullrequestSubscriber) HasIntersection added in v0.2.5

func (pullrequestSubscriber *PullrequestSubscriber) HasIntersection(map1 map[string]string, map2 map[string]string) bool

func (PullrequestSubscriber) IsFinished

func (pullrequestSubscriber PullrequestSubscriber) IsFinished(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) bool

func (*PullrequestSubscriber) ManageError added in v0.2.1

func (pullrequestSubscriber *PullrequestSubscriber) ManageError(context context.Context, obj *pipelinev1alpha1.PipelineTrigger, req ctrl.Request, r client.Client, message error) (reconcile.Result, error)

func (*PullrequestSubscriber) SetCurrentPipelineRunStatus added in v0.2.1

func (pullrequestSubscriber *PullrequestSubscriber) SetCurrentPipelineRunStatus(pipelineRunList tektondevv1.PipelineRunList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (PullrequestSubscriber) Subscribes

func (pullrequestSubscriber PullrequestSubscriber) Subscribes(pipelineTrigger pipelinev1alpha1.PipelineTrigger) error

type SourceSubscriber

type SourceSubscriber interface {
	Subscribes(pipelineTrigger pipelinev1alpha1.PipelineTrigger) error
	Exists(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) error
	GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) (bool, error)
	CreatePipelineRunResource(pipelineTrigger *pipelinev1alpha1.PipelineTrigger, r *runtime.Scheme) []*tektondevv1.PipelineRun
	IsFinished(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) bool
	ManageError(context context.Context, obj *pipelinev1alpha1.PipelineTrigger, req ctrl.Request, r client.Client, message error) (reconcile.Result, error)
	SetCurrentPipelineRunStatus(pipelineRunList tektondevv1.PipelineRunList, obj *pipelinev1alpha1.PipelineTrigger)
	CalculateCurrentState(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList tektondevv1.PipelineRunList) bool
	HasIntersection(map1 map[string]string, map2 map[string]string) bool
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL