Documentation ¶
Index ¶
- func CancelWait(p metadata.Plugin)
- func LazyConnect(finder func() (metadata.Plugin, error), retry time.Duration) metadata.Plugin
- func NewPluginFromChannel(writes <-chan func(map[string]interface{})) metadata.Plugin
- func NewPluginFromData(data map[string]interface{}) metadata.Plugin
- func NewUpdatablePlugin(reader metadata.Plugin, commit CommitFunc) metadata.Updatable
- func UpdatableLazyConnect(finder func() (metadata.Updatable, error), retry time.Duration) metadata.Updatable
- type CommitFunc
- type LoadFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CancelWait ¶
CancelWait stops the plugin from waiting / retrying to connect
func LazyConnect ¶
LazyConnect returns a metadata.Plugin that defers connection to actual method invocation and can optionally block until the connection is made.
func NewPluginFromChannel ¶
NewPluginFromChannel returns a plugin implementation where reads and writes are serialized via channel of functions that have a view to the metadata. Closing the write channel stops the serialized read/writes and falls back to unserialized reads.
func NewPluginFromData ¶
NewPluginFromData creates a plugin out of a simple data map. Note the updates to the map is not guarded and synchronized with the reads.
func NewUpdatablePlugin ¶
func NewUpdatablePlugin(reader metadata.Plugin, commit CommitFunc) metadata.Updatable
NewUpdatablePlugin assembles the implementations into a Updatable implementation
Types ¶
type CommitFunc ¶
CommitFunc is the function for handling commit