controller

Documentation

Index

• type GatherJob
  • func (g *GatherJob) Gather(ctx context.Context, kubeConfig, protoKubeConfig *rest.Config) error
  • func (g *GatherJob) GatherAndUpload(kubeConfig, protoKubeConfig *rest.Config) error
• type Operator
  • func (s *Operator) Run(ctx context.Context, controller *controllercmd.ControllerContext) error

Types

type GatherJob

type GatherJob struct {
	config.Controller
	InsightsConfigAPIEnabled bool
}

GatherJob is the type responsible for controlling a non-periodic Gather execution

func (*GatherJob) Gather

func (g *GatherJob) Gather(ctx context.Context, kubeConfig, protoKubeConfig *rest.Config) error

Gather runs a single gather and stores the generated archive, without uploading it. 1. Creates the necessary configs/clients 2. Creates the configobserver to get more configs 3. Initiates the recorder 4. Executes a Gather 5. Flushes the results

func (*GatherJob) GatherAndUpload

func (g *GatherJob) GatherAndUpload(kubeConfig, protoKubeConfig *rest.Config) error

GatherAndUpload runs a single gather and stores the generated archive, uploads it. 1. Prepare the necessary kube configs 2. Get the corresponding "datagathers.insights.openshift.io" resource 3. Create all the gatherers 4. Run data gathering 5. Recodrd the data into the Insights archive 6. Get the latest archive and upload it 7. Updates the status of the corresponding "datagathers.insights.openshift.io" resource continuously

type Operator

type Operator struct {
	config.Controller
}

Operator is the type responsible for controlling the start-up of the Insights Operator

func (*Operator) Run

func (s *Operator) Run(ctx context.Context, controller *controllercmd.ControllerContext) error

Run starts the Insights Operator: 1. Gets/Creates the necessary configs/clients 2. Starts the configobserver and status reporter 3. Initiates the recorder and starts the periodic record pruneing 4. Starts the periodic gathering 5. Creates the insights-client and starts uploader and reporter