Documentation ¶
Index ¶
- type LinkState
- type RunMode
- type RunModeBase
- func (this *RunModeBase) Cleanup() error
- func (this *RunModeBase) Debugf(msgfmt string, args ...interface{})
- func (this *RunModeBase) Env() RunModeEnv
- func (this *RunModeBase) Errorf(msgfmt string, args ...interface{})
- func (this *RunModeBase) GetErrorForMeshNode(ip net.IP) error
- func (this *RunModeBase) GetInterface() netlink.Link
- func (this *RunModeBase) GetLinkState(klink *api.KubeLink) LinkState
- func (this *RunModeBase) HandleDNSPropagation(klink *api.KubeLink)
- func (this *RunModeBase) Infof(msgfmt string, args ...interface{})
- func (this *RunModeBase) Name() string
- func (this *RunModeBase) ReconcileInterface(logger logger.LogContext) error
- func (this *RunModeBase) RequiredIPTablesChains() iptables.Requests
- func (this *RunModeBase) Setup() error
- func (this *RunModeBase) Start() error
- func (this *RunModeBase) UpdateLocalGatewayInfo(*controllers.LocalGatewayInfo)
- type RunModeEnv
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RunMode ¶
type RunMode interface { Name() string Env() RunModeEnv Start() error Setup() error HandleDNSPropagation(klink *api.KubeLink) GetInterface() netlink.Link UpdateLocalGatewayInfo(*controllers.LocalGatewayInfo) GetErrorForMeshNode(ip net.IP) error RequiredIPTablesChains() iptables.Requests ReconcileInterface(logger logger.LogContext) error GetLinkState(klink *api.KubeLink) LinkState Cleanup() error }
func NewNoneMode ¶
func NewNoneMode(env RunModeEnv) (RunMode, error)
type RunModeBase ¶
type RunModeBase struct { RunModeEnv // contains filtered or unexported fields }
func NewRunModeBase ¶
func NewRunModeBase(name string, env RunModeEnv) RunModeBase
func (*RunModeBase) Cleanup ¶
func (this *RunModeBase) Cleanup() error
func (*RunModeBase) Debugf ¶
func (this *RunModeBase) Debugf(msgfmt string, args ...interface{})
func (*RunModeBase) Env ¶
func (this *RunModeBase) Env() RunModeEnv
func (*RunModeBase) Errorf ¶
func (this *RunModeBase) Errorf(msgfmt string, args ...interface{})
func (*RunModeBase) GetErrorForMeshNode ¶
func (this *RunModeBase) GetErrorForMeshNode(ip net.IP) error
func (*RunModeBase) GetInterface ¶
func (this *RunModeBase) GetInterface() netlink.Link
func (*RunModeBase) GetLinkState ¶
func (this *RunModeBase) GetLinkState(klink *api.KubeLink) LinkState
func (*RunModeBase) HandleDNSPropagation ¶
func (this *RunModeBase) HandleDNSPropagation(klink *api.KubeLink)
func (*RunModeBase) Infof ¶
func (this *RunModeBase) Infof(msgfmt string, args ...interface{})
func (*RunModeBase) Name ¶
func (this *RunModeBase) Name() string
func (*RunModeBase) ReconcileInterface ¶
func (this *RunModeBase) ReconcileInterface(logger logger.LogContext) error
func (*RunModeBase) RequiredIPTablesChains ¶
func (this *RunModeBase) RequiredIPTablesChains() iptables.Requests
func (*RunModeBase) Setup ¶
func (this *RunModeBase) Setup() error
func (*RunModeBase) Start ¶
func (this *RunModeBase) Start() error
func (*RunModeBase) UpdateLocalGatewayInfo ¶
func (this *RunModeBase) UpdateLocalGatewayInfo(*controllers.LocalGatewayInfo)
type RunModeEnv ¶
type RunModeEnv interface { Controller() controller.Interface Config() *config.Config LinkTool() *controllers.LinkTool Secrets() *controllers.SecretCache Tasks() tasks.Tasks Links() kubelink.Links GetAccess() kubelink.LinkAccessInfo GetDNSInfo() kubelink.LinkDNSInfo TriggerUpdate() TriggerLink(kubelink.LinkName) UpdateLinkInfo(logger logger.LogContext, name kubelink.LinkName, access *kubelink.LinkAccessInfo, dns *kubelink.LinkDNSInfo) }
Click to show internal directories.
Click to hide internal directories.