v1alpha1

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2024 License: Apache-2.0 Imports: 19 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 {
	DynamicClient   dynamic.DynamicClient
	SubscriberError error
}

func NewGitrepositorySubscriber 

func NewGitrepositorySubscriber(dynClient dynamic.DynamicClient) *GitrepositorySubscriber

func (GitrepositorySubscriber) CalculateCurrentState added in v0.2.1 

func (gitrepositorySubscriber GitrepositorySubscriber) CalculateCurrentState(secondClusterEnabled bool, secondClusterAddr string, secondClusterBearerToken string, ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList unstructured.UnstructuredList, group string, version string) (bool, bool, error)

func (GitrepositorySubscriber) CreatePipelineRunResource 

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

func (GitrepositorySubscriber) Exists 

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

func (*GitrepositorySubscriber) Get added in v0.5.0 

func (gitrepositorySubscriber *GitrepositorySubscriber) Get(ctx context.Context, client dynamic.DynamicClient, name string, namespace string, group string, version string) (*unstructured.Unstructured, error)

func (GitrepositorySubscriber) GetLastConditions added in v0.3.3 

func (gitrepositorySubscriber GitrepositorySubscriber) GetLastConditions(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) ([]string, []v1.Condition)

func (GitrepositorySubscriber) GetLatestEvent 

func (gitrepositorySubscriber GitrepositorySubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request, group string, version string) (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) IsValid added in v0.5.0 

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

func (*GitrepositorySubscriber) List added in v0.5.0 

func (gitrepositorySubscriber *GitrepositorySubscriber) List(ctx context.Context, client dynamic.DynamicClient, namespace string, group string, version string) ([]unstructured.Unstructured, error)

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) SetCurrentPipelineRunName added in v0.3.7 

func (gitrepositorySubscriber GitrepositorySubscriber) SetCurrentPipelineRunName(ctx context.Context, client client.Client, pipelineRun *unstructured.Unstructured, pipelineRunName string, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (GitrepositorySubscriber) SetCurrentPipelineRunStatus added in v0.2.1 

func (gitrepositorySubscriber GitrepositorySubscriber) SetCurrentPipelineRunStatus(pipelineRunList unstructured.UnstructuredList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (GitrepositorySubscriber) Subscribes 

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

type ImagepolicySubscriber 

type ImagepolicySubscriber struct {
	DynamicClient   dynamic.DynamicClient
	SubscriberError error
}

func NewImagepolicySubscriber 

func NewImagepolicySubscriber(dynClient dynamic.DynamicClient) *ImagepolicySubscriber

func (ImagepolicySubscriber) CalculateCurrentState added in v0.2.1 

func (imagepolicySubscriber ImagepolicySubscriber) CalculateCurrentState(secondClusterEnabled bool, secondClusterAddr string, secondClusterBearerToken string, ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList unstructured.UnstructuredList, group string, version string) (bool, bool, error)

func (ImagepolicySubscriber) CreatePipelineRunResource 

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

func (ImagepolicySubscriber) Exists 

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

func (*ImagepolicySubscriber) Get added in v0.5.0 

func (imagepolicySubscriber *ImagepolicySubscriber) Get(ctx context.Context, client dynamic.DynamicClient, name string, namespace string, group string, version string) (*unstructured.Unstructured, error)

func (ImagepolicySubscriber) GetLastConditions added in v0.3.3 

func (imagepolicySubscriber ImagepolicySubscriber) GetLastConditions(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) ([]string, []v1.Condition)

func (ImagepolicySubscriber) GetLatestEvent 

func (imagepolicySubscriber ImagepolicySubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request, group string, version string) (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) IsValid added in v0.5.0 

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

func (*ImagepolicySubscriber) List added in v0.5.0 

func (imagepolicySubscriber *ImagepolicySubscriber) List(ctx context.Context, client dynamic.DynamicClient, namespace string, group string, version string) ([]unstructured.Unstructured, error)

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) SetCurrentPipelineRunName added in v0.3.7 

func (imagepolicySubscriber ImagepolicySubscriber) SetCurrentPipelineRunName(ctx context.Context, client client.Client, pipelineRun *unstructured.Unstructured, pipelineRunName string, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (ImagepolicySubscriber) SetCurrentPipelineRunStatus added in v0.2.1 

func (imagepolicySubscriber ImagepolicySubscriber) SetCurrentPipelineRunStatus(pipelineRunList unstructured.UnstructuredList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (ImagepolicySubscriber) Subscribes 

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

type Param added in v0.5.0 

type Param struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type PullRequestResult added in v0.5.0 

type PullRequestResult struct {
	BranchName           string
	BranchCommit         string
	Running              bool
	SecondClusterRunning bool
	Error                error
}

type PullrequestSubscriber 

type PullrequestSubscriber struct {
	DynamicClient   dynamic.DynamicClient
	SubscriberError error
}

func NewPullrequestSubscriber 

func NewPullrequestSubscriber(dynClient dynamic.DynamicClient) *PullrequestSubscriber

func (PullrequestSubscriber) CalculateCurrentState added in v0.2.1 

func (pullrequestSubscriber PullrequestSubscriber) CalculateCurrentState(secondClusterEnabled bool, secondClusterAddr string, secondClusterBearerToken string, ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList unstructured.UnstructuredList, group string, version string) (bool, bool, error)

func (PullrequestSubscriber) CreatePipelineRunResource 

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

func (PullrequestSubscriber) Exists 

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

func (*PullrequestSubscriber) Get added in v0.5.0 

func (pullrequestSubscriber *PullrequestSubscriber) Get(ctx context.Context, client dynamic.DynamicClient, name string, namespace string, group string, version string) (*unstructured.Unstructured, error)

func (PullrequestSubscriber) GetLastConditions added in v0.3.3 

func (pullrequestSubscriber PullrequestSubscriber) GetLastConditions(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) ([]string, []v1.Condition)

func (PullrequestSubscriber) GetLatestEvent 

func (pullrequestSubscriber PullrequestSubscriber) GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request, group string, version string) (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) IsValid added in v0.5.0 

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

func (*PullrequestSubscriber) List added in v0.5.0 

func (pullrequestSubscriber *PullrequestSubscriber) List(ctx context.Context, client dynamic.DynamicClient, namespace string, group string, version string) ([]unstructured.Unstructured, error)

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) SetCurrentPipelineRunName added in v0.3.7 

func (pullrequestSubscriber PullrequestSubscriber) SetCurrentPipelineRunName(ctx context.Context, client client.Client, pipelineRun *unstructured.Unstructured, pipelineRunName string, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (*PullrequestSubscriber) SetCurrentPipelineRunStatus added in v0.2.1 

func (pullrequestSubscriber *PullrequestSubscriber) SetCurrentPipelineRunStatus(pipelineRunList unstructured.UnstructuredList, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)

func (PullrequestSubscriber) Subscribes 

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

type SourceSubscriber 

type SourceSubscriber interface {
	Subscribes(pipelineTrigger pipelinev1alpha1.PipelineTrigger) error
	List(ctx context.Context, client dynamic.DynamicClient, namespace string, group string, version string) ([]unstructured.Unstructured, error)
	Get(ctx context.Context, client dynamic.DynamicClient, name string, namespace string, group string, version string) (*unstructured.Unstructured, error)
	IsValid(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request) error
	Exists(ctx context.Context, pipelineTrigger pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request, group string, version string) error
	GetLatestEvent(ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, req ctrl.Request, group string, version string) (bool, error)
	CreatePipelineRunResource(pipelineTrigger *pipelinev1alpha1.PipelineTrigger, r *runtime.Scheme) []*unstructured.Unstructured
	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 unstructured.UnstructuredList, obj *pipelinev1alpha1.PipelineTrigger)
	CalculateCurrentState(secondClusterEnabled bool, secondClusterAddr string, secondClusterBearerToken string, ctx context.Context, pipelineTrigger *pipelinev1alpha1.PipelineTrigger, client client.Client, pipelineRunList unstructured.UnstructuredList, group string, version string) (bool, bool, error)
	HasIntersection(map1 map[string]string, map2 map[string]string) bool
	GetLastConditions(pipelineTrigger *pipelinev1alpha1.PipelineTrigger) ([]string, []metav1.Condition)
	SetCurrentPipelineRunName(ctx context.Context, client client.Client, pipelineRun *unstructured.Unstructured, pipelineRunName string, pipelineTrigger *pipelinev1alpha1.PipelineTrigger)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.