f5

Documentation

Index

• type Agent
  • func NewAgent() *Agent
  • func (a *Agent) CleanupL2(ctx context.Context, segmentID int) error
  • func (a *Agent) CleanupSNATPorts(networkID string) error
  • func (a *Agent) CleanupSelfIPs(subnetID string) error
  • func (a *Agent) EnsureL2(ctx context.Context, segmentID int, parentSegmentID *int) error
  • func (a *Agent) EnsureSelfIPs(segmentID int, subnetID string, dryRun bool) error
  • func (a *Agent) GetJobQueue() *common.JobChan
  • func (a *Agent) PendingSyncLoop(job gocron.Job) error
  • func (a *Agent) ProcessEndpoint(ctx context.Context, endpointID strfmt.UUID) error
  • func (a *Agent) ProcessServices(ctx context.Context) error
  • func (a *Agent) PrometheusListenerThread()
  • func (a *Agent) Run()

Types

type Agent

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

func NewAgent

func NewAgent() *Agent

func (*Agent) CleanupL2

func (a *Agent) CleanupL2(ctx context.Context, segmentID int) error

CleanupL2 cleans up L2 configuration on BIG-IP(s) and VCMP(s) for the given segmentID.

func (*Agent) CleanupSNATPorts

func (a *Agent) CleanupSNATPorts(networkID string) error

func (*Agent) CleanupSelfIPs

func (a *Agent) CleanupSelfIPs(subnetID string) error

func (*Agent) EnsureL2

func (a *Agent) EnsureL2(ctx context.Context, segmentID int, parentSegmentID *int) error

EnsureL2 ensures that L2 configuration exists on BIG-IP(s) and VCMP(s) for the given segmentID.

func (*Agent) EnsureSelfIPs

func (a *Agent) EnsureSelfIPs(segmentID int, subnetID string, dryRun bool) error

EnsureSelfIPs ensures that a SelfIPs exists on the BIG-IP(s) for the given endpoint port.

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, endpointID strfmt.UUID) error

func (*Agent) ProcessServices

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

func (*Agent) PrometheusListenerThread

func (a *Agent) PrometheusListenerThread()

func (*Agent) Run

func (a *Agent) Run()