Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

goplugin

package module

Go to main page

Versions in this module

v1

v1.0.0

Nov 30, 2020

Changes in this version

+ func BuildProtocol(opt *ProtocolOption) caller.Builder

+ type GoPlugin struct

+ func New(hostName string, opts ...Option) *GoPlugin

+ func (g *GoPlugin) Build() (*host.Builder, error)

+ func (g *GoPlugin) GetPluginConf(pluginName string) (*PluginConf, error)

+ func (g *GoPlugin) GetProcessInstance() *process.Instance

+ func (g *GoPlugin) SetupPlugin(plugins ...PluginMapper) *GoPlugin

+ type HostPlugins struct

+ Host string

+ Plugins host.Plugins

+ type InstallationOptions struct

+ RetryTimeoutCaller int

+ type Option func(*GoPlugin)

+ func WithCustomConfigChecker(adapters ...discover.Checker) Option

+ func WithCustomConfigParser(parserAdapter discover.Parser, sourceAdapter discover.SourceReader) Option

+ func WithCustomIdentityChecker(adapter host.IdentityChecker) Option

+ func WithCustomProcess(runner process.Runner, processes process.ProcessesBuilder) Option

+ type PluginConf struct

+ Protocol *ProtocolOption

+ type PluginMapper map[string]*PluginConf

+ func Map(pluginName string, conf *PluginConf) PluginMapper

+ type PluginSupervisor struct

+ func Supervisor(pluggable *Registry, options ...PluginSupervisorOption) *PluginSupervisor

+ func (s *PluginSupervisor) AutoRestart(payload *supervisor.Payload)

+ func (s *PluginSupervisor) Handle()

+ func (s *PluginSupervisor) OnError(event *supervisor.Payload, handlers ...supervisor.OnErrorHandler)

+ func (s *PluginSupervisor) Setup(handlers ...supervisor.OnErrorHandler) error

+ func (s *PluginSupervisor) Shutdown()

+ func (s *PluginSupervisor) Start() *PluginSupervisor

+ func (s *PluginSupervisor) Watch() <-chan *supervisor.Payload

+ type PluginSupervisorOption func(*PluginSupervisor)

+ func SupervisorOptionCustomDriver(drv supervisor.Driver) PluginSupervisorOption

+ func SupervisorOptionInterval(interval int) PluginSupervisorOption

+ type ProtocolOption struct

+ GRPCOpts *driver.GrpcOptions

+ RESTOpts *driver.RESTOptions

+ type Registry struct

+ func Register(hostPlugins ...*GoPlugin) *Registry

+ func (r *Registry) GetAllPlugins() ([]*HostPlugins, error)

+ func (r *Registry) GetCaller(host, plugin string) (*caller.Plugin, error)

+ func (r *Registry) GetContainer(host string) (*executor.Container, error)

+ func (r *Registry) GetHostPluginInstance(host string) (*GoPlugin, error)

+ func (r *Registry) GetPID(hostName, pluginName string) (process.ID, error)

+ func (r *Registry) Install(options *InstallationOptions) (*Registry, error)

+ func (r *Registry) KillPlugins()

v1.0.0-alpha.3

Oct 9, 2020

v1.0.0-alpha.2

Sep 21, 2020

v1.0.0-alpha.1

Sep 19, 2020

v1.0.0-alpha.0

Sep 17, 2020