flagutil

package
v0.0.0-...-1738bad Latest Latest
Warning

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

 Go to latest Published: May 10, 2024 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Overview

Package flagutil contains utilities and interfaces shared between several Prow commands.

Package flagutil contains utilities and interfaces shared between several test-infra commands.

Index

Constants

View Source 
const (
	DefaultMetricsPort = 9090
	DefaultPProfPort   = 6060
	DefaultHealthPort  = 8081

	DefaultMemoryProfileInterval = 30 * time.Second
)

Variables

View Source 
var MissingPermissions = errors.New("missing permissions")

Functions

func CheckAuthorizations 

func CheckAuthorizations(client authorizationv1.SelfSubjectAccessReviewInterface, namespace string, requiredTestPodVerbs []string) error

CheckAuthorizations checks if we are able to perform the required actions against test pods for the provided pod verbs (requiredTestPodVerbs).

Types

type Bool 

type Bool struct {
	Value    bool
	Explicit bool
}

Bool holds a boolean flag value, tracking whether it was set explicitly.

func (*Bool) IsBoolFlag 

func (b *Bool) IsBoolFlag() bool

IsBoolFlag causes golang to consider --foo to mean --foo=true

func (*Bool) Set 

func (b *Bool) Set(s string) error

Set the bool according to the string.

func (*Bool) String 

func (b *Bool) String() string

String value of the string.

type BugzillaOptions 

type BugzillaOptions struct {
	ApiKeyPath string
	// contains filtered or unexported fields
}

BugzillaOptions holds options for interacting with Bugzilla.

func (*BugzillaOptions) AddFlags 

