Documentation
¶
Index ¶
- func IsInvalidConfig(err error) bool
- func IsWrongTypeError(err error) bool
- type Config
- type Resource
- func (r *Resource) ApplyCreateChange(ctx context.Context, obj, createChange interface{}) error
- func (r *Resource) ApplyDeleteChange(ctx context.Context, obj, deleteChange interface{}) error
- func (r *Resource) ApplyUpdateChange(ctx context.Context, obj, updateChange interface{}) error
- func (r *Resource) GetCurrentState(ctx context.Context, obj interface{}) (interface{}, error)
- func (r *Resource) GetDesiredState(ctx context.Context, obj interface{}) (interface{}, error)
- func (r *Resource) Name() string
- func (r *Resource) NewDeletePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*controller.Patch, error)
- func (r *Resource) NewUpdatePatch(ctx context.Context, obj, currentState, desiredState interface{}) (*controller.Patch, error)
- type StateGetter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsInvalidConfig ¶
IsInvalidConfig asserts invalidConfigError.
func IsWrongTypeError ¶
IsWrongTypeError asserts wrongTypeError.
Types ¶
type Config ¶
type Config struct {
G8sClient versioned.Interface
Logger micrologger.Logger
StateGetter StateGetter
Name string
}
type Resource ¶
type Resource struct {
// contains filtered or unexported fields
}
func (*Resource) ApplyCreateChange ¶
ApplyCreateChange ensures the App CR is created in the k8s api.
func (*Resource) ApplyDeleteChange ¶
func (*Resource) ApplyUpdateChange ¶
func (*Resource) GetCurrentState ¶
func (*Resource) GetDesiredState ¶
func (*Resource) NewDeletePatch ¶
func (*Resource) NewUpdatePatch ¶
type StateGetter ¶
type StateGetter interface {
// GetCurrentState returns a current state of the system for the given
// incarnation of the observed Kubernetes object. The state consists of
// multiple objects but it is fine to return a slice of single object
// if only one object is managed by this resource.
GetCurrentState(ctx context.Context, obj interface{}) ([]*v1alpha1.App, error)
// GetDesiredState returns a desired state of the system for the given
// incarnation of the observed Kubernetes object. The state consists of
// multiple objects but it is fine to return a slice of single object
// if only one object is managed by this resource.
//
// NOTE: This state may be different if the observed object is
// created/updated or deleted. Deletion timestamp can be checked to
// figure if the object is scheduled for deletion.
GetDesiredState(ctx context.Context, obj interface{}) ([]*v1alpha1.App, error)
}
Click to show internal directories.
Click to hide internal directories.