tables

package
v1.20.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// BGPReconcileErrCountPerInstance is number of errors stored per instance in statedb.
	BGPReconcileErrCountPerInstance = 5
)

Variables

View Source 
var (
	BGPReconcileErrorIndex = statedb.Index[*BGPReconcileError, BGPReconcileErrorKey]{
		Name: "key",
		FromObject: func(obj *BGPReconcileError) index.KeySet {
			return index.NewKeySet(
				BGPReconcileErrorKey{
					Instance: obj.Instance,
					ErrorID:  obj.ErrorID,
				}.Key(),
			)
		},
		FromKey: BGPReconcileErrorKey.Key,
		Unique:  true,
	}
	BGPReconcileErrorInstance = statedb.Index[*BGPReconcileError, string]{
		Name: "Instance",
		FromObject: func(obj *BGPReconcileError) index.KeySet {
			return index.NewKeySet(index.String(obj.Instance))
		},
		FromKey:    index.String,
		FromString: index.FromString,
		Unique:     false,
	}
)
View Source 
var (
	DesiredRoutePoliciesByKey          = desiredRoutePoliciesKeyIndex.Query
	DesiredRoutePoliciesByPolicyObject = desiredRoutePoliciesObjectIndex.Query
	DesiredRoutePoliciesByInstance     = desiredRoutePoliciesInstanceIndex.Query
)

Functions

func DesiredRoutePoliciesByInstanceOwner added in v1.20.0 

func DesiredRoutePoliciesByInstanceOwner(instance string, owner string) statedb.Query[*DesiredRoutePolicy]

func DesiredRoutePoliciesByInstanceOwnerResource added in v1.20.0 

func DesiredRoutePoliciesByInstanceOwnerResource(instance string, owner string, resource resource.Key) statedb.Query[*DesiredRoutePolicy]

func NewBGPReconcileErrorTable 

func NewBGPReconcileErrorTable(db *statedb.DB) (statedb.RWTable[*BGPReconcileError], error)

func NewDesiredRoutePoliciesTable added in v1.20.0 

func NewDesiredRoutePoliciesTable(db *statedb.DB) (statedb.RWTable[*DesiredRoutePolicy], error)

Types

type BGPReconcileError 

type BGPReconcileError struct {
	Instance string
	ErrorID  int
	Error    string
}

func (*BGPReconcileError) DeepCopy 

func (re *BGPReconcileError) DeepCopy() *BGPReconcileError

func (*BGPReconcileError) String 

func (re *BGPReconcileError) String() string

func (*BGPReconcileError) TableHeader 

func (re *BGPReconcileError) TableHeader() []string

func (*BGPReconcileError) TableRow 

func (re *BGPReconcileError) TableRow() []string

type BGPReconcileErrorKey 

type BGPReconcileErrorKey struct {
	Instance string
	ErrorID  int
}

func (BGPReconcileErrorKey) Key 

func (k BGPReconcileErrorKey) Key() index.Key

type DesiredRoutePolicy added in v1.20.0 

type DesiredRoutePolicy struct {
	// Instance is BGP instance name to which this policy entry belongs.
	Instance string
	// Peer is name of the BGP peer to which this policy entry applies.
	Peer string
	// PolicyType defines type of the route policy.
	PolicyType types.RoutePolicyType
	// Statement holds desired policy statement.
	Statement *types.RoutePolicyStatement

	// Priority is used to order statements with the same Instance, Peer and PolicyType combination.
	// Lower number has higher priority (will be added to the top of the rendered policy).
	Priority int
	// Owner defines ownership of this policy entry - e.g. a reconciler name.
	Owner string
	// Resource contains the key of the resource for which this policy entry was rendered,
	// used as reconciliation helper for the owners, may be empty if not needed.
	Resource resource.Key
}

DesiredRoutePolicy holds one desired BGP route policy statement with policy metadata. Each entry must have a unique Instance + Peer + PolicyType + Statement.Name combination. +deepequal-gen=true

func (*DesiredRoutePolicy) DeepEqual added in v1.20.0 

func (in *DesiredRoutePolicy) DeepEqual(other *DesiredRoutePolicy) bool

DeepEqual is an autogenerated deepequal function, deeply comparing the receiver with other. in must be non-nil.

func (*DesiredRoutePolicy) GetKey added in v1.20.0 

func (p *DesiredRoutePolicy) GetKey() DesiredRoutePolicyKey

func (*DesiredRoutePolicy) GetOwnerKey added in v1.20.0 

func (p *DesiredRoutePolicy) GetOwnerKey() desiredRoutePolicyOwnerKey

func (*DesiredRoutePolicy) GetPolicyObjectKey added in v1.20.0 

func (p *DesiredRoutePolicy) GetPolicyObjectKey() DesiredRoutePolicyObjectKey

func (*DesiredRoutePolicy) GetResourceKey added in v1.20.0 

func (p *DesiredRoutePolicy) GetResourceKey() desiredRoutePolicyResourceKey

func (*DesiredRoutePolicy) StatementName added in v1.20.0 

func (p *DesiredRoutePolicy) StatementName() string

func (*DesiredRoutePolicy) String added in v1.20.0 

func (p *DesiredRoutePolicy) String() string

func (*DesiredRoutePolicy) TableHeader added in v1.20.0 

func (*DesiredRoutePolicy) TableHeader() []string

func (*DesiredRoutePolicy) TableRow added in v1.20.0 

func (p *DesiredRoutePolicy) TableRow() []string

type DesiredRoutePolicyKey added in v1.20.0 

type DesiredRoutePolicyKey struct {
	Instance      string
	Peer          string
	PolicyType    types.RoutePolicyType
	StatementName string
}

DesiredRoutePolicyKey uniquely identifies a desired route policy statement.

func (DesiredRoutePolicyKey) Key added in v1.20.0 

func (k DesiredRoutePolicyKey) Key() index.Key

type DesiredRoutePolicyObjectKey added in v1.20.0 

type DesiredRoutePolicyObjectKey struct {
	Instance   string
	Peer       string
	PolicyType types.RoutePolicyType
}

DesiredRoutePolicyObjectKey groups policy statements with the same object key value into a single route policy object.

func (DesiredRoutePolicyObjectKey) Key added in v1.20.0 

func (k DesiredRoutePolicyObjectKey) Key() index.Key

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.