cluster

Documentation

Index

• Constants
• Variables
• func CheckBannedUser(clusterID string) error
• func ControlplaneNodeStatus(kubeCli client.Client) error
• func EtcdCrStatus(kubeCli client.Client) (string, error)
• func EtcdHealthCheck(clusterId string) error
• func EtcdPodStatus(kubeCli client.Client) (*corev1.PodList, error)
• func Etcdctlhealth(kconfig *rest.Config, clientset *kubernetes.Clientset, etcdctlCmd string, ...) (string, error)
• func GetCloudTrailLogsForCluster(awsProfile string, clusterID string, maxPages int) ([]*types.Event, error)
• func NewCmdCluster(streams genericclioptions.IOStreams, client *k8s.LazyClient, ...) *cobra.Command
• func NewCmdHypershiftInfo(streams genericclioptions.IOStreams) *cobra.Command
• type ChanReturn
• type ClusterHealthCondensedObject
• type CreatorPatch
• type LogCapture
  • func (capture *LogCapture) GetStdOut() string
  • func (capture *LogCapture) Write(p []byte) (n int, err error)
• type OrgId
  • func (o *OrgId) Run(clusterID string) error
• type OrgIdOutput
• type RegisterCluster
• type Resync
  • func (r *Resync) New() error
  • func (r *Resync) Run(ctx context.Context) error

Constants

const (
	JiraBaseURL                   = "https://issues.redhat.com"
	JiraTokenRegistrationPath     = "/secure/ViewProfile.jspa?selectedTab=com.atlassian.pats.pats-plugin:jira-user-personal-access-tokens"
	PagerDutyTokenRegistrationUrl = "https://martindstone.github.io/PDOAuth/"
	ClassicSplunkURL              = "" /* 126-byte string literal not displayed */
	HCPSplunkURL                  = "" /* 172-byte string literal not displayed */

)

const (
	EtcdNamespaceName       = "openshift-etcd"
	EtcdMemberConditionType = "EtcdMembersAvailable"
	ContainerName           = "etcdctl"
	MasterNodeLabel         = "node-role.kubernetes.io/master"
	EtcdPodMatchLabelName   = "k8s-app"
	EtcdPodMatchValueName   = "etcd"
	EtcdLabelSelector       = "k8s-app=etcd"
)

const (
	EtcdQuorumTurnOffPatch = `{"spec": {"unsupportedConfigOverrides": {"useUnsupportedUnsafeNonHANonProductionUnstableEtcd": true}}}`
	EtcdQuorumTurnOnPatch  = `{"spec": {"unsupportedConfigOverrides": null}}`
	EtcdForceRedeployPatch = `{"spec": {"forceRedeploymentReason": "single-master-recovery-%s"}}`
)

Patch Constants

const BanCodeExportControlCompliance = "export_control_compliance"

const CheckSyncMaxAttempts = 24

const HYPERSHIFT_URL = "/api/clusters_mgmt/v1/clusters/{cluster_id}/hypershift"

const Namespace = "openshift-monitoring"

const (
	OldFlowSupportRole = "role/RH-Technical-Support-Access"
)

Variables

var BackplaneClusterAdmin = "backplane-cluster-admin"

Functions

func CheckBannedUser

func CheckBannedUser(clusterID string) error

func ControlplaneNodeStatus

func ControlplaneNodeStatus(kubeCli client.Client) error

func EtcdCrStatus

func EtcdCrStatus(kubeCli client.Client) (string, error)

func EtcdHealthCheck

func EtcdHealthCheck(clusterId string) error

func EtcdPodStatus

func EtcdPodStatus(kubeCli client.Client) (*corev1.PodList, error)

func Etcdctlhealth

func Etcdctlhealth(kconfig *rest.Config, clientset *kubernetes.Clientset, etcdctlCmd string, etcdPodName string) (string, error)

func GetCloudTrailLogsForCluster

func GetCloudTrailLogsForCluster(awsProfile string, clusterID string, maxPages int) ([]*types.Event, error)

func NewCmdCluster

func NewCmdCluster(streams genericclioptions.IOStreams, client *k8s.LazyClient, globalOpts *globalflags.GlobalOptions) *cobra.Command

NewCmdCluster implements the cluster utility

func NewCmdHypershiftInfo

func NewCmdHypershiftInfo(streams genericclioptions.IOStreams) *cobra.Command

newCmdPool gets the current status of the AWS Account Operator AccountPool

Types

type ChanReturn

type ChanReturn[T retrievable] struct {
	Value T
	Error error
}

type ClusterHealthCondensedObject

type ClusterHealthCondensedObject struct {
	ID       string   `yaml:"ID"`
	Name     string   `yaml:"Name"`
	Provider string   `yaml:"Provider"`
	AZs      []string `yaml:"AZs"`
	Expected struct {
		Master int         `yaml:"Master"`
		Infra  int         `yaml:"Infra"`
		Worker interface{} `yaml:"Worker"`
	} `yaml:"Expected nodes"`
	Actual struct {
		Total          int `yaml:"Total"`
		Stopped        int `yaml:"Stopped"`
		RunningMasters int `yaml:"Running Masters"`
		RunningInfra   int `yaml:"Running Infra"`
		RunningWorker  int `yaml:"Running Worker"`
	} `yaml:"Actual nodes"`
}

type CreatorPatch

type CreatorPatch struct {
	Creator_ID string `json:"creator_id"`
}

type LogCapture

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

func (*LogCapture) GetStdOut

func (capture *LogCapture) GetStdOut() string

func (*LogCapture) Write

func (capture *LogCapture) Write(p []byte) (n int, err error)

type OrgId

type OrgId struct {
}

func (*OrgId) Run

func (o *OrgId) Run(clusterID string) error

type OrgIdOutput

type OrgIdOutput struct {
	ExternalId string `json:"external_id"`
	InternalId string `json:"internal_id"`
}

type RegisterCluster

type RegisterCluster struct {
	External_id     string `json:"external_id"`
	Subscription_id string `json:"subscription_id"`
	Organization_id string `json:"organization_id"`
	Console_url     string `json:"console_url"`
	Display_name    string `json:"display_name"`
}

type Resync

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

func (*Resync) New

func (r *Resync) New() error

func (*Resync) Run

func (r *Resync) Run(ctx context.Context) error