v1beta1

package
v1.2.2-dev-20240329 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromClusterFlowHandlerToHandler 

func FromClusterFlowHandlerToHandler(sync ClusterFlowHandler) generic.Handler

func FromClusterOutputHandlerToHandler 

func FromClusterOutputHandlerToHandler(sync ClusterOutputHandler) generic.Handler

func FromLoggingHandlerToHandler 

func FromLoggingHandlerToHandler(sync LoggingHandler) generic.Handler

func RegisterClusterFlowGeneratingHandler 

func RegisterClusterFlowGeneratingHandler(ctx context.Context, controller ClusterFlowController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterFlowGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterClusterFlowGeneratingHandler configures a ClusterFlowController to execute a ClusterFlowGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterFlowStatusHandler 

func RegisterClusterFlowStatusHandler(ctx context.Context, controller ClusterFlowController, condition condition.Cond, name string, handler ClusterFlowStatusHandler)

RegisterClusterFlowStatusHandler configures a ClusterFlowController to execute a ClusterFlowStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterOutputGeneratingHandler 

func RegisterClusterOutputGeneratingHandler(ctx context.Context, controller ClusterOutputController, apply apply.Apply,
	condition condition.Cond, name string, handler ClusterOutputGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterClusterOutputGeneratingHandler configures a ClusterOutputController to execute a ClusterOutputGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterClusterOutputStatusHandler 

func RegisterClusterOutputStatusHandler(ctx context.Context, controller ClusterOutputController, condition condition.Cond, name string, handler ClusterOutputStatusHandler)

RegisterClusterOutputStatusHandler configures a ClusterOutputController to execute a ClusterOutputStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterLoggingGeneratingHandler 

func RegisterLoggingGeneratingHandler(ctx context.Context, controller LoggingController, apply apply.Apply,
	condition condition.Cond, name string, handler LoggingGeneratingHandler, opts *generic.GeneratingHandlerOptions)

RegisterLoggingGeneratingHandler configures a LoggingController to execute a LoggingGeneratingHandler for every events observed, passing the returned objects to the provided apply.Apply. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func RegisterLoggingStatusHandler 

func RegisterLoggingStatusHandler(ctx context.Context, controller LoggingController, condition condition.Cond, name string, handler LoggingStatusHandler)

RegisterLoggingStatusHandler configures a LoggingController to execute a LoggingStatusHandler for every events observed. If a non-empty condition is provided, it will be updated in the status conditions for every handler execution

func UpdateClusterFlowDeepCopyOnChange 

func UpdateClusterFlowDeepCopyOnChange(client ClusterFlowClient, obj *v1beta1.ClusterFlow, handler func(obj *v1beta1.ClusterFlow) (*v1beta1.ClusterFlow, error)) (*v1beta1.ClusterFlow, error)

func UpdateClusterOutputDeepCopyOnChange 

func UpdateClusterOutputDeepCopyOnChange(client ClusterOutputClient, obj *v1beta1.ClusterOutput, handler func(obj *v1beta1.ClusterOutput) (*v1beta1.ClusterOutput, error)) (*v1beta1.ClusterOutput, error)

func UpdateLoggingDeepCopyOnChange 

func UpdateLoggingDeepCopyOnChange(client LoggingClient, obj *v1beta1.Logging, handler func(obj *v1beta1.Logging) (*v1beta1.Logging, error)) (*v1beta1.Logging, error)

Types

type ClusterFlowCache 

type ClusterFlowCache interface {
	Get(namespace, name string) (*v1beta1.ClusterFlow, error)
	List(namespace string, selector labels.Selector) ([]*v1beta1.ClusterFlow, error)

	AddIndexer(indexName string, indexer ClusterFlowIndexer)
	GetByIndex(indexName, key string) ([]*v1beta1.ClusterFlow, error)
}

type ClusterFlowClient 

type ClusterFlowClient interface {
	Create(*v1beta1.ClusterFlow) (*v1beta1.ClusterFlow, error)
	Update(*v1beta1.ClusterFlow) (*v1beta1.ClusterFlow, error)
	UpdateStatus(*v1beta1.ClusterFlow) (*v1beta1.ClusterFlow, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1beta1.ClusterFlow, error)
	List(namespace string, opts metav1.ListOptions) (*v1beta1.ClusterFlowList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.ClusterFlow, err error)
}

type ClusterFlowController 

type ClusterFlowController interface {
	generic.ControllerMeta
	ClusterFlowClient

	OnChange(ctx context.Context, name string, sync ClusterFlowHandler)
	OnRemove(ctx context.Context, name string, sync ClusterFlowHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ClusterFlowCache
}

func NewClusterFlowController 

func NewClusterFlowController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterFlowController

type ClusterFlowGeneratingHandler 

type ClusterFlowGeneratingHandler func(obj *v1beta1.ClusterFlow, status v1beta1.FlowStatus) ([]runtime.Object, v1beta1.FlowStatus, error)

ClusterFlowGeneratingHandler is the top-level handler that is executed for every ClusterFlow event. It extends ClusterFlowStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type ClusterFlowHandler 

type ClusterFlowHandler func(string, *v1beta1.ClusterFlow) (*v1beta1.ClusterFlow, error)

type ClusterFlowIndexer 

type ClusterFlowIndexer func(obj *v1beta1.ClusterFlow) ([]string, error)

type ClusterFlowStatusHandler 

type ClusterFlowStatusHandler func(obj *v1beta1.ClusterFlow, status v1beta1.FlowStatus) (v1beta1.FlowStatus, error)

ClusterFlowStatusHandler is executed for every added or modified ClusterFlow. Should return the new status to be updated

type ClusterOutputCache 

type ClusterOutputCache interface {
	Get(namespace, name string) (*v1beta1.ClusterOutput, error)
	List(namespace string, selector labels.Selector) ([]*v1beta1.ClusterOutput, error)

	AddIndexer(indexName string, indexer ClusterOutputIndexer)
	GetByIndex(indexName, key string) ([]*v1beta1.ClusterOutput, error)
}

type ClusterOutputClient 

type ClusterOutputClient interface {
	Create(*v1beta1.ClusterOutput) (*v1beta1.ClusterOutput, error)
	Update(*v1beta1.ClusterOutput) (*v1beta1.ClusterOutput, error)
	UpdateStatus(*v1beta1.ClusterOutput) (*v1beta1.ClusterOutput, error)
	Delete(namespace, name string, options *metav1.DeleteOptions) error
	Get(namespace, name string, options metav1.GetOptions) (*v1beta1.ClusterOutput, error)
	List(namespace string, opts metav1.ListOptions) (*v1beta1.ClusterOutputList, error)
	Watch(namespace string, opts metav1.ListOptions) (watch.Interface, error)
	Patch(namespace, name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.ClusterOutput, err error)
}

type ClusterOutputController 

type ClusterOutputController interface {
	generic.ControllerMeta
	ClusterOutputClient

	OnChange(ctx context.Context, name string, sync ClusterOutputHandler)
	OnRemove(ctx context.Context, name string, sync ClusterOutputHandler)
	Enqueue(namespace, name string)
	EnqueueAfter(namespace, name string, duration time.Duration)

	Cache() ClusterOutputCache
}

func NewClusterOutputController 

func NewClusterOutputController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) ClusterOutputController

type ClusterOutputGeneratingHandler 

type ClusterOutputGeneratingHandler func(obj *v1beta1.ClusterOutput, status v1beta1.OutputStatus) ([]runtime.Object, v1beta1.OutputStatus, error)

ClusterOutputGeneratingHandler is the top-level handler that is executed for every ClusterOutput event. It extends ClusterOutputStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type ClusterOutputHandler 

type ClusterOutputHandler func(string, *v1beta1.ClusterOutput) (*v1beta1.ClusterOutput, error)

type ClusterOutputIndexer 

type ClusterOutputIndexer func(obj *v1beta1.ClusterOutput) ([]string, error)

type ClusterOutputStatusHandler 

type ClusterOutputStatusHandler func(obj *v1beta1.ClusterOutput, status v1beta1.OutputStatus) (v1beta1.OutputStatus, error)

ClusterOutputStatusHandler is executed for every added or modified ClusterOutput. Should return the new status to be updated

type Interface 

type Interface interface {
	ClusterFlow() ClusterFlowController
	ClusterOutput() ClusterOutputController
	Logging() LoggingController
}

func New 

func New(controllerFactory controller.SharedControllerFactory) Interface

type LoggingCache 

type LoggingCache interface {
	Get(name string) (*v1beta1.Logging, error)
	List(selector labels.Selector) ([]*v1beta1.Logging, error)

	AddIndexer(indexName string, indexer LoggingIndexer)
	GetByIndex(indexName, key string) ([]*v1beta1.Logging, error)
}

type LoggingClient 

type LoggingClient interface {
	Create(*v1beta1.Logging) (*v1beta1.Logging, error)
	Update(*v1beta1.Logging) (*v1beta1.Logging, error)
	UpdateStatus(*v1beta1.Logging) (*v1beta1.Logging, error)
	Delete(name string, options *metav1.DeleteOptions) error
	Get(name string, options metav1.GetOptions) (*v1beta1.Logging, error)
	List(opts metav1.ListOptions) (*v1beta1.LoggingList, error)
	Watch(opts metav1.ListOptions) (watch.Interface, error)
	Patch(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1beta1.Logging, err error)
}

type LoggingController 

type LoggingController interface {
	generic.ControllerMeta
	LoggingClient

	OnChange(ctx context.Context, name string, sync LoggingHandler)
	OnRemove(ctx context.Context, name string, sync LoggingHandler)
	Enqueue(name string)
	EnqueueAfter(name string, duration time.Duration)

	Cache() LoggingCache
}

func NewLoggingController 

func NewLoggingController(gvk schema.GroupVersionKind, resource string, namespaced bool, controller controller.SharedControllerFactory) LoggingController

type LoggingGeneratingHandler 

type LoggingGeneratingHandler func(obj *v1beta1.Logging, status v1beta1.LoggingStatus) ([]runtime.Object, v1beta1.LoggingStatus, error)

LoggingGeneratingHandler is the top-level handler that is executed for every Logging event. It extends LoggingStatusHandler by a returning a slice of child objects to be passed to apply.Apply

type LoggingHandler 

type LoggingHandler func(string, *v1beta1.Logging) (*v1beta1.Logging, error)

type LoggingIndexer 

type LoggingIndexer func(obj *v1beta1.Logging) ([]string, error)

type LoggingStatusHandler 

type LoggingStatusHandler func(obj *v1beta1.Logging, status v1beta1.LoggingStatus) (v1beta1.LoggingStatus, error)

LoggingStatusHandler is executed for every added or modified Logging. Should return the new status to be updated

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.