server

package

v2.3.20181123+incompat... Latest Latest Go to latest Published: Oct 18, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/yunionio/sdnagent

Links

Open Source Insights

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 ¶

View Source

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
)

View Source

const (
	TcManCmdAdd = iota
	TcManCmdDel
)

View Source

const FAILSAFE string = "failSAFE"

View Source

const THEMAN string = "THEman"

TODO make them unique

Variables ¶

View Source

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}$`)

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL