watch_and_update

Documentation

Index

• Constants
• Variables
• type GVK
• type MessageSender
  • func NewGRPCMessageSender(ctx context.Context, cc *grpc.ClientConn, ev *env.Env, logger logging.Logger) (MessageSender, error)
• type MessageSenderContext
• type Reconciler
  • func (r *Reconciler) AddWatcherFinalizer(ctx context.Context, obj client.Object) (ctrl.Result, error)
  • func (r *Reconciler) GetName() string
  • func (r *Reconciler) Reconcile(ctx context.Context, oReq ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) RemoveWatcherFinalizer(ctx context.Context, obj client.Object) (ctrl.Result, error)
  • func (r *Reconciler) SendResourceEvents(ctx context.Context, obj *unstructured.Unstructured, logger logging.Logger) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, logger logging.Logger) error

Constants

const (
	DispatchToKloudliteInfra string = "kloudlite.io/dispatch-to-infra"
)

Variables

var (
	ProjectGVK     = newGVK("crds.kloudlite.io/v1", "Project")
	AppGVK         = newGVK("crds.kloudlite.io/v1", "App")
	ExternalAppGVK = newGVK("crds.kloudlite.io/v1", "ExternalApp")

	ManagedResourceGVK = newGVK("crds.kloudlite.io/v1", "ManagedResource")
	EnvironmentGVK     = newGVK("crds.kloudlite.io/v1", "Environment")
	RouterGVK          = newGVK("crds.kloudlite.io/v1", "Router")

	GatewayGVK        = newGVK("networking.kloudlite.io/v1", "Gateway")
	ServiceBindingGVK = newGVK("networking.kloudlite.io/v1", "ServiceBinding")

	ClusterManagedServiceGVK = newGVK("crds.kloudlite.io/v1", "ClusterManagedService")
	HelmChartGVK             = newGVK("crds.kloudlite.io/v1", "HelmChart")
	ProjectManageServiceGVK  = newGVK("crds.kloudlite.io/v1", "ProjectManagedService")

	// native resources
	PersistentVolumeClaimGVK = newGVK("v1", "PersistentVolumeClaim")
	PersistentVolumeGVK      = newGVK("v1", "PersistentVolume")
	VolumeAttachmentGVK      = newGVK("storage.k8s.io/v1", "VolumeAttachment")
	IngressGVK               = newGVK("networking.k8s.io/v1", "Ingress")

	SecretGVK    = newGVK("v1", "Secret")
	ConfigmapGVK = newGVK("v1", "ConfigMap")
	NamespaceGVK = newGVK("v1", "Namespace")
)

var ErrNoMsgSender error = fmt.Errorf("msg sender is nil")

Types

type GVK

type GVK struct {
	schema.GroupVersionKind
}

type MessageSender

type MessageSender interface {
	DispatchConsoleResourceUpdates(ctx MessageSenderContext, stu t.ResourceUpdate) error
	DispatchInfraResourceUpdates(ctx MessageSenderContext, stu t.ResourceUpdate) error
	DispatchContainerRegistryResourceUpdates(ctx MessageSenderContext, stu t.ResourceUpdate) error
	DispatchIotConsoleResourceUpdates(ctx MessageSenderContext, stu t.ResourceUpdate) error
}

func NewGRPCMessageSender

func NewGRPCMessageSender(ctx context.Context, cc *grpc.ClientConn, ev *env.Env, logger logging.Logger) (MessageSender, error)

type MessageSenderContext

type MessageSenderContext struct {
	context.Context
	// contains filtered or unexported fields
}

type Reconciler

type Reconciler struct {
	client.Client
	Scheme *runtime.Scheme

	Name string
	Env  *env.Env

	MsgSender MessageSender
	// contains filtered or unexported fields
}

Reconciler reconciles a StatusWatcher object

func (*Reconciler) AddWatcherFinalizer

func (r *Reconciler) AddWatcherFinalizer(ctx context.Context, obj client.Object) (ctrl.Result, error)

func (*Reconciler) GetName

func (r *Reconciler) GetName() string

func (*Reconciler) Reconcile

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

+kubebuilder:rbac:groups=watcher.kloudlite.io,resources=statuswatchers,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=watcher.kloudlite.io,resources=statuswatchers/status,verbs=get;update;patch +kubebuilder:rbac:groups=watcher.kloudlite.io,resources=statuswatchers/finalizers,verbs=update

func (*Reconciler) RemoveWatcherFinalizer

func (r *Reconciler) RemoveWatcherFinalizer(ctx context.Context, obj client.Object) (ctrl.Result, error)

func (*Reconciler) SendResourceEvents

func (r *Reconciler) SendResourceEvents(ctx context.Context, obj *unstructured.Unstructured, logger logging.Logger) (ctrl.Result, error)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, logger logging.Logger) error

SetupWithManager sets up the controllers with the Manager.