ovn

Documentation

Index

• func NewWorker(opts *options.Options) worker.IWorker
• type OVNNorthboundKeeper
  • func DumpOVNNorthbound(ctx context.Context, cli *ovnutil.OvnNbCtl) (*OVNNorthboundKeeper, error)
  • func (keeper *OVNNorthboundKeeper) ClaimDnsRecords(ctx context.Context, vpcs agentmodels.Vpcs, dnsrecords agentmodels.DnsRecords) error
  • func (keeper *OVNNorthboundKeeper) ClaimGroupnetwork(ctx context.Context, groupnetwork *agentmodels.Groupnetwork) error
  • func (keeper *OVNNorthboundKeeper) ClaimGuestnetwork(ctx context.Context, guestnetwork *agentmodels.Guestnetwork, ...) error
  • func (keeper *OVNNorthboundKeeper) ClaimLoadbalancerNetwork(ctx context.Context, loadbalancerNetwork *agentmodels.LoadbalancerNetwork) error
  • func (keeper *OVNNorthboundKeeper) ClaimNetwork(ctx context.Context, network *agentmodels.Network, opts *options.Options) error
  • func (keeper *OVNNorthboundKeeper) ClaimRoutes(ctx context.Context, vpc *agentmodels.Vpc, routes resolvedRoutes) error
  • func (keeper *OVNNorthboundKeeper) ClaimVpc(ctx context.Context, vpc *agentmodels.Vpc) error
  • func (keeper *OVNNorthboundKeeper) ClaimVpcEipgw(ctx context.Context, vpc *agentmodels.Vpc) error
  • func (keeper *OVNNorthboundKeeper) ClaimVpcGuestDnsRecords(ctx context.Context, vpc *agentmodels.Vpc) error
  • func (keeper *OVNNorthboundKeeper) ClaimVpcHost(ctx context.Context, vpc *agentmodels.Vpc, host *agentmodels.Host) error
  • func (keeper *OVNNorthboundKeeper) Mark(ctx context.Context)
  • func (keeper *OVNNorthboundKeeper) Sweep(ctx context.Context) error
• type Worker
  • func (w *Worker) Start(ctx context.Context, app *appsrv.Application, prefix string)

Functions

func NewWorker

func NewWorker(opts *options.Options) worker.IWorker

Types

type OVNNorthboundKeeper

type OVNNorthboundKeeper struct {
	DB ovn_nb.OVNNorthbound
	// contains filtered or unexported fields
}

func DumpOVNNorthbound

func DumpOVNNorthbound(ctx context.Context, cli *ovnutil.OvnNbCtl) (*OVNNorthboundKeeper, error)

func (*OVNNorthboundKeeper) ClaimDnsRecords

func (keeper *OVNNorthboundKeeper) ClaimDnsRecords(ctx context.Context, vpcs agentmodels.Vpcs, dnsrecords agentmodels.DnsRecords) error

func (*OVNNorthboundKeeper) ClaimGroupnetwork

func (keeper *OVNNorthboundKeeper) ClaimGroupnetwork(ctx context.Context, groupnetwork *agentmodels.Groupnetwork) error

func (*OVNNorthboundKeeper) ClaimGuestnetwork

func (keeper *OVNNorthboundKeeper) ClaimGuestnetwork(ctx context.Context, guestnetwork *agentmodels.Guestnetwork, opts *options.Options) error

func (*OVNNorthboundKeeper) ClaimLoadbalancerNetwork

func (keeper *OVNNorthboundKeeper) ClaimLoadbalancerNetwork(ctx context.Context, loadbalancerNetwork *agentmodels.LoadbalancerNetwork) error

func (*OVNNorthboundKeeper) ClaimNetwork

func (keeper *OVNNorthboundKeeper) ClaimNetwork(ctx context.Context, network *agentmodels.Network, opts *options.Options) error

func (*OVNNorthboundKeeper) ClaimRoutes

func (keeper *OVNNorthboundKeeper) ClaimRoutes(ctx context.Context, vpc *agentmodels.Vpc, routes resolvedRoutes) error

func (*OVNNorthboundKeeper) ClaimVpc

func (keeper *OVNNorthboundKeeper) ClaimVpc(ctx context.Context, vpc *agentmodels.Vpc) error

func (*OVNNorthboundKeeper) ClaimVpcEipgw

func (keeper *OVNNorthboundKeeper) ClaimVpcEipgw(ctx context.Context, vpc *agentmodels.Vpc) error

func (*OVNNorthboundKeeper) ClaimVpcGuestDnsRecords

func (keeper *OVNNorthboundKeeper) ClaimVpcGuestDnsRecords(ctx context.Context, vpc *agentmodels.Vpc) error

func (*OVNNorthboundKeeper) ClaimVpcHost

func (keeper *OVNNorthboundKeeper) ClaimVpcHost(ctx context.Context, vpc *agentmodels.Vpc, host *agentmodels.Host) error

func (*OVNNorthboundKeeper) Mark

func (keeper *OVNNorthboundKeeper) Mark(ctx context.Context)

func (*OVNNorthboundKeeper) Sweep

func (keeper *OVNNorthboundKeeper) Sweep(ctx context.Context) error

type Worker

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

func (*Worker) Start

func (w *Worker) Start(ctx context.Context, app *appsrv.Application, prefix string)