server

Documentation

Index

• Constants
• Variables
• type AgentServer
  • func Server() *AgentServer
  • func (s *AgentServer) GetFlowMan(bridge string) *FlowMan
  • func (s *AgentServer) Start() error
  • func (s *AgentServer) Stop()
• type FlowMan
  • func NewFlowMan(bridge string) *FlowMan
  • func (fm *FlowMan) AddFlow(ctx context.Context, of *ovs.Flow)
  • func (fm *FlowMan) DelFlow(ctx context.Context, of *ovs.Flow)
  • func (fm *FlowMan) Start(ctx context.Context)
  • func (fm *FlowMan) SyncFlows(ctx context.Context)
• type FlowManWaitData
• type Guest
  • func NewGuest(guest *utils.Guest, watcher *serversWatcher) *Guest
  • func (g *Guest) ClearSettings(ctx context.Context)
  • func (g *Guest) UpdateSettings(ctx context.Context)
• type HostLocal
  • func NewHostLocal(watcher *serversWatcher) *HostLocal
  • func (hl *HostLocal) UpdateSettings(ctx context.Context)
• type TcMan
  • func NewTcMan() *TcMan
  • func (tm *TcMan) AddIfaces(ctx context.Context, who string, data []*utils.TcData)
  • func (tm *TcMan) ClearIfaces(ctx context.Context, who string)
  • func (tm *TcMan) Start(ctx context.Context)
• type TcManCmd
• type TcManCmdType
• type TcManPage
• type TcManSection
  • func NewTcManSection() *TcManSection
  • func (s *TcManSection) Update(t *TcManSection)

Constants

const (
	DefaultHostConfigPath     string        = "/etc/yunion/host.conf"
	GuestCtZoneBase           uint16        = 1000
	FlowManIdleCheckDuration  time.Duration = 13 * time.Second
	TcManIdleCheckDuration    time.Duration = 17 * time.Second
	WatcherRefreshRate        time.Duration = 31 * time.Second
	WatcherRefreshRateOnError time.Duration = 3 * time.Second
	WatcherRecentPendingTime  time.Duration = WatcherRefreshRateOnError * 5
)

const (
	TcManCmdAdd = iota
	TcManCmdDel
)

const FAILSAFE string = "failSAFE"

const THEMAN string = "THEman"

TODO make them unique

Variables

var REGEX_UUID = regexp.MustCompile(`^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$`)

Types

type AgentServer

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

func Server

func Server() *AgentServer

func (*AgentServer) GetFlowMan

func (s *AgentServer) GetFlowMan(bridge string) *FlowMan

func (*AgentServer) Start

func (s *AgentServer) Start() error

func (*AgentServer) Stop

func (s *AgentServer) Stop()

type FlowMan

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

func NewFlowMan

func NewFlowMan(bridge string) *FlowMan

func (*FlowMan) AddFlow

func (fm *FlowMan) AddFlow(ctx context.Context, of *ovs.Flow)

func (*FlowMan) DelFlow

func (fm *FlowMan) DelFlow(ctx context.Context, of *ovs.Flow)

func (*FlowMan) Start

func (fm *FlowMan) Start(ctx context.Context)

func (*FlowMan) SyncFlows

func (fm *FlowMan) SyncFlows(ctx context.Context)

type FlowManWaitData

type FlowManWaitData struct {
	Count   int32
	FlowMan *FlowMan
}

type Guest

type Guest struct {
	*utils.Guest
	// contains filtered or unexported fields
}

func NewGuest

func NewGuest(guest *utils.Guest, watcher *serversWatcher) *Guest

func (*Guest) ClearSettings

func (g *Guest) ClearSettings(ctx context.Context)

func (*Guest) UpdateSettings

func (g *Guest) UpdateSettings(ctx context.Context)

type HostLocal

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

func NewHostLocal

func NewHostLocal(watcher *serversWatcher) *HostLocal

func (*HostLocal) UpdateSettings

func (hl *HostLocal) UpdateSettings(ctx context.Context)

type TcMan

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

func NewTcMan

func NewTcMan() *TcMan

func (*TcMan) AddIfaces

func (tm *TcMan) AddIfaces(ctx context.Context, who string, data []*utils.TcData)

func (*TcMan) ClearIfaces

func (tm *TcMan) ClearIfaces(ctx context.Context, who string)

func (*TcMan) Start

func (tm *TcMan) Start(ctx context.Context)

type TcManCmd

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

type TcManCmdType

type TcManCmdType int

type TcManPage

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

type TcManSection

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

func NewTcManSection

func NewTcManSection() *TcManSection

func (*TcManSection) Update

func (s *TcManSection) Update(t *TcManSection)