sdk

type BindingHandler func(input *BindingInput) (*BindingOutput, error)

type BindingInput struct {
	BindingContext binding_context.BindingContext
	Values         utils.Values
	ConfigValues   utils.Values
	LogLabels      map[string]string
	LogEntry       *log.Entry
	Envs           map[string]string
}

type BindingOutput struct {
	ConfigValuesPatches *utils.ValuesPatch
	MemoryValuesPatches *utils.ValuesPatch
	Metrics             []metric_operation.MetricOperation
	Error               error
}

type CommonGoHook struct {
	HookConfig   *HookConfig
	HookMetadata *HookMetadata
}

type GoHook interface {
	Metadata() HookMetadata
	Config() (config *HookConfig)
	Run(input *HookInput) (output *HookOutput, err error)
}

type Handlers struct {
	Main              func()
	Group             map[string]func()
	Kubernetes        map[string]func()
	Schedule          map[string]func()
	OnStartup         func()
	OnBeforeAll       func()
	OnAfterAll        func()
	OnBeforeHelm      func()
	OnAfterHelm       func()
	OnAfterDeleteHelm func()
}

type HookBindingContext struct {
	Type       string // type: Event Synchronization Group Schedule
	Binding    string // binding name
	Snapshots  map[string][]kem_types.ObjectAndFilterResult
	WatchEvent string // Added/Modified/Deleted
	Objects    []kem_types.ObjectAndFilterResult
	Object     kem_types.ObjectAndFilterResult
}

type HookConfig struct {
	YamlConfig string // define bindings with YAML as in shell hooks.

	Schedule          []ScheduleConfig
	Kubernetes        []KubernetesConfig
	OnStartup         *OrderedConfig
	OnBeforeHelm      *OrderedConfig
	OnAfterHelm       *OrderedConfig
	OnAfterDeleteHelm *OrderedConfig
	OnBeforeAll       *OrderedConfig
	OnAfterAll        *OrderedConfig
	MainHandler       BindingHandler
	GroupHandlers     map[string]BindingHandler
}

type HookInput struct {
	BindingContexts []binding_context.BindingContext
	Values          utils.Values
	ConfigValues    utils.Values
	LogLabels       map[string]string
	Envs            map[string]string
}

type HookLoader interface {
	Load()
}

type HookMetadata struct {
	Name       string
	Path       string
	Global     bool
	Module     bool
	ModuleName string
}

type HookOutput struct {
	ConfigValuesPatches *utils.ValuesPatch
	MemoryValuesPatches *utils.ValuesPatch
	Metrics             []metric_operation.MetricOperation
	Error               error
}

type JqFilterHelper struct {
	Name            string
	JqFilterFn      func(obj *unstructured.Unstructured) (result string, err error)
	ResultConverter func(string, interface{}) error
}

type KubernetesConfig struct {
	Name                         string
	ApiVersion                   string
	Kind                         string
	NameSelector                 *kem_types.NameSelector
	NamespaceSelector            *kem_types.NamespaceSelector
	LabelSelector                *metav1.LabelSelector
	FieldSelector                *kem_types.FieldSelector
	JqFilter                     string
	IncludeSnapshotsFrom         []string
	Queue                        string
	Group                        string
	ExecuteHookOnEvents          []kem_types.WatchEventType
	ExecuteHookOnSynchronization bool
	WaitForSynchronization       bool
	KeepFullObjectsInMemory      bool
	AllowFailure                 bool
	Handler                      BindingHandler
	FilterFunc                   func(obj *unstructured.Unstructured) (string, error)
}

type OnAfterHookBinding struct {
	Order   int
	Handler func(bc *binding_context.BindingContext) (*HookOutput, error)
}

type OrderedConfig struct {
	Order   float64
	Handler BindingHandler
}

type ScheduleConfig struct {
	Name                 string
	Crontab              string
	AllowFailure         bool
	IncludeSnapshotsFrom []string
	Queue                string
	Group                string
	Handler              BindingHandler
}