Documentation ¶
Index ¶
Constants ¶
View Source
const SHARED_SETTING_PREFIX = "REEVE_SHARED_"
View Source
const TIMEOUT_ACTIVITY = 2 * time.Minute
View Source
const TIMEOUT_QUEUE = 1 * time.Minute
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Contract ¶
type Contract struct { sync.Mutex Consumer sync.Mutex Contract string // contains filtered or unexported fields }
func (*Contract) IsCanceled ¶
type PluginProvider ¶
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 }
func (*PluginProvider) Close ¶
func (p *PluginProvider) Close()
type Runtime ¶
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 }
func GetRuntime ¶
func GetRuntime() *Runtime
func (*Runtime) LoadPlugins ¶
func (*Runtime) LogQueueStatus ¶
func (runtime *Runtime) LogQueueStatus()
Click to show internal directories.
Click to hide internal directories.