ni

Documentation

Index

• func DeleteNetworkNamespace(networkID string) error
• type Agent
  • func NewAgent() *Agent
  • func (a *Agent) CollectStats()
  • func (a *Agent) DisableInjection(si *ServiceInjection) error
  • func (a *Agent) EnableInjection(si *ServiceInjection) error
  • func (a *Agent) GetJobQueue() *common.JobChan
  • func (a *Agent) PendingSyncLoop(job gocron.Job) error
  • func (a *Agent) ProcessEndpoint(ctx context.Context, id strfmt.UUID) error
  • func (a *Agent) ProcessServices(ctx context.Context) error
  • func (a *Agent) Run()
  • func (a *Agent) SetupOpenStack() error
• type HAProxyController
  • func NewHAProxyController() *HAProxyController
• type NetworkNamespace
  • func EnsureNetworkNamespace(port *ports.Port, client *gophercloud.ServiceClient) (*NetworkNamespace, error)
  • func (ns *NetworkNamespace) Close() error
  • func (ns *NetworkNamespace) DisableNetworkNamespace() error
  • func (ns *NetworkNamespace) EnableNetworkNamespace() error
• type ServiceInjection

Functions

func DeleteNetworkNamespace

func DeleteNetworkNamespace(networkID string) error

Types

type Agent

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

func NewAgent

func NewAgent() *Agent

func (*Agent) CollectStats

func (a *Agent) CollectStats()

func (*Agent) DisableInjection

func (a *Agent) DisableInjection(si *ServiceInjection) error

func (*Agent) EnableInjection

func (a *Agent) EnableInjection(si *ServiceInjection) error

func (*Agent) GetJobQueue

func (a *Agent) GetJobQueue() *common.JobChan

func (*Agent) PendingSyncLoop

func (a *Agent) PendingSyncLoop(job gocron.Job) error

func (*Agent) ProcessEndpoint

func (a *Agent) ProcessEndpoint(ctx context.Context, id strfmt.UUID) error

func (*Agent) ProcessServices

func (a *Agent) ProcessServices(ctx context.Context) error

func (*Agent) Run

func (a *Agent) Run()

func (*Agent) SetupOpenStack

func (a *Agent) SetupOpenStack() error

type HAProxyController

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

func NewHAProxyController

func NewHAProxyController() *HAProxyController

type NetworkNamespace

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

func EnsureNetworkNamespace

func EnsureNetworkNamespace(port *ports.Port, client *gophercloud.ServiceClient) (*NetworkNamespace, error)

func (*NetworkNamespace) Close

func (ns *NetworkNamespace) Close() error

func (*NetworkNamespace) DisableNetworkNamespace

func (ns *NetworkNamespace) DisableNetworkNamespace() error

func (*NetworkNamespace) EnableNetworkNamespace

func (ns *NetworkNamespace) EnableNetworkNamespace() error

type ServiceInjection

type ServiceInjection struct {
	Id        strfmt.UUID
	Status    string
	PortId    strfmt.UUID
	Network   strfmt.UUID
	IpAddress strfmt.IPv4
	Port      int
}