hooks

package
v0.9.0-rc4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Package hooks contains interfaces used to invoke callbacks at specific points during the plugin loading process.

Hook types:

PluginLoadHook

This hook is invoked whenever a plugin is loaded by the plugin loader.

Use the OnLoad* methods to construct a new PluginLoadHook with the type of the plugin you want to be notified for. Known plugin types can be found in pkg/plugins/types.

Load hooks will be invoked exactly once per plugin, per hook, in a separate goroutine. All load hooks for a particular event are run in parallel.

Load hooks should not block for an extended period of time. When a plugin is loaded, it will block until all hooks have completed (returned). Blocking inside a hook can cause delays in the loading process or deadlock. Hooks can be registered during other hook callbacks, but take care to avoid deadlocks.

LoadingCompletedHook

This hook is invoked after all plugins have been loaded, which occurs when all load hooks for all plugins have completed (returned).

Use the OnLoadingCompleted method to construct a new LoadingCompletedHook.

There are no restrictions related to blocking in an OnLoadingCompleted hook callback. It is valid to block indefinitely, e.g. to start a server.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LoadingCompletedHook

type LoadingCompletedHook interface {
	Invoke(numLoaded int)
}

func OnLoadingCompleted

func OnLoadingCompleted(fn func(int)) LoadingCompletedHook

type PluginLoadHook

type PluginLoadHook interface {
	ShouldInvoke(t any) bool
	Invoke(t any, md meta.PluginMeta, conn *grpc.ClientConn) (done chan struct{})
}

func OnLoad

func OnLoad[T any](fn func(T)) PluginLoadHook

Invokes the provided callback function when the plugin of type T is loaded.

func OnLoadM

func OnLoadM[T any](fn func(T, meta.PluginMeta)) PluginLoadHook

Like OnLoad[T], but adds plugin metadata to the callback.

func OnLoadMC

func OnLoadMC[T any](fn func(T, meta.PluginMeta, *grpc.ClientConn)) PluginLoadHook

Like OnLoadM[T], but adds the grpc client connection to the callback.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL