kubeinteraction

Documentation

Index

• Constants
• func AddLabelsAndAnnotations(event *info.Event, pipelineRun *tektonv1.PipelineRun, repo *apipac.Repository, ...)
• func PollImmediateWithContext(ctx context.Context, pollTimeout time.Duration, fn func() (bool, error)) error
• type Interaction
  • func NewKubernetesInteraction(c *params.Run) (*Interaction, error)
  • func (k Interaction) CleanupPipelines(ctx context.Context, logger *zap.SugaredLogger, repo *v1alpha1.Repository, ...) error
  • func (k Interaction) CreateSecret(ctx context.Context, ns string, secret *corev1.Secret) error
  • func (k Interaction) DeleteSecret(ctx context.Context, _ *zap.SugaredLogger, targetNamespace, secretName string) error
  • func (k Interaction) GetEvents(ctx context.Context, ns, objtype, name string) (*corev1.EventList, error)
  • func (k Interaction) GetPodLogs(ctx context.Context, ns, podName, containerName string, tailLines int64) (string, error)
  • func (k Interaction) GetSecret(ctx context.Context, secretopt ktypes.GetSecretOpt) (string, error)
  • func (k Interaction) UpdateSecretWithOwnerRef(ctx context.Context, logger *zap.SugaredLogger, ...) error
• type Interface

Constants

const (
	StateStarted   = "started"
	StateQueued    = "queued"
	StateCompleted = "completed"
	StateFailed    = "failed"
)

Functions

func AddLabelsAndAnnotations

func AddLabelsAndAnnotations(event *info.Event, pipelineRun *tektonv1.PipelineRun, repo *apipac.Repository, providerinfo *info.ProviderConfig)

func PollImmediateWithContext

func PollImmediateWithContext(ctx context.Context, pollTimeout time.Duration, fn func() (bool, error)) error

Types

type Interaction

type Interaction struct {
	Run *params.Run
}

func NewKubernetesInteraction

func NewKubernetesInteraction(c *params.Run) (*Interaction, error)

func (Interaction) CleanupPipelines

func (k Interaction) CleanupPipelines(ctx context.Context, logger *zap.SugaredLogger, repo *v1alpha1.Repository, pr *tektonv1.PipelineRun, maxKeep int) error

func (Interaction) CreateSecret

func (k Interaction) CreateSecret(ctx context.Context, ns string, secret *corev1.Secret) error

func (Interaction) DeleteSecret

func (k Interaction) DeleteSecret(ctx context.Context, _ *zap.SugaredLogger, targetNamespace, secretName string) error

DeleteSecret deletes the secret created for git-clone basic-auth

func (Interaction) GetEvents

func (k Interaction) GetEvents(ctx context.Context, ns, objtype, name string) (*corev1.EventList, error)

func (Interaction) GetPodLogs

func (k Interaction) GetPodLogs(ctx context.Context, ns, podName, containerName string, tailLines int64) (string, error)

GetPodLogs of a ns on a podname and container, tailLines is the number of line to tail -1 mean unlimited

func (Interaction) GetSecret

func (k Interaction) GetSecret(ctx context.Context, secretopt ktypes.GetSecretOpt) (string, error)

func (Interaction) UpdateSecretWithOwnerRef

func (k Interaction) UpdateSecretWithOwnerRef(ctx context.Context, logger *zap.SugaredLogger, targetNamespace, secretName string, pr *pipelinev1.PipelineRun) error

UpdateSecretWithOwnerRef updates the secret with ownerReference

type Interface

type Interface interface {
	CleanupPipelines(context.Context, *zap.SugaredLogger, *v1alpha1.Repository, *pipelinev1.PipelineRun, int) error
	CreateSecret(ctx context.Context, ns string, secret *corev1.Secret) error
	UpdateSecretWithOwnerRef(context.Context, *zap.SugaredLogger, string, string, *pipelinev1.PipelineRun) error
	GetSecret(context.Context, ktypes.GetSecretOpt) (string, error)
	GetPodLogs(context.Context, string, string, string, int64) (string, error)
}