hook

type FileSystemHookDiscovery struct{}

type Hook struct {
	Name   string // The unique name like '002-prometheus-hooks/startup_hook'.
	Path   string // The absolute path to the executable file.
	Config *config.HookConfig

	HookController *controller.HookController
	RateLimiter    *rate.Limiter

	TmpDir                 string
	KeepTemporaryHookFiles bool

	LogProxyHookJSON    bool
	LogProxyHookJSONKey string

	Logger *log.Logger
	// contains filtered or unexported fields
}

type HookDiscovery interface {
	// Discover returns a sorted list of absolute paths to hook executables.
	Discover(workingDir string) ([]string, error)
}

type HookEnv struct {
	ContextPath         string
	MetricsPath         string
	AdmissionPath       string
	ConversionPath      string
	KubernetesPatchPath string
}

type HookManager interface {
	Init() error
	GetHook(name string) *Hook
	GetHookNames() []string
	GetHooksInOrder(bindingType htypes.BindingType) ([]string, error)
	CreateTasksFromKubeEvent(kubeEvent kemtypes.KubeEvent, createTaskFn func(*Hook, controller.BindingExecutionInfo) task.Task) []task.Task
	HandleCreateTasksFromScheduleEvent(crontab string, createTaskFn func(*Hook, controller.BindingExecutionInfo) task.Task) []task.Task
	HandleAdmissionEvent(ctx context.Context, event admission.Event, createTaskFn func(*Hook, controller.BindingExecutionInfo))
	DetectAdmissionEventType(event admission.Event) htypes.BindingType
	HandleConversionEvent(ctx context.Context, crdName string, request *v1.ConversionRequest, rule conversion.Rule, createTaskFn func(*Hook, controller.BindingExecutionInfo))
	FindConversionChain(crdName string, rule conversion.Rule) []conversion.Rule
}

type IOProvider interface {
	Prepare(versionedCtx bctx.BindingContextList) (*HookEnv, error)
	Cleanup(env *HookEnv)
}

type Manager struct {
	// contains filtered or unexported fields
}

type ManagerConfig struct {
	WorkingDir               string
	TempDir                  string
	KubeEventsManager        kubeeventsmanager.KubeEventsManager
	ScheduleManager          schedulemanager.ScheduleManager
	AdmissionWebhookManager  *admission.WebhookManager
	ConversionWebhookManager *conversion.WebhookManager

	// HookDiscovery overrides the default filesystem-based hook discovery.
	// When nil, FileSystemHookDiscovery is used.
	HookDiscovery HookDiscovery

	KeepTemporaryHookFiles bool
	LogProxyHookJSON       bool
	LogProxyHookJSONKey    string

	Logger *log.Logger
}

type MetricOperation struct {
	Name string `json:"name"`
	// Deprecated: use Value + Action="add" instead. Add only works for parsing from file
	Add *float64 `json:"add,omitempty"` // shortcut for action=add value=num
	// Deprecated: use Value + Action="set" instead. Set only works for parsing from file
	Set     *float64          `json:"set,omitempty"` // shortcut for action=set value=num
	Value   *float64          `json:"value,omitempty"`
	Buckets []float64         `json:"buckets,omitempty"`
	Labels  map[string]string `json:"labels"`
	Group   string            `json:"group,omitempty"`
	Action  string            `json:"action,omitempty"`
}

type ResponseParser interface {
	ParseResult(hookName string, env *HookEnv, result *Result) error
}

type Result struct {
	Usage                *executor.CmdUsage
	Metrics              []operation.MetricOperation
	ConversionResponse   *conversion.Response
	AdmissionResponse    *admission.Response
	KubernetesPatchBytes []byte
}