pipelineascode

package

v0.40.0 Latest Latest Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation ¶

Index ¶

Constants
func GetCurrentNSWebhookSecret(ctx context.Context, k8int kubeinteraction.Interface, run *params.Run) (string, error)
func SetupAuthenticatedClient(ctx context.Context, vcx provider.Interface, kint kubeinteraction.Interface, ...) error
type ConcurrencyManager
- func NewConcurrencyManager() *ConcurrencyManager
type PacRun
- func NewPacs(event *info.Event, vcx provider.Interface, run *params.Run, ...) PacRun
- func (p *PacRun) Run(ctx context.Context) error
type SecretFromRepository
- func (s *SecretFromRepository) Get(ctx context.Context) error

Constants ¶

const (
	DefaultGitProviderSecretKey        = "provider.token"
	DefaultGitProviderWebhookSecretKey = "webhook.secret"
)

View Source

const (
	CompletedStatus = "completed"
)

Variables ¶

This section is empty.

Functions ¶

func GetCurrentNSWebhookSecret ¶

func GetCurrentNSWebhookSecret(ctx context.Context, k8int kubeinteraction.Interface, run *params.Run) (string, error)

GetCurrentNSWebhookSecret get secret from namespace as stored on context.

func SetupAuthenticatedClient ¶ added in v0.40.0

func SetupAuthenticatedClient(
	ctx context.Context,
	vcx provider.Interface,
	kint kubeinteraction.Interface,
	run *params.Run,
	event *info.Event,
	repo *v1alpha1.Repository,
	globalRepo *v1alpha1.Repository,
	pacInfo *info.PacOpts,
	logger *zap.SugaredLogger,
) error

SetupAuthenticatedClient sets up the authenticated VCS client with proper token scoping. This is the centralized place for all client authentication and token scoping logic.

This function is idempotent and safe to call multiple times.

Types ¶

type ConcurrencyManager ¶ added in v0.15.0

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

func NewConcurrencyManager ¶ added in v0.15.0

func NewConcurrencyManager() *ConcurrencyManager

func (*ConcurrencyManager) AddPipelineRun ¶ added in v0.15.0

func (c *ConcurrencyManager) AddPipelineRun(pr *v1.PipelineRun)

func (*ConcurrencyManager) Enable ¶ added in v0.15.0

func (c *ConcurrencyManager) Enable()

func (*ConcurrencyManager) GetExecutionOrder ¶ added in v0.15.0

func (c *ConcurrencyManager) GetExecutionOrder() (string, []*v1.PipelineRun)

type PacRun ¶

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

func NewPacs ¶

func NewPacs(event *info.Event, vcx provider.Interface, run *params.Run, pacInfo *info.PacOpts, k8int kubeinteraction.Interface, logger *zap.SugaredLogger, globalRepo *v1alpha1.Repository) PacRun

func (*PacRun) Run ¶

func (p *PacRun) Run(ctx context.Context) error

type SecretFromRepository ¶

type SecretFromRepository struct {
	K8int       kubeinteraction.Interface
	Config      *info.ProviderConfig
	Event       *info.Event
	Repo        *apipac.Repository
	WebhookType string
	Namespace   string
	Logger      *zap.SugaredLogger
}

func (*SecretFromRepository) Get ¶ added in v0.27.0

func (s *SecretFromRepository) Get(ctx context.Context) error

Get grab the secret from the repository CRD.

Source Files ¶

View all Source files

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