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) GetPool() db.PgxIface
  • func (a *Agent) GetScheduler() gocron.Scheduler
  • func (a *Agent) PendingSyncLoop(ctx context.Context, syncAll bool) 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) GetPool

func (a *Agent) GetPool() db.PgxIface

func (*Agent) GetScheduler

func (a *Agent) GetScheduler() gocron.Scheduler

func (*Agent) PendingSyncLoop

func (a *Agent) PendingSyncLoop(ctx context.Context, syncAll bool) 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
}