bgpv2

Documentation

Index

• Constants
• Variables
• func IsOwner(owners []meta_v1.OwnerReference, expected string) bool
• func TrimError(err error, maxLen int) error
• type BGPParams
• type BGPResourceManager
  • func (b *BGPResourceManager) Run(ctx context.Context) (err error)
• type Config
  • func (cfg Config) Flags(flags *pflag.FlagSet)

Constants

const (
	// BGPv2Enabled is the name of the flag that enables BGPv2 APIs in Cilium.
	BGPv2Enabled = "bgp-v2-api-enabled"
)

Variables

var Cell = cell.Module(
	"bgp-cp-operator",
	"BGP Control Plane Operator",
	cell.Config(Config{}),
	cell.Invoke(registerBGPResourceManager),
)

Functions

func IsOwner

func IsOwner(owners []meta_v1.OwnerReference, expected string) bool

IsOwner checks if the expected is present in owners list.

func TrimError

func TrimError(err error, maxLen int) error

TrimError trims error message to maxLen.

Types

type BGPParams

type BGPParams struct {
	cell.In

	Logger       logrus.FieldLogger
	LC           cell.Lifecycle
	Clientset    k8s_client.Clientset
	DaemonConfig *option.DaemonConfig
	JobRegistry  job.Registry
	Scope        cell.Scope
	Config       Config

	// resource tracking
	ClusterConfigResource      resource.Resource[*cilium_api_v2alpha1.CiliumBGPClusterConfig]
	NodeConfigOverrideResource resource.Resource[*cilium_api_v2alpha1.CiliumBGPNodeConfigOverride]
	NodeConfigResource         resource.Resource[*cilium_api_v2alpha1.CiliumBGPNodeConfig]
	NodeResource               resource.Resource[*cilium_api_v2.CiliumNode]
}

type BGPResourceManager

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

func (*BGPResourceManager) Run

func (b *BGPResourceManager) Run(ctx context.Context) (err error)

Run starts the BGPResourceManager operator.

type Config

type Config struct {
	BGPv2Enabled bool `mapstructure:"bgp-v2-api-enabled"`
}

func (Config) Flags

func (cfg Config) Flags(flags *pflag.FlagSet)

Flags implements cell.Flagger interface.