Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoPluginInCatalog = errors.New("no plugin in catalog")
View Source
var (
ErrPluginCheckFailed = errors.New("plugin health check failed")
)
Functions ¶
This section is empty.
Types ¶
type Option ¶ added in v0.5.0
type Option func(catalog.BuiltInPluginRegistry)
func WithBuiltInPlugins ¶ added in v0.5.0
func WithBuiltInPlugins(plugins []catalog.BuiltInPlugin) Option
type PluginWatcher ¶ added in v0.9.0
type PluginWatcher struct {
// contains filtered or unexported fields
}
func NewPluginWatcher ¶ added in v0.9.0
func NewPluginWatcher(catalog pluginLister, interval time.Duration) *PluginWatcher
func (*PluginWatcher) Start ¶ added in v0.9.0
func (w *PluginWatcher) Start(ctx context.Context)
type Registry ¶
type Registry struct {
serviceapi.Registry
*plugincatalog.Catalog
}
func (*Registry) WatchPlugins ¶ added in v0.9.0
WatchPlugins starts the plugin health watcher as a background goroutine. On detecting a dead plugin it sends SIGTERM to trigger graceful shutdown.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.