task

package

v1.24.5 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubegems/kubegems

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
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
- 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
type EdgeClusterResourceChangedCallback
type Options
- func NewDefaultOptions() *Options
type Reconciler
- 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

Constants ¶

View Source

const (
	AnnotationEdgeTaskResourcesHash = "edge.kubegems.io/resources-hash"
	AnnotationEdgeTaskNameNamespace = "edge.kubegems.io/edge-task"
)

View Source

const (
	IndexFieldEdgeTaskStatusPhase         = "status.phase"
	IndexFieldEdgeTaskSpecEdgeClusterName = "spec.edgeClusterName"
	IndexFieldEdgeClusterStatusPhase      = "status.phase"
)

View Source

const DefaultEdgeResourceQueueSize = 1024

Variables ¶

This section is empty.

Functions ¶

func CheckStatus ¶

func CheckStatus(ctx context.Context, status *edgev1beta1.EdgeTaskResourceStatus, edgeresource client.Object, edgecli client.Client)

func EdgeClusterTrigger ¶

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

func EdgeTaskResourceEventsFromEvents ¶

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

func ExtractEdgeTask ¶

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

func FindOwnerControllerRecursively ¶

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

func GetEdgeTaskCondition ¶

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

func HashResources ¶

func HashResources(obj any) string

func InjectEdgeTask ¶

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

func ParseResources ¶

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

func ParseResourcesTyped ¶

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

func RemoveEdgeTaskCondition ¶

func RemoveEdgeTaskCondition(status *edgev1beta1.EdgeTaskStatus, conditionType edgev1beta1.EdgeTaskConditionType)

func Run ¶

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

func UpdateEdgeTaskCondition ¶

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

Types ¶

type EdgeClientsHolder ¶

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

func NewEdgeClientsHolder ¶

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

func (*EdgeClientsHolder) Get ¶

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

func (*EdgeClientsHolder) Invalid ¶

func (c *EdgeClientsHolder) Invalid(uid string)

func (*EdgeClientsHolder) SourceFunc ¶

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

Start behaves like controller-runtime's source.Source interface

type EdgeClusterEvent ¶

type EdgeClusterEvent struct {
	UID           string
	TaskName      string
	TaskNamespace string
}

type EdgeClusterResourceChangedCallback ¶

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

type Options ¶

type Options struct {
	MaxConcurrentReconciles int    `json:"maxConcurrentReconciles,omitempty"`
	HealthProbeBindAddress  string `json:"healthProbeBindAddress,omitempty"`
	MetricsBindAddress      string `json:"metricsBindAddress,omitempty"`
	EdgeServerAddr          string `json:"edgeServerAddr,omitempty"`
	EdgeNamespace           string `json:"edgeNamespace,omitempty"`
}

func NewDefaultOptions ¶

func NewDefaultOptions() *Options

type Reconciler ¶

type Reconciler struct {
	client.Client
	EdgeClients *EdgeClientsHolder
}

func (*Reconciler) Reconcile ¶

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

func (*Reconciler) SetupWithManager ¶

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

nolint: forcetypeassert

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL