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.