subroutine

package

v0.1.1 Latest Latest Go to latest Published: Apr 9, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/platform-mesh/search-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func NewAPIBindingWatcherSubroutine(mgr mcmanager.Manager, allClient client.Client, apiExportName string) *apiBindingWatcherSubroutine
type IndexLifecycleSubroutine
- func NewIndexLifecycleSubroutine(mgr mcmanager.Manager, osClient *opensearch.Client, staticIndexPrefix string) *IndexLifecycleSubroutine
type IndexableResourceWatcherSubroutine
- func NewIndexableResourceWatcherSubroutine(mgr mcmanager.Manager, allClient client.Client, orgsClient client.Client, ...) (*IndexableResourceWatcherSubroutine, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewAPIBindingWatcherSubroutine ¶

func NewAPIBindingWatcherSubroutine(mgr mcmanager.Manager, allClient client.Client, apiExportName string) *apiBindingWatcherSubroutine

NewAPIBindingWatcherSubroutine creates a new APIBinding watcher subroutine

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) *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) (ctrl.Result, 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, 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) (ctrl.Result, errors.OperatorError)

Source Files ¶

View all Source files

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