pluginmgr

type ISyncable interface {
	Name() string
	Description() string
	Enabled() bool
	Checksum() string
}

type Notify = func(messaging.Message)

type Plugin interface {
	Start(ctx context.Context) error
}

type PluginAdapter[T ISyncable] interface {
	// This is the go-plugin dispense key, e.g. "rule", "enrichment".
	PluginKey() string
	// This is the HandshakeConfig cookie value, e.g. "rule_v1".
	MagicValue() string
	// GRPCPlugin returns the go-plugin.Plugin that constructs the gRPC client stub.
	GRPCPlugin() plugin.Plugin
	// Handshake type-asserts the dispensed raw interface, calls Init (and optionally GetMetadata),
	// and returns the wrapped public T, a PluginLifecycle, the plugin stable ID, the display name, and any error.
	Handshake(ctx context.Context, raw interface{}, binPath string, hash string) (T, PluginLifecycle, string, string, error)
	// IsEnabled reports whether a running handle should continue running.
	IsEnabled(handle *PluginHandle) bool
	// Returns how many subprocess instances to spawn for this binary.
	// Return 1 (or ≤ 0) for the default single-worker behaviour.
	Workers(binPath string) int
}

type PluginHandle struct {
	Client    *plugin.Client
	Lifecycle PluginLifecycle
	BinPath   string
	ID        string // stable plugin identifier (e.g. UUID); used for bus messages and pool ops
	Name      string // human-readable display name; used for logging
	Hash      string // SHA-256 of the binary at launch time
	// contains filtered or unexported fields
}

type PluginLifecycle interface {
	Ping(ctx context.Context) error
	Shutdown(ctx context.Context) error
}

type PluginManager[T ISyncable] struct {
	// contains filtered or unexported fields
}

type PluginManagerMetrics struct {
	Starts             prometheus.Counter
	Crashes            prometheus.Counter
	Restarts           prometheus.Counter
	Updates            prometheus.Counter
	StartLatency       prometheus.Histogram
	ActiveSubprocesses *prometheus.GaugeVec
}

type RegisterMessage[T ISyncable] struct {
	messaging.IsMessage
	Items    []T
	MaxProcs int
}

type RemoveMessage[T ISyncable] struct {
	messaging.IsMessage
	ItemID string
}

type UnregisterMessage[T ISyncable] struct {
	messaging.IsMessage
	ItemID string
}

type UpdateMessage[T ISyncable] struct {
	messaging.IsMessage
	Items     []T
	MaxProcs  int
	OnDrained func()
}