runtime

type CLIPlugin struct {
	plugin.Plugin
	CLIMethods map[string]string
}

type Contract struct {
	sync.Mutex
	Consumer sync.Mutex
	Contract string
	// contains filtered or unexported fields
}

type ContractQueue[T any] struct {
	queue.Queue[T]
	Contract Contract
}

type PluginAPI struct {
	Plugin  string
	Runtime *Runtime
}

type PluginProvider struct {
	Plugins map[string]plugin.Plugin

	MessagePlugins  map[string]plugin.Plugin
	DiscoverPlugins map[string]plugin.Plugin
	ResolvePlugins  map[string]plugin.Plugin
	NotifyPlugins   map[string]plugin.Plugin
	CLIPlugins      map[string]CLIPlugin
}

type Runtime struct {
	PluginDirectory     string
	HTTPPort, HTTPSPort string
	PathPrefix          string
	TLSCert, TLSKey     string

	Log, ProcLog, ErrorLog *log.Logger

	MessageSecrets map[string]bool
	CLISecrets     map[string]bool
	WorkerSecrets  map[string]bool
	WorkerGroups   map[string]bool

	MessageQueue queue.Queue[schema.FullMessage]
	StatusQueue  queue.Queue[schema.PipelineStatus]
	TriggerQueue queue.Queue[schema.Trigger]
	NotifyQueue  queue.Queue[schema.PipelineStatus]

	MessageQueues map[string]queue.Queue[schema.FullMessage]
	WorkerQueues  map[string]*ContractQueue[activity.PipelineActivity]
	Activity      map[string]*activity.RuntimeActivity

	QueueTimeout time.Duration

	PluginProvider PluginProvider

	Status chan []string
}