controllers

package
v0.0.0-...-2275388 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServiceConditionTypeAdvertising string = "Advertising"
	ServiceConditionTypeAdvertised  string = "Advertised"
	ServiceConditionTypeNotReady    string = "NotReady"

	ServiceConditionReasonAdvertising string = "Advertising allocated LB addresses"
	ServiceConditionReasonAdvertised  string = "Advertised allocated LB addresses"
	ServiceConditionReasonNotReady    string = "No Ready Endpoints"

	AdvertisementTypeService string = "service"
)

Variables

View Source 
var (
	ErrPoolAnnotationIsNotFound   error = errors.New("Pool name annotation is not found")
	ErrFromPoolAnnotationIsNotSet error = errors.New("Pool name allocated from is not set")
	ErrAllocatorIsNotFound        error = errors.New("Allocator is not found")
)
View Source 
var (
	ErrPeerIsNotEstablished error = fmt.Errorf("Peer is not established")
)

Functions

func PeerFromBGPPeer 

func PeerFromBGPPeer(p *sartv1alpha1.BGPPeer) sartv1alpha1.Peer

Types

type AddressPoolReconciler 

type AddressPoolReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

AddressPoolReconciler reconciles a AddressPool object

func (*AddressPoolReconciler) Reconcile 

func (r *AddressPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the AddressPool object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*AddressPoolReconciler) SetupWithManager 

func (r *AddressPoolReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type AddressRequestReconciler 

type AddressRequestReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

AddressRequestReconciler reconciles a AddressRequest object

func (*AddressRequestReconciler) Reconcile 

func (r *AddressRequestReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the AddressRequest object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*AddressRequestReconciler) SetupWithManager 

func (r *AddressRequestReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type BGPAdvertisementReconciler 

type BGPAdvertisementReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	SpeakerEndpointPort uint32
	SpeakerType         speaker.SpeakerType
	// contains filtered or unexported fields
}

BGPAdvertisementReconciler reconciles a BGPAdvertisement object

func NewBGPAdvertisementReconciler 

func NewBGPAdvertisementReconciler(client client.Client, scheme *runtime.Scheme, endpoint uint32, speakerType speaker.SpeakerType) *BGPAdvertisementReconciler

func (*BGPAdvertisementReconciler) Reconcile 

func (r *BGPAdvertisementReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*BGPAdvertisementReconciler) SetupWithManager 

func (r *BGPAdvertisementReconciler) SetupWithManager(mgr ctrl.Manager) error

type BGPPeerReconciler 

type BGPPeerReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	SpeakerEndpointPort uint32
	SpeakerType         speaker.SpeakerType
}

BGPPeerReconciler reconciles a BGPPeer object

func (*BGPPeerReconciler) Reconcile 

func (r *BGPPeerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the BGPPeer object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*BGPPeerReconciler) SetupWithManager 

func (r *BGPPeerReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ClusterBGPReconciler 

type ClusterBGPReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ClusterBGPReconciler reconciles a ClusterBGP object

func (*ClusterBGPReconciler) Reconcile 

func (r *ClusterBGPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ClusterBGP object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*ClusterBGPReconciler) SetupWithManager 

func (r *ClusterBGPReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type LBAllocationReconciler 

type LBAllocationReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	Allocators map[string]map[string]allocator.Allocator
	// contains filtered or unexported fields
}

func NewLBAllocationReconciler 

func NewLBAllocationReconciler(client client.Client, scheme *runtime.Scheme, allocators map[string]map[string]allocator.Allocator) *LBAllocationReconciler

func (*LBAllocationReconciler) Reconcile 

func (r *LBAllocationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LBAllocationReconciler) SetupWithManager 

func (r *LBAllocationReconciler) SetupWithManager(mgr ctrl.Manager) error

type NodeBGPReconciler 

type NodeBGPReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	SpeakerEndpointPort uint32
	SpeakerType         speaker.SpeakerType
}

NodeBGPReconciler reconciles a NodeBGP object

func (*NodeBGPReconciler) Reconcile 

func (r *NodeBGPReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the NodeBGP object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*NodeBGPReconciler) SetupWithManager 

func (r *NodeBGPReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type NodeWatcher 

type NodeWatcher struct {
	client.Client
	Scheme              *runtime.Scheme
	SpeakerEndpointPort uint32
	SpeakerType         speaker.SpeakerType
}

func (*NodeWatcher) Reconcile 

func (n *NodeWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NodeWatcher) SetupWithManager 

func (n *NodeWatcher) SetupWithManager(mgr ctrl.Manager) error

type PeerStateWatcher 

type PeerStateWatcher struct {
	client.Client
	SpeakerEndpoint uint32
	SpeakerType     speaker.SpeakerType
	// contains filtered or unexported fields
}

func NewPeerStateWatcher 

func NewPeerStateWatcher(c client.Client, endpoint uint32, speakerType speaker.SpeakerType, interval uint32) *PeerStateWatcher

func (*PeerStateWatcher) Reconcile 

func (r *PeerStateWatcher) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PeerStateWatcher) SetupWithManager 

func (r *PeerStateWatcher) SetupWithManager(mgr ctrl.Manager) error

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.