subroutine

package
v0.5.11 Latest Latest
Warning

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

 Go to latest Published: Jun 22, 2026 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetScopedClient added in v0.3.0 

func GetScopedClient(cfg *rest.Config, scheme *runtime.Scheme, clusterPath string) (client.Client, error)

GetScopedClient creates a client scoped to a specific logical cluster path (e.g. "root:orgs")

func NewAPIBindingWatcherSubroutine 

func NewAPIBindingWatcherSubroutine(mgr mcmanager.Manager, orgsClient client.Client, localCfg *rest.Config, indexPrefix string) (*apiBindingWatcherSubroutine, error)

NewAPIBindingWatcherSubroutine creates a new APIBinding watcher subroutine. orgsClient must be scoped to the root:orgs workspace. localCfg must be the admin KCP REST config.

Types

type IndexLifecycleSubroutine 

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

IndexLifecycleSubroutine manages the lifecycle of OpenSearch indices

func NewIndexLifecycleSubroutine 

func NewIndexLifecycleSubroutine(
	mgr mcmanager.Manager,
	osClient *opensearch.Client,
	staticIndexPrefix string,
	semanticModelID string,
) *IndexLifecycleSubroutine

NewIndexLifecycleSubroutine creates a new index lifecycle subroutine

func (*IndexLifecycleSubroutine) Finalize 

func (s *IndexLifecycleSubroutine) Finalize(ctx context.Context, instance runtimeobject.RuntimeObject) (ctrl.Result, errors.OperatorError)

Finalize handles cleanup when the resource is being deleted

func (*IndexLifecycleSubroutine) Finalizers 

func (s *IndexLifecycleSubroutine) Finalizers(instance runtimeobject.RuntimeObject) []string

Finalizers returns the finalizers this subroutine manages

func (*IndexLifecycleSubroutine) GetName 

func (s *IndexLifecycleSubroutine) GetName() string

GetName returns the subroutine name

func (*IndexLifecycleSubroutine) Process 

func (s *IndexLifecycleSubroutine) Process(ctx context.Context, instance runtimeobject.RuntimeObject) (result ctrl.Result, opErr errors.OperatorError)

Process handles the reconciliation logic

type IndexableResourceWatcherSubroutine 

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

IndexableResourceWatcherSubroutine watches IndexableResource resources across workspaces

func NewIndexableResourceWatcherSubroutine 

func NewIndexableResourceWatcherSubroutine(mgr mcmanager.Manager, allClient client.Client, orgsClient client.Client, osClient *opensearch.Client, apiExportName string, indexPrefix string, localCfg *rest.Config) (*IndexableResourceWatcherSubroutine, error)

NewIndexableResourceWatcherSubroutine creates a new IndexableResource watcher subroutine. localCfg must be the admin KCP REST config

func (*IndexableResourceWatcherSubroutine) Finalize 

func (s *IndexableResourceWatcherSubroutine) Finalize(ctx context.Context, instance runtimeobject.RuntimeObject) (ctrl.Result, errors.OperatorError)

func (*IndexableResourceWatcherSubroutine) Finalizers 

func (s *IndexableResourceWatcherSubroutine) Finalizers(_ runtimeobject.RuntimeObject) []string

Finalizers return the finalizers this subroutine manages

func (*IndexableResourceWatcherSubroutine) GetName 

func (s *IndexableResourceWatcherSubroutine) GetName() string

func (*IndexableResourceWatcherSubroutine) Process 

func (s *IndexableResourceWatcherSubroutine) Process(ctx context.Context, instance runtimeobject.RuntimeObject) (result ctrl.Result, opErr errors.OperatorError)

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.