Documentation ¶
Index ¶
- Variables
- type BaseTransformer
- type ITransformer
- type ManifestInfo
- type NewTransformerFunc
- type Status
- type TransformerInfo
- type Transformers
- func (t Transformers) CalculateCredits(transformers []BaseTransformer) int
- func (t Transformers) Execute(transformers []BaseTransformer, params map[string]interface{}) (result map[string]interface{}, err error)
- func (t Transformers) Get(gvk gvk.GroupVersionKind) (TransformerInfo, error)
- func (t Transformers) Register(gvk gvk.GroupVersionKind, transformer NewTransformerFunc) error
- func (t Transformers) UpdateParams(params *map[string]interface{}, toUpdate map[string]interface{}) error
Constants ¶
This section is empty.
Variables ¶
View Source
var DEFAULT_DEADLINE = 5 * time.Second
View Source
var ErrTransformerTimeout = fmt.Errorf("Transformer exceeded deadline")
Functions ¶
This section is empty.
Types ¶
type BaseTransformer ¶
type BaseTransformer struct { gvk.GroupVersionKind Spec interface{} `json:"spec"` Status []Status `json:"status"` }
type ITransformer ¶
type ITransformer interface { //Prepare() error //Transform(base interface{}) error WithSpec(spec interface{}, params map[string]interface{}) (ITransformer, error) Execute(ctx context.Context, base map[string]interface{}) (map[string]interface{}, error) Result() interface{} Status() []Status Params() map[string]interface{} CreditsConsumed() int Deadline() time.Duration }
type ManifestInfo ¶
type NewTransformerFunc ¶
type NewTransformerFunc = func(spec interface{}, params map[string]interface{}) (ITransformer, error)
type TransformerInfo ¶
type TransformerInfo struct { New NewTransformerFunc Credits int Deadline time.Duration }
type Transformers ¶
type Transformers struct {
// contains filtered or unexported fields
}
func NewTransformerManager ¶
func NewTransformerManager() (*Transformers, error)
func (Transformers) CalculateCredits ¶
func (t Transformers) CalculateCredits(transformers []BaseTransformer) int
func (Transformers) Execute ¶
func (t Transformers) Execute(transformers []BaseTransformer, params map[string]interface{}) (result map[string]interface{}, err error)
func (Transformers) Get ¶
func (t Transformers) Get(gvk gvk.GroupVersionKind) (TransformerInfo, error)
func (Transformers) Register ¶
func (t Transformers) Register(gvk gvk.GroupVersionKind, transformer NewTransformerFunc) error
func (Transformers) UpdateParams ¶
func (t Transformers) UpdateParams(params *map[string]interface{}, toUpdate map[string]interface{}) error
Click to show internal directories.
Click to hide internal directories.