controller

Documentation

Index

• Constants
• func NewServer(cfg ServerOptions) *http.Server
• type ClientOptions
• type Controller
  • func NewController(cloud aws.CloudAPI, kubeclientset kubernetes.Interface, ...) (*Controller, error)
  • func (c *Controller) Run(threadiness int, stopCh chan struct{}) error
• type Handler
• type ServerOptions

Constants

const (
	//setting default threadiness to number of go-routines
	DefaultThreadiness       = 5
	DefaultElection          = true
	DefaultElectionID        = "app-mesh-controller-leader"
	DefaultElectionNamespace = ""
)

Functions

func NewServer

func NewServer(cfg ServerOptions) *http.Server

Types

type ClientOptions

type ClientOptions struct {
	Master     string
	Kubeconfig string
}

type Controller

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

func NewController

func NewController(
	cloud aws.CloudAPI,
	kubeclientset kubernetes.Interface,
	meshclientset meshclientset.Interface,
	podInformer coreinformers.PodInformer,
	meshInformer meshinformers.MeshInformer,
	virtualNodeInformer meshinformers.VirtualNodeInformer,
	virtualServiceInformer meshinformers.VirtualServiceInformer,
	stats *metrics.Recorder,
	leaderElection bool,
	leaderElectionID string,
	leaderElectionNamespace string) (*Controller, error)

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{}) error

type Handler

type Handler struct {
	http.ServeMux
}

type ServerOptions

type ServerOptions struct {
	Address string
}