func (o *BugzillaOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects Bugzilla options into the given FlagSet.

func (*BugzillaOptions) BugzillaClient 

func (o *BugzillaOptions) BugzillaClient() (bugzilla.Client, error)

BugzillaClient returns a Bugzilla client.

func (*BugzillaOptions) Validate 

func (o *BugzillaOptions) Validate(dryRun bool) error

Validate validates Bugzilla options.

type ControllerManagerOptions 

type ControllerManagerOptions struct {
	TimeoutListingProwJobs        time.Duration
	TimeoutListingProwJobsDefault time.Duration
}

func (*ControllerManagerOptions) AddFlags 

func (o *ControllerManagerOptions) AddFlags(fs *flag.FlagSet)

func (*ControllerManagerOptions) Validate 

func (o *ControllerManagerOptions) Validate(_ bool) error

type FlagParameter 

type FlagParameter func(options *flagParams)

func DisableThrottlerOptions 

func DisableThrottlerOptions() FlagParameter

DisableThrottlerOptions suppresses the presence of throttler-related flags, effectively disallowing external users to parametrize default throttling behavior. This is useful mostly when a program creates multiple GH clients with different behavior.

func ThrottlerDefaults 

func ThrottlerDefaults(hourlyTokens, allowedBursts int) FlagParameter

ThrottlerDefaults allows to customize the default values of flags that control the throttler behavior. Setting `hourlyTokens` to zero disables throttling by default.

type GerritFields 

type GerritFields struct {
	MaxQPS, MaxBurst int // No throttling when unset.
}

type GerritOptions 

type GerritOptions struct {
	GerritFields
	// contains filtered or unexported fields
}

func (*GerritOptions) AddFlags 

func (o *GerritOptions) AddFlags(fs *flag.FlagSet)

func (*GerritOptions) SetDefaultThrottle 

func (o *GerritOptions) SetDefaultThrottle(MaxQPS, MaxBurst int)

func (*GerritOptions) Validate 

func (o *GerritOptions) Validate(dryrun bool) error

type GitHubEnablementOptions 

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

GitHubEnablementOptions allows enable/disable functionality on a github org or org/repo level. If either EnabledOrgs or EnabledRepos is set, only org/repos in those are allowed, otherwise everything that is not in DisabledOrgs or DisabledRepos is allowed.

func (*GitHubEnablementOptions) AddFlags 

func (o *GitHubEnablementOptions) AddFlags(fs *flag.FlagSet)

func (*GitHubEnablementOptions) EnablementChecker 

func (o *GitHubEnablementOptions) EnablementChecker() func(org, repo string) bool

func (*GitHubEnablementOptions) Validate 

func (o *GitHubEnablementOptions) Validate(_ bool) error

type GitHubOptions 

type GitHubOptions struct {
	Host string

	TokenPath         string
	AllowAnonymous    bool
	AllowDirectAccess bool
	AppID             string
	AppPrivateKeyPath string

	ThrottleHourlyTokens int
	ThrottleAllowBurst   int

	OrgThrottlers Strings
	// contains filtered or unexported fields
}

GitHubOptions holds options for interacting with GitHub.

Set AllowAnonymous to be true if you want to allow anonymous github access. Set AllowDirectAccess to be true if you want to suppress warnings on direct github access (without ghproxy).

func (*GitHubOptions) AddCustomizedFlags 

func (o *GitHubOptions) AddCustomizedFlags(fs *flag.FlagSet, paramFuncs ...FlagParameter)

AddCustomizedFlags injects GitHub options into the given FlagSet. Behavior can be customized via the functional options.

func (*GitHubOptions) AddFlags 

func (o *GitHubOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects GitHub options into the given FlagSet

func (*GitHubOptions) GitClientFactory 

func (o *GitHubOptions) GitClientFactory(cookieFilePath string, cacheDir *string, dryRun, persistCache bool) (gitv2.ClientFactory, error)

GitClientFactory returns git.ClientFactory. Passing non-empty cookieFilePath will result in git ClientFactory to work with Gerrit. TODO(chaodaiG): move this logic to somewhere more appropriate instead of in github.go.

func (*GitHubOptions) GitHubClient 

func (o *GitHubOptions) GitHubClient(dryRun bool) (github.Client, error)

GitHubClient returns a GitHub client.

func (*GitHubOptions) GitHubClientWithAccessToken 

func (o *GitHubOptions) GitHubClientWithAccessToken(token string) (github.Client, error)

GitHubClientWithAccessToken creates a GitHub client from an access token.

func (*GitHubOptions) GitHubClientWithLogFields 

func (o *GitHubOptions) GitHubClientWithLogFields(dryRun bool, fields logrus.Fields) (github.Client, error)

GitHubClientWithLogFields returns a GitHub client with extra logging fields

func (*GitHubOptions) Validate 

func (o *GitHubOptions) Validate(bool) error

Validate validates GitHub options. Note that validate updates the GitHubOptions to add default values for TokenPath and graphqlEndpoint.

type InstrumentationOptions 

type InstrumentationOptions struct {
	// MetricsPort is the port which is used to serve metrics
	MetricsPort int
	// PProfPort is the port which is used to serve pprof
	PProfPort int
	// HealthPort is the port which is used to serve liveness and readiness
	HealthPort int

	// ProfileMemory determines if the process should profile memory
	ProfileMemory bool
	// MemoryProfileInterval is the interval at which memory profiles should be dumped
	MemoryProfileInterval time.Duration
}

InstrumentationOptions holds common options which are used across Prow components

func DefaultInstrumentationOptions 

func DefaultInstrumentationOptions() InstrumentationOptions

DefaultInstrumentationOptions returns an initialized options struct, mostly for use in tests.

func (*InstrumentationOptions) AddFlags 

func (o *InstrumentationOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects common options into the given FlagSet.

func (*InstrumentationOptions) Validate 

func (o *InstrumentationOptions) Validate(_ bool) error

type JiraOptions 

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

func (*JiraOptions) AddFlags 

func (o *JiraOptions) AddFlags(fs *flag.FlagSet)

func (*JiraOptions) Client 

func (o *JiraOptions) Client() (jira.Client, error)

func (*JiraOptions) Validate 

func (o *JiraOptions) Validate(_ bool) error

type KubernetesClientOptions 

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

KubernetesClientOptions holds options for interacting with Kubernetes.

func (*KubernetesClientOptions) AddFlags 

func (o *KubernetesClientOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects Kubernetes options into the given FlagSet.

func (*KubernetesClientOptions) KubeClient 

func (o *KubernetesClientOptions) KubeClient() (kubernetes.Interface, error)

KubeClient returns a Kubernetes client.

func (*KubernetesClientOptions) ProwJobClient 

func (o *KubernetesClientOptions) ProwJobClient() (versioned.Interface, error)

ProwJobClient returns a Kubernetes client.

func (*KubernetesClientOptions) Validate 

func (o *KubernetesClientOptions) Validate(dryRun bool) error

Validate validates Kubernetes options.

type KubernetesOptions 

type KubernetesOptions struct {
	NOInClusterConfigDefault bool
	// contains filtered or unexported fields
}

KubernetesOptions holds options for interacting with Kubernetes. These options are both useful for clients interacting with ProwJobs and other resources on the infrastructure cluster, as well as Pods on build clusters.

func (*KubernetesOptions) AddFlags 

func (o *KubernetesOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects Kubernetes options into the given FlagSet.

func (*KubernetesOptions) AddKubeconfigChangeCallback 

func (o *KubernetesOptions) AddKubeconfigChangeCallback(callback func()) error

AddKubeconfigChangeCallback adds a callback that gets called whenever the kubeconfig changes. The main usecase for this is to exit components that can not reload a kubeconfig at runtime so the kubelet restarts them

func (*KubernetesOptions) BuildClusterClients 

func (o *KubernetesOptions) BuildClusterClients(namespace string, dryRun bool) (buildClusterClients map[string]corev1.PodInterface, err error)

BuildClusterClients returns Pod clients for build clusters.

func (*KubernetesOptions) BuildClusterCoreV1Clients 

func (o *KubernetesOptions) BuildClusterCoreV1Clients(dryRun bool) (v1Clients map[string]corev1.CoreV1Interface, err error)

BuildClusterCoreV1Clients returns core v1 clients for build clusters.

func (*KubernetesOptions) BuildClusterManagers 

func (o *KubernetesOptions) BuildClusterManagers(dryRun bool, requiredTestPodVerbs []string, callBack func(), namespace string, opts ...func(*manager.Options)) (map[string]manager.Manager, error)

BuildClusterManagers returns a manager per buildCluster. Per default, LeaderElection and the metrics listener are disabled, as we assume that there is another manager for ProwJobs that handles that.

func (*KubernetesOptions) BuildClusterUncachedRuntimeClients 

func (o *KubernetesOptions) BuildClusterUncachedRuntimeClients(dryRun bool) (map[string]ctrlruntimeclient.Client, error)

BuildClusterUncachedRuntimeClients returns ctrlruntimeclients for the build cluster in a non-caching implementation.

func (*KubernetesOptions) ClusterClientForContext 

func (o *KubernetesOptions) ClusterClientForContext(context string, dryRun bool) (kubernetesClient kubernetes.Interface, err error)

ClusterClientForContext returns a Kubernetes client for the given context name.

func (*KubernetesOptions) InfrastructureClusterClient 

func (o *KubernetesOptions) InfrastructureClusterClient(dryRun bool) (kubernetesClient kubernetes.Interface, err error)

InfrastructureClusterClient returns a Kubernetes client for the infrastructure cluster.

func (*KubernetesOptions) InfrastructureClusterConfig 

func (o *KubernetesOptions) InfrastructureClusterConfig(dryRun bool) (*rest.Config, error)

InfrastructureClusterConfig returns the *rest.Config for the infrastructure cluster

func (*KubernetesOptions) KnownClusters 

func (o *KubernetesOptions) KnownClusters(dryRun bool) (map[string]rest.Config, error)

func (*KubernetesOptions) LoadClusterConfigs 

func (o *KubernetesOptions) LoadClusterConfigs(callBacks ...func()) (map[string]rest.Config, error)

LoadClusterConfigs returns the resolved rest.Configs and each callback function will be executed if the underlying kubeconfig files are modified. This function is for the case where the rest.Configs are needed without interests of the clients.

func (*KubernetesOptions) ProwJobClient 

func (o *KubernetesOptions) ProwJobClient(namespace string, dryRun bool) (prowJobClient prowv1.ProwJobInterface, err error)

ProwJobClient returns a ProwJob client.

func (*KubernetesOptions) ProwJobClientset 

func (o *KubernetesOptions) ProwJobClientset(dryRun bool) (prowJobClientset prow.Interface, err error)

ProwJobClientset returns a ProwJob clientset for use in informer factories.

func (*KubernetesOptions) SetDisabledClusters 

func (o *KubernetesOptions) SetDisabledClusters(disabledClusters sets.Set[string])

SetDisabledClusters sets disabledClusters It has no effects if the options have been resolved.

func (*KubernetesOptions) Validate 

func (o *KubernetesOptions) Validate(_ bool) error

Validate validates Kubernetes options.

type OptionGroup 

type OptionGroup interface {
	// AddFlags injects options into the given FlagSet.
	AddFlags(fs *flag.FlagSet)

	// Validate validates options.
	Validate(dryRun bool) error
}

OptionGroup provides an interface which can be implemented by an option handler (e.g. for GitHub or Kubernetes) to support generic option-group handling.

type StorageClientOptions 

type StorageClientOptions struct {
	// GCSCredentialsFile is used for reading/writing to GCS block storage.
	// It's optional, if you want to write to local paths or GCS credentials auto-discovery is used.
	// If set, this file is used to read/write to gs:// paths
	// If not, credential auto-discovery is used
	GCSCredentialsFile string `json:"gcs_credentials_file,omitempty"`
	// S3CredentialsFile is used for reading/writing to s3 block storage.
	// It's optional, if you want to write to local paths or S3 credentials auto-discovery is used.
	// If set, this file is used to read/write to s3:// paths
	// If not, go cloud credential auto-discovery is used
	// For more details see the prow/io/providers pkg.
	S3CredentialsFile string `json:"s3_credentials_file,omitempty"`
}

func (*StorageClientOptions) AddFlags 

func (o *StorageClientOptions) AddFlags(fs *flag.FlagSet)

AddFlags injects status client options into the given FlagSet.

func (*StorageClientOptions) HasGCSCredentials 

func (o *StorageClientOptions) HasGCSCredentials() bool

func (*StorageClientOptions) HasS3Credentials 

func (o *StorageClientOptions) HasS3Credentials() bool

func (*StorageClientOptions) StorageClient 

func (o *StorageClientOptions) StorageClient(ctx context.Context) (io.Opener, error)

StorageClient returns a Storage client.

func (*StorageClientOptions) Validate 

func (o *StorageClientOptions) Validate(dryRun bool) error

Validate validates options.

type Strings 

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

Strings represents the value of a flag that accept multiple strings.

func NewStrings 

func NewStrings(def ...string) Strings

NewStrings returns a Strings struct that defaults to the value of def if left unset.

func NewStringsBeenSet 

func NewStringsBeenSet(def ...string) Strings

NewStringsBeenSet returns a Strings struct with beenSet: true

func (*Strings) Add 

func (s *Strings) Add(value string)

Add records the value passes, adding to the defaults (if any)

func (*Strings) Set 

func (s *Strings) Set(value string) error

Set records the value passed, overwriting the defaults (if any)

func (*Strings) String 

func (s *Strings) String() string

String returns a concatenated string of all the values joined by commas.

func (*Strings) StringSet 

func (s *Strings) StringSet() sets.Set[string]

StringSet returns a sets.Set[string] of strings set for this value instance.

func (*Strings) Strings 

func (s *Strings) Strings() []string

Strings returns the slice of strings set for this value instance.

Source Files

View all Source files

Directories

Path Synopsis

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.