warden

Documentation

Index

• type Config
  • func (c *Config) Validate() []error
• type Warden
  • func NewWardenWithOpts(opts *Config) *Warden
  • func (w Warden) Initialize() error
  • func (w *Warden) Run(stop <-chan struct{})

Types

type Config

type Config struct {
	// generic
	Cluster                string
	InMemberCluster        bool
	IsWritable             bool
	LocalClusterKubeConfig string
	PivotClusterKubeConfig string
	KlogLevel              string

	// report
	PivotKubeHost string
	PeriodSecond  int
	WaitSecond    int
	RetryCounts   int

	// api server
	JwtSecret string
	Addr      string
	Port      int
	TlsCert   string
	TlsKey    string

	// local manager
	AllowPrivileged   bool
	LeaderElect       bool
	WebhookCert       string
	WebhookServerPort int
	EnableControllers string

	// nginx ingress controller param
	NginxNamespace           string
	NginxTcpServiceConfigMap string
	NginxUdpServiceConfigMap string
}

func (*Config) Validate

func (c *Config) Validate() []error

type Warden

type Warden struct {
	*Config

	SyncCtrl  *syncmgr.SyncManager
	Server    *server.Server
	Reporter  *reporter.Reporter
	LocalCtrl *localmgr.LocalManager
}

Warden has two shapes: 1. Running in pivot cluster as a independent process. 2. Running in member cluster as a independent process.

func NewWardenWithOpts

func NewWardenWithOpts(opts *Config) *Warden

func (Warden) Initialize

func (w Warden) Initialize() error

func (*Warden) Run

func (w *Warden) Run(stop <-chan struct{})