v1beta1

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 20 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)

func RegisterClusterFlowStatusHandler 

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

func RegisterClusterOutputGeneratingHandler 

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

func RegisterClusterOutputStatusHandler 

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

func RegisterLoggingGeneratingHandler 

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

func RegisterLoggingStatusHandler 

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

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)

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)

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)

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)

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)

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)

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.