v1

Documentation

Index

• func FromExecutionHandlerToHandler(sync ExecutionHandler) generic.Handler
• func FromModuleHandlerToHandler(sync ModuleHandler) generic.Handler
• func FromStateHandlerToHandler(sync StateHandler) generic.Handler
• type ExecutionCache
• type ExecutionClient
• type ExecutionController
  • func NewExecutionController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) ExecutionController
• type ExecutionHandler
  • func UpdateExecutionOnChange(updater generic.Updater, handler ExecutionHandler) ExecutionHandler
• type ExecutionIndexer
• type Interface
  • func New(controllerManager *generic.ControllerManager, ...) Interface
• type ModuleCache
• type ModuleClient
• type ModuleController
  • func NewModuleController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) ModuleController
• type ModuleHandler
  • func UpdateModuleOnChange(updater generic.Updater, handler ModuleHandler) ModuleHandler
• type ModuleIndexer
• type StateCache
• type StateClient
• type StateController
  • func NewStateController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, ...) StateController
• type StateHandler
  • func UpdateStateOnChange(updater generic.Updater, handler StateHandler) StateHandler
• type StateIndexer

Functions

func FromExecutionHandlerToHandler

func FromExecutionHandlerToHandler(sync ExecutionHandler) generic.Handler

func FromModuleHandlerToHandler

func FromModuleHandlerToHandler(sync ModuleHandler) generic.Handler

func FromStateHandlerToHandler

func FromStateHandlerToHandler(sync StateHandler) generic.Handler

Types

type ExecutionCache

type ExecutionCache interface {
	Get(namespace, name string) (*v1.Execution, error)
	List(namespace string, selector labels.Selector) ([]*v1.Execution, error)

	AddIndexer(indexName string, indexer ExecutionIndexer)
	GetByIndex(indexName, key string) ([]*v1.Execution, error)
}

type ExecutionClient

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

type ExecutionController

type ExecutionController interface {
	ExecutionClient

	OnChange(ctx context.Context, name string, sync ExecutionHandler)
	OnRemove(ctx context.Context, name string, sync ExecutionHandler)
	Enqueue(namespace, name string)

	Cache() ExecutionCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewExecutionController

func NewExecutionController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ExecutionsGetter, informer informers.ExecutionInformer) ExecutionController

type ExecutionHandler

type ExecutionHandler func(string, *v1.Execution) (*v1.Execution, error)

func UpdateExecutionOnChange

func UpdateExecutionOnChange(updater generic.Updater, handler ExecutionHandler) ExecutionHandler

type ExecutionIndexer

type ExecutionIndexer func(obj *v1.Execution) ([]string, error)

type Interface

type Interface interface {
	Execution() ExecutionController
	Module() ModuleController
	State() StateController
}

func New

func New(controllerManager *generic.ControllerManager, client clientset.TerraformcontrollerV1Interface,
	informers informers.Interface) Interface

type ModuleCache

type ModuleCache interface {
	Get(namespace, name string) (*v1.Module, error)
	List(namespace string, selector labels.Selector) ([]*v1.Module, error)

	AddIndexer(indexName string, indexer ModuleIndexer)
	GetByIndex(indexName, key string) ([]*v1.Module, error)
}

type ModuleClient

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

type ModuleController

type ModuleController interface {
	ModuleClient

	OnChange(ctx context.Context, name string, sync ModuleHandler)
	OnRemove(ctx context.Context, name string, sync ModuleHandler)
	Enqueue(namespace, name string)

	Cache() ModuleCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewModuleController

func NewModuleController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.ModulesGetter, informer informers.ModuleInformer) ModuleController

type ModuleHandler

type ModuleHandler func(string, *v1.Module) (*v1.Module, error)

func UpdateModuleOnChange

func UpdateModuleOnChange(updater generic.Updater, handler ModuleHandler) ModuleHandler

type ModuleIndexer

type ModuleIndexer func(obj *v1.Module) ([]string, error)

type StateCache

type StateCache interface {
	Get(namespace, name string) (*v1.State, error)
	List(namespace string, selector labels.Selector) ([]*v1.State, error)

	AddIndexer(indexName string, indexer StateIndexer)
	GetByIndex(indexName, key string) ([]*v1.State, error)
}

type StateClient

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

type StateController

type StateController interface {
	StateClient

	OnChange(ctx context.Context, name string, sync StateHandler)
	OnRemove(ctx context.Context, name string, sync StateHandler)
	Enqueue(namespace, name string)

	Cache() StateCache

	Informer() cache.SharedIndexInformer
	GroupVersionKind() schema.GroupVersionKind

	AddGenericHandler(ctx context.Context, name string, handler generic.Handler)
	AddGenericRemoveHandler(ctx context.Context, name string, handler generic.Handler)
	Updater() generic.Updater
}

func NewStateController

func NewStateController(gvk schema.GroupVersionKind, controllerManager *generic.ControllerManager, clientGetter clientset.StatesGetter, informer informers.StateInformer) StateController

type StateHandler

type StateHandler func(string, *v1.State) (*v1.State, error)

func UpdateStateOnChange

func UpdateStateOnChange(updater generic.Updater, handler StateHandler) StateHandler

type StateIndexer

type StateIndexer func(obj *v1.State) ([]string, error)