controllers

Documentation

Index

• type AWSAccess
• type AuthConfig
• type BuiltInWorkersConfig
• type CryptoConfig
• type DBCryptoKey
• type GitHubConfig
• type GitHubLoginStrategy
• type HooksConfig
• type IndexConfig
• type InstanceReconciler
  • func (r *InstanceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *InstanceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MatrixConfig
• type NotifyConfig
• type ObjectConfig
• type PostgresAccess
• type PostgresDatabase
  • func (d *PostgresDatabase) ConnectionString(public, noVerify bool) string
• type PulseAccess
• type PurgeCacheConfig
• type QueueConfig
• type SecretsConfig
• type ServiceAccount
• type SlackConfig
• type TaskClusterAccess
• type TaskClusterOperations
  • func (o *TaskClusterOperations) Build(ctx context.Context) ([]runtime.Object, error)
  • func (o *TaskClusterOperations) Close(ctx context.Context) error
  • func (o *TaskClusterOperations) FinishDeployment(ctx context.Context) (reconcile.Result, error)
  • func (o *TaskClusterOperations) MigrateState(ctx context.Context) error
  • func (o *TaskClusterOperations) Prepare(ctx context.Context) error
  • func (o *TaskClusterOperations) RenderValues(ctx context.Context) (*TaskClusterValues, error)
• type TaskClusterState
• type TaskClusterValues
• type UIConfig
• type UILoginStrategiesConfig
• type WebServerConfig
• type WebSockTunnelBuilder
  • func (b *WebSockTunnelBuilder) Build() ([]runtime.Object, error)
• type WebSockTunnelReconciler
  • func (r *WebSockTunnelReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *WebSockTunnelReconciler) SetupWithManager(mgr ctrl.Manager) error
• type WorkerManagerConfig

Types

type AWSAccess

type AWSAccess struct {
	AccessKeyID     string `json:"aws_access_key_id"`
	SecretAccessKey string `json:"aws_secret_access_key"`
}

type AuthConfig

type AuthConfig struct {
	PostgresAccess
	PulseAccess
	CryptoConfig
	AzureAccounts       map[string]string                      `json:"azure_accounts"`
	StaticAccounts      []taskclusterv1beta1.StaticAccessToken `json:"static_clients"`
	WebSockTunnelSecret string                                 `json:"websocktunnel_secret"`
}

type BuiltInWorkersConfig

type BuiltInWorkersConfig struct {
	TaskClusterAccess
}

type CryptoConfig

type CryptoConfig struct {
	AzureCryptoKey string        `json:"azure_crypto_key,omitempty"`
	DBCryptoKeys   []DBCryptoKey `json:"db_crypto_keys"`
}

type DBCryptoKey

type DBCryptoKey struct {
	ID        string `json:"id"`
	Algorithm string `json:"algo"`
	Key       string `json:"key"`
}

type GitHubConfig

type GitHubConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	BotUsername      string `json:"bot_username"`
	GitHubPrivatePEM string `json:"github_private_pem"`
	GitHubAppID      string `json:"github_app_id"`
	WebhookSecret    string `json:"webhook_secret"`
}

type GitHubLoginStrategy

type GitHubLoginStrategy struct {
	ClientID     string `json:"clientId"`
	ClientSecret string `json:"clientSecret"`
}

type HooksConfig

type HooksConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	CryptoConfig
}

type IndexConfig

type IndexConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
}

type InstanceReconciler

type InstanceReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme

	ChartPath    string
	UsePublicIPs bool
}

InstanceReconciler reconciles a Instance object

func (*InstanceReconciler) Reconcile

func (r *InstanceReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*InstanceReconciler) SetupWithManager

func (r *InstanceReconciler) SetupWithManager(mgr ctrl.Manager) error

type MatrixConfig

type MatrixConfig struct {
	AccessToken string `json:"matrix_access_token,omitempty"`
	BaseURL     string `json:"matrix_base_url,omitempty"`
	UserID      string `json:"matrix_user_id,omitempty"`
}

type NotifyConfig

type NotifyConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	AWSAccess
	MatrixConfig
	SlackConfig
	EmailSourceAddress string `json:"email_source_address"`
}

type ObjectConfig

type ObjectConfig struct {
	TaskClusterAccess
	PostgresAccess
	CryptoConfig
}

type PostgresAccess

type PostgresAccess struct {
	ReadDBURL  string `json:"read_db_url"`
	WriteDBURL string `json:"write_db_url"`
}

type PostgresDatabase

type PostgresDatabase struct {
	PublicIP  string `json:"publicIp"`
	PrivateIP string `json:"privateIp"`
	Username  string `json:"username"`
	Password  string `json:"password"`
	Database  string `json:"database"`
}

func (*PostgresDatabase) ConnectionString

func (d *PostgresDatabase) ConnectionString(public, noVerify bool) string

ConnectionString returns an admin Postgres connection string for this database.

type PulseAccess

type PulseAccess struct {
	PulseUsername string `json:"pulse_username"`
	PulsePassword string `json:"pulse_password"`
}

type PurgeCacheConfig

type PurgeCacheConfig struct {
	TaskClusterAccess
	PostgresAccess
}

type QueueConfig

type QueueConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	AWSAccess
	PublicArtifactBucket   string `json:"public_artifact_bucket"`
	PrivateArtifactBucket  string `json:"private_artifact_bucket"`
	SignPublicArtifactURLs bool   `json:"sign_public_artifact_urls"`
	ArtifactRegion         string `json:"artifact_region"`
}

type SecretsConfig

type SecretsConfig struct {
	TaskClusterAccess
	PostgresAccess
	CryptoConfig
}

type ServiceAccount

type ServiceAccount struct {
	AccessToken      string `json:"accessToken,omitempty"`
	PostgresPassword string `json:"postgresPassword,omitempty"`
	PulsePassword    string `json:"pulsePassword,omitempty"`
	CryptoConfig
}

type SlackConfig

type SlackConfig struct {
	APIURL      string `json:"slack_api_url,omitempty"`
	AccessToken string `json:"slack_access_token,omitempty"`
}

type TaskClusterAccess

type TaskClusterAccess struct {
	AccessToken string `json:"taskcluster_access_token"`
}

type TaskClusterOperations

type TaskClusterOperations struct {
	logr.Logger
	client.Client
	Scheme *runtime.Scheme
	types.NamespacedName

	ChartPath    string
	UsePublicIPs bool
	// contains filtered or unexported fields
}

func (*TaskClusterOperations) Build

func (o *TaskClusterOperations) Build(ctx context.Context) ([]runtime.Object, error)

func (*TaskClusterOperations) Close

func (o *TaskClusterOperations) Close(ctx context.Context) error

func (*TaskClusterOperations) FinishDeployment

func (o *TaskClusterOperations) FinishDeployment(ctx context.Context) (reconcile.Result, error)

func (*TaskClusterOperations) MigrateState

func (o *TaskClusterOperations) MigrateState(ctx context.Context) error

func (*TaskClusterOperations) Prepare

func (o *TaskClusterOperations) Prepare(ctx context.Context) error

func (*TaskClusterOperations) RenderValues

func (o *TaskClusterOperations) RenderValues(ctx context.Context) (*TaskClusterValues, error)

type TaskClusterState

type TaskClusterState struct {
	ServiceAccounts map[string]*ServiceAccount `json:"serviceAccounts,omitempty"`
	SessionSecret   string                     `json:"sessionSecret,omitempty"`
}

type TaskClusterValues

type TaskClusterValues struct {
	Auth           AuthConfig           `json:"auth"`
	BuiltInWorkers BuiltInWorkersConfig `json:"built_in_workers"`
	GitHub         GitHubConfig         `json:"github"`
	Hooks          HooksConfig          `json:"hooks"`
	Index          IndexConfig          `json:"index"`
	Notify         NotifyConfig         `json:"notify"`
	Object         ObjectConfig         `json:"object"`
	PurgeCache     PurgeCacheConfig     `json:"purge_cache"`
	Queue          QueueConfig          `json:"queue"`
	Secrets        SecretsConfig        `json:"secrets"`
	WebServer      WebServerConfig      `json:"web_server"`
	WorkerManager  WorkerManagerConfig  `json:"worker_manager"`
	UI             UIConfig             `json:"ui"`

	RootURL             string `json:"rootUrl"`
	ApplicationName     string `json:"applicationName"`
	IngressStaticIPName string `json:"ingressStaticIpName"`
	IngressSecretName   string `json:"ingressSecretName"`
	IngressExternalDNS  string `json:"ingressExternalDNS"`
	PulseHostname       string `json:"pulseHostname"`
	PulseVHost          string `json:"pulseVhost"`
	DockerImage         string `json:"dockerImage"`
	AzureAccountID      string `json:"azureAccountId"`
}

type UIConfig

type UIConfig struct {
	GraphQLSubscriptionEndpoint string `json:"graphql_subscription_endpoint"`
	GraphQLEndpoint             string `json:"graphql_endpoint"`
	BannerMessage               string `json:"banner_message"`
	UILoginStrategyNames        string `json:"ui_login_strategy_names"`
}

type UILoginStrategiesConfig

type UILoginStrategiesConfig struct {
	GitHub *GitHubLoginStrategy `json:"github"`
}

type WebServerConfig

type WebServerConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	CryptoConfig
	PublicURL                   string                  `json:"public_url"`
	AdditionalAllowedCORSOrigin string                  `json:"additional_allowed_cors_origin"`
	UILoginStrategies           UILoginStrategiesConfig `json:"ui_login_strategies"`
	SessionSecret               string                  `json:"session_secret"`
	RegisteredClients           []string                `json:"registered_clients"`
}

type WebSockTunnelBuilder

type WebSockTunnelBuilder struct {
	logr.Logger

	Source *taskclusterv1beta1.WebSockTunnel
}

func (*WebSockTunnelBuilder) Build

func (b *WebSockTunnelBuilder) Build() ([]runtime.Object, error)

type WebSockTunnelReconciler

type WebSockTunnelReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

WebSockTunnelReconciler reconciles a WebSockTunnel object

func (*WebSockTunnelReconciler) Reconcile

func (r *WebSockTunnelReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*WebSockTunnelReconciler) SetupWithManager

func (r *WebSockTunnelReconciler) SetupWithManager(mgr ctrl.Manager) error

type WorkerManagerConfig

type WorkerManagerConfig struct {
	TaskClusterAccess
	PostgresAccess
	PulseAccess
	CryptoConfig
	Providers map[string]json.RawMessage `json:"providers"`
}