Versions in this module Expand all Collapse all v0 v0.99.0 Jun 20, 2020 Changes in this version + const ProtocolSchemeHTTPV1 + 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) + func WithRequestTimeout(t time.Duration) func(*RequestOpts) + type Client struct + func NewClient(addr string, tlsConfig *tlsconfig.Options) (*Client, error) + func NewClientWithTimeout(addr string, tlsConfig *tlsconfig.Options, timeout time.Duration) (*Client, error) + func (c *Client) Call(serviceMethod string, args, ret interface{}) error + func (c *Client) CallWithOptions(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) Client() *Client + func (p *Plugin) IsV1() bool + func (p *Plugin) Name() string + func (p *Plugin) Protocol() string + func (p *Plugin) ScopedPath(s string) string + type RequestOpts struct + Timeout time.Duration
Go to main page