operator

Documentation

Overview

* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• type Config
  • func NewSubmarineOperatorConfig() *Config
  • func (c *Config) AddFlags(fs *pflag.FlagSet)
• type SubmarineOperator
  • func NewSubmarineOperator(cfg *Config) *SubmarineOperator
  • func (op *SubmarineOperator) Run(stop <-chan struct{}) error

Types

type Config

type Config struct {
	KubeConfigFile string
	Master         string
	ListenAddr     string
	Submarine      config.Submarine
}

Config contains configuration for submarine-operator

func NewSubmarineOperatorConfig

func NewSubmarineOperatorConfig() *Config

NewSubmarineOperatorConfig builds and returns a submarine-operator Config

func (*Config) AddFlags

func (c *Config) AddFlags(fs *pflag.FlagSet)

AddFlags add cobra flags to populate Config

type SubmarineOperator

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

Controller is the controller implementation for Student resources

func NewSubmarineOperator

func NewSubmarineOperator(cfg *Config) *SubmarineOperator

func (*SubmarineOperator) Run

func (op *SubmarineOperator) Run(stop <-chan struct{}) error

Run executes the Submarine Operator