resources

Documentation

Index

• func WrapFuncs(monitor mntr.Monitor, query QueryFunc, destroy DestroyFunc) (QueryFunc, DestroyFunc, error)
• type AdaptFuncToDelete
• type AdaptFuncToEnsure
• type DestroyFunc
  • func ReduceDestroyers(monitor mntr.Monitor, destroyers []Destroyer) DestroyFunc
  • func (d DestroyFunc) Destroy(k8sClient kubernetes.ClientInt) error
• type Destroyer
• type EnsureFunc
  • func QueriersToEnsurer(monitor mntr.Monitor, infoLogs bool, queriers []Querier, ...) (EnsureFunc, error)
  • func (e EnsureFunc) Ensure(k8sClient kubernetes.ClientInt) error
• type Ensurer
• type Querier
• type QueriersReducerFunc
• type QueryFunc
  • func DestroyerToQuerier(destroyer Destroyer) QueryFunc
  • func DestroyersToQueryFuncs(destroyers []Destroyer) []QueryFunc
  • func (q QueryFunc) Query(k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)
• type TestableDestroyer
  • func ToTestableDestroy(destroyFunc DestroyFunc, adapterArguments interface{}) *TestableDestroyer
• type TestableQuerier
  • func ToTestableQuerier(queryFunc QueryFunc, adapterArguments interface{}) *TestableQuerier

Functions

func WrapFuncs

func WrapFuncs(monitor mntr.Monitor, query QueryFunc, destroy DestroyFunc) (QueryFunc, DestroyFunc, error)

Types

type AdaptFuncToDelete

type AdaptFuncToDelete func(monitor mntr.Monitor, desired *tree.Tree, current *tree.Tree) (DestroyFunc, error)

type AdaptFuncToEnsure

type AdaptFuncToEnsure func(monitor mntr.Monitor, desired *tree.Tree, current *tree.Tree) (QueryFunc, error)

type DestroyFunc

type DestroyFunc func(k8sClient kubernetes.ClientInt) error

func ReduceDestroyers

func ReduceDestroyers(monitor mntr.Monitor, destroyers []Destroyer) DestroyFunc

func (DestroyFunc) Destroy

func (d DestroyFunc) Destroy(k8sClient kubernetes.ClientInt) error

type Destroyer

type Destroyer interface {
	Destroy(k8sClient kubernetes.ClientInt) error
}

type EnsureFunc

type EnsureFunc func(k8sClient kubernetes.ClientInt) error

func QueriersToEnsurer

func QueriersToEnsurer(monitor mntr.Monitor, infoLogs bool, queriers []Querier, k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)

func (EnsureFunc) Ensure

func (e EnsureFunc) Ensure(k8sClient kubernetes.ClientInt) error

type Ensurer

type Ensurer interface {
	Ensure(k8sClient kubernetes.ClientInt) error
}

type Querier

type Querier interface {
	Query(k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)
}

type QueriersReducerFunc

type QueriersReducerFunc func(monitor mntr.Monitor, infoLogs bool, queriers []Querier, k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)

type QueryFunc

type QueryFunc func(k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)

func DestroyerToQuerier

func DestroyerToQuerier(destroyer Destroyer) QueryFunc

func DestroyersToQueryFuncs

func DestroyersToQueryFuncs(destroyers []Destroyer) []QueryFunc

func (QueryFunc) Query

func (q QueryFunc) Query(k8sClient kubernetes.ClientInt, queried map[string]interface{}) (EnsureFunc, error)

type TestableDestroyer

type TestableDestroyer struct {
	DestroyFunc
	Arguments interface{}
}

func ToTestableDestroy

func ToTestableDestroy(destroyFunc DestroyFunc, adapterArguments interface{}) *TestableDestroyer

type TestableQuerier

type TestableQuerier struct {
	QueryFunc
	Arguments interface{}
}

func ToTestableQuerier

func ToTestableQuerier(queryFunc QueryFunc, adapterArguments interface{}) *TestableQuerier