task

Apr 21, 2023

Changes in this version

+ const AnnotationEdgeTaskNameNamespace

+ const AnnotationEdgeTaskResourcesHash

+ const DefaultEdgeResourceQueueSize

+ const IndexFieldEdgeClusterStatusPhase

+ const IndexFieldEdgeTaskSpecEdgeClusterName

+ const IndexFieldEdgeTaskStatusPhase

+ func CheckStatus(ctx context.Context, status *edgev1beta1.EdgeTaskResourceStatus, ...)

+ func EdgeClusterTrigger(ctx context.Context, cli client.Client) handler.EventHandler

+ func EdgeTaskResourceEventsFromEvents(events []corev1.Event) []edgev1beta1.EdgeTaskResourceEvent

+ func ExtractEdgeTask(obj client.Object) (name string, namespace string)

+ func FindOwnerControllerRecursively(ctx context.Context, cli client.Client, obj client.Object) (client.Object, error)

+ func GetEdgeTaskCondition(status *edgev1beta1.EdgeTaskStatus, ...) (int, *edgev1beta1.EdgeTaskCondition)

+ func HashResources(obj any) string

+ func InjectEdgeTask(obj client.Object, edgetask *edgev1beta1.EdgeTask)

+ func ParseResources(resources []runtime.RawExtension) ([]*unstructured.Unstructured, error)

+ func ParseResourcesTyped(resources []runtime.RawExtension, schema *runtime.Scheme) ([]client.Object, error)

+ func RemoveEdgeTaskCondition(status *edgev1beta1.EdgeTaskStatus, ...)

+ func Run(ctx context.Context, options *Options) error

+ func UpdateEdgeTaskCondition(task *edgev1beta1.EdgeTask, condition edgev1beta1.EdgeTaskCondition)

+ type EdgeClientsHolder struct

+ func NewEdgeClientsHolder(ctx context.Context, server string) (*EdgeClientsHolder, error)

+ func (c *EdgeClientsHolder) Get(uid string) (client.Client, error)

+ func (c *EdgeClientsHolder) Invalid(uid string)

+ func (c *EdgeClientsHolder) SourceFunc(ctx context.Context, cli client.Client) source.Func

+ type EdgeClusterEvent struct

+ TaskName string

+ TaskNamespace string

+ UID string

+ type EdgeClusterResourceChangedCallback func(uid string, obj client.Object)

+ type Options struct

+ EdgeNamespace string

+ EdgeServerAddr string

+ HealthProbeBindAddress string

+ MaxConcurrentReconciles int

+ MetricsBindAddress string

+ func NewDefaultOptions() *Options

+ type Reconciler struct

+ EdgeClients *EdgeClientsHolder

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

+ func (r *Reconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options *Options) error