routines

Documentation

Index

• func ExportCluster(interval time.Duration, clusterName string, clusterCIDRs []string, ...) manager.Runnable
• func ExportEndpoints(interval time.Duration, getConnector types.EndpointGetter, ...) manager.Runnable
• func LoadEndpointsAndCommunities(interval time.Duration, store storepkg.Interface, ...) manager.Runnable
• func NewIPPool(clusterName, cidr string) calicoapi.IPPool
• func NewIPPoolKeeper(interval time.Duration, localClusterName string, cli client.Client, ...) manager.Runnable
• func Periodic(interval time.Duration, fn func(ctx context.Context)) manager.Runnable
• type GetEndpointsAndCommunitiesFunc
• type LocalClusterReporter
  • func (ctl *LocalClusterReporter) Start(ctx context.Context) error
• type UpdateCluster
• type UpdateEndpointsFunc

Functions

func ExportCluster

func ExportCluster(interval time.Duration, clusterName string, clusterCIDRs []string, getConnector types.EndpointGetter, updateCluster UpdateCluster) manager.Runnable

ExportCluster is used to export cluster CIDRs and endpoints to host cluster

func ExportEndpoints

func ExportEndpoints(interval time.Duration, getConnector types.EndpointGetter, updateEndpoints UpdateEndpointsFunc) manager.Runnable

func LoadEndpointsAndCommunities

func LoadEndpointsAndCommunities(interval time.Duration, store storepkg.Interface, getEndpointsAndCommunities GetEndpointsAndCommunitiesFunc) manager.Runnable

func NewIPPool

func NewIPPool(clusterName, cidr string) calicoapi.IPPool

func NewIPPoolKeeper

func NewIPPoolKeeper(interval time.Duration, localClusterName string, cli client.Client, getClusterCIDRInfo types.GetClusterCIDRInfo) manager.Runnable

func Periodic

func Periodic(interval time.Duration, fn func(ctx context.Context)) manager.Runnable

Types

type GetEndpointsAndCommunitiesFunc

type GetEndpointsAndCommunitiesFunc func() (apiserver.EndpointsAndCommunity, error)

type LocalClusterReporter

type LocalClusterReporter struct {
	Cluster      string
	ClusterCIDRs []string
	GetConnector types.EndpointGetter
	SyncInterval time.Duration
	Client       client.Client
	Log          logr.Logger
}

LocalClusterReporter create or update cluster data in the cluster where controller is running

func (*LocalClusterReporter) Start

func (ctl *LocalClusterReporter) Start(ctx context.Context) error

type UpdateCluster

type UpdateCluster func(cluster apis.Cluster) error

type UpdateEndpointsFunc

type UpdateEndpointsFunc func(endpoints []apis.Endpoint) error