plugin

type CapsuleWatcher interface {
	// Watch a primary resource, by providing a capsule name and
	// the type of the object to watch for.
	// All objects which type matches `objType` and that belongs to the capsule
	// will be processed.
	WatchPrimary(ctx context.Context, objType client.Object, cb WatchCallback) error
}

type GRPCServer struct {
	apiplugin.UnimplementedPluginServiceServer

	Impl Plugin
	// contains filtered or unexported fields
}

type Info struct {
	Name       string
	Image      string
	IsBuiltin  bool
	BinaryPath string
	Args       []string
}

type InitializeRequest struct {
	Config []byte
	Tag    string
	// contains filtered or unexported fields
}

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

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

type ManagerOption func(m *Manager)

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

type NoWatchObjectStatus struct{}

type ObjectWatcher interface {
	Reschedule(deadline time.Time)
	WatchSecondaryByName(objectName string, objType client.Object, cb WatchCallback)
	WatchSecondaryByLabels(objectLabels labels.Set, objType client.Object, cb WatchCallback)
}

type ParseStep[T any] func(config T, req pipeline.CapsuleRequest) (string, any, error)

type Plugin interface {
	// Run is executed once per reconciliation and throug the CapsuleRequest, has read access
	// to the Capsule being reconciled and read/write access to all other derived resources
	Run(ctx context.Context, req pipeline.CapsuleRequest, logger hclog.Logger) error
	// Initialize is executed once when the rig-operator starts up and is used to pass the configuration
	// of the plugin from the operator to the plugin itself.
	Initialize(req InitializeRequest) error
	WatchObjectStatus(ctx context.Context, watcher CapsuleWatcher) error
}

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

type ThirdPartyConfig struct {
	Plugins []ThirdPartyPlugin `json:"plugins"`
}

type ThirdPartyPlugin struct {
	Name string `json:"name"`
}

type WatchCallback func(
	obj client.Object,
	events []*corev1.Event,
	objectWatcher ObjectWatcher,
) *apipipeline.ObjectStatusInfo

type Watcher interface {
	NewCapsuleWatcher(
		ctx context.Context,
		namespace string,
		capsule string,
		c chan<- *apiplugin.ObjectStatusChange) CapsuleWatcher
}