Versions in this module Expand all Collapse all v1 v1.13.1 Mar 11, 2020 Changes in this version + var ErrNotFound = errors.New("plugin not found") + var ErrNotImplements = errors.New("Plugin does not implement the requested driver") + func Handle(iface string, fn func(string, *Client)) + func IsNotFound(err error) bool + func Scan() ([]string, error) + type Client struct + func NewClient(addr string, tlsConfig *tlsconfig.Options) (*Client, error) + func NewClientWithTimeout(addr string, tlsConfig *tlsconfig.Options, timeoutInSecs int) (*Client, error) + func (c *Client) Call(serviceMethod string, args interface{}, ret interface{}) error + func (c *Client) SendFile(serviceMethod string, data io.Reader, ret interface{}) error + func (c *Client) Stream(serviceMethod string, args interface{}) (io.ReadCloser, error) + type Manifest struct + Implements []string + type Plugin struct + Addr string + Manifest *Manifest + TLSConfig *tlsconfig.Options + func Get(name, imp string) (*Plugin, error) + func GetAll(imp string) ([]*Plugin, error) + func NewLocalPlugin(name, addr string) *Plugin + func (p *Plugin) BasePath() string + func (p *Plugin) Client() *Client + func (p *Plugin) IsV1() bool + func (p *Plugin) Name() string