v1beta1

Documentation

Index

• func FromClusterFlowHandlerToHandler(sync ClusterFlowHandler) generic.Handler
• func FromClusterOutputHandlerToHandler(sync ClusterOutputHandler) generic.Handler
• func FromLoggingHandlerToHandler(sync LoggingHandler) generic.Handler
• func RegisterClusterFlowGeneratingHandler(ctx context.Context, controller ClusterFlowController, apply apply.Apply, ...)
• func RegisterClusterFlowStatusHandler(ctx context.Context, controller ClusterFlowController, ...)
• func RegisterClusterOutputGeneratingHandler(ctx context.Context, controller ClusterOutputController, apply apply.Apply, ...)
• func RegisterClusterOutputStatusHandler(ctx context.Context, controller ClusterOutputController, ...)
• func RegisterLoggingGeneratingHandler(ctx context.Context, controller LoggingController, apply apply.Apply, ...)
• func RegisterLoggingStatusHandler(ctx context.Context, controller LoggingController, condition condition.Cond, ...)
• func UpdateClusterFlowDeepCopyOnChange(client ClusterFlowClient, obj *v1beta1.ClusterFlow, ...) (*v1beta1.ClusterFlow, error)
• func UpdateClusterOutputDeepCopyOnChange(client ClusterOutputClient, obj *v1beta1.ClusterOutput, ...) (*v1beta1.ClusterOutput, error)
• func UpdateLoggingDeepCopyOnChange(client LoggingClient, obj *v1beta1.Logging, ...) (*v1beta1.Logging, error)
• type ClusterFlowCache
• type ClusterFlowClient
• type ClusterFlowController
  • func NewClusterFlowController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterFlowController
• type ClusterFlowGeneratingHandler
• type ClusterFlowHandler
• type ClusterFlowIndexer
• type ClusterFlowStatusHandler
• type ClusterOutputCache
• type ClusterOutputClient
• type ClusterOutputController
  • func NewClusterOutputController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) ClusterOutputController
• type ClusterOutputGeneratingHandler
• type ClusterOutputHandler
• type ClusterOutputIndexer
• type ClusterOutputStatusHandler
• type Interface
  • func New(controllerFactory controller.SharedControllerFactory) Interface
• type LoggingCache
• type LoggingClient
• type LoggingController
  • func NewLoggingController(gvk schema.GroupVersionKind, resource string, namespaced bool, ...) LoggingController
• type LoggingGeneratingHandler
• type LoggingHandler
• type LoggingIndexer
• type LoggingStatusHandler

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)