plugin

Apr 14, 2021

Changes in this version

type Manager

+ func NewManager() (*Manager, error)

+ type Plugin interface

+ Close func()

+ Name func() string

+ Provider func() proto.CQProvider

+ Version func() string

Feb 28, 2021

Changes in this version

+ func GetProviderPath(name string, version string) (string, error)

+ type Manager struct

+ func GetManager() *Manager

+ func (p *Manager) AddEmbeddedPlugin(providerName string, cqp CQProvider)

+ func (p *Manager) GetOrCreateProvider(providerName, version string) (CQProvider, error)

+ func (p *Manager) GetProvider(providerName, version string) (CQProvider, error)

+ func (p *Manager) KillProvider(providerName string) error

+ func (p *Manager) Shutdown()

Feb 13, 2021

Changes in this version

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ func KillProviderPluginClient(path string)

+ func NewLogger(verbose bool, options ...zap.Option) (*zap.Logger, error)

+ func RegisterRunSelfProvider(provider CQProvider)

+ type CQPlugin struct

+ Impl CQProvider

+ func (p *CQPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *CQPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

+ type CQProvider interface

+ Fetch func(data []byte) error

+ GenConfig func() (string, error)

+ Init func(driver string, dsn string, verbose bool) error

+ func GetProviderPluginClient(path string) (CQProvider, error)

+ func GetRunSelfProvider() CQProvider

+ type GRPCClient struct

+ func (m *GRPCClient) Fetch(data []byte) error

+ func (m *GRPCClient) GenConfig() (string, error)

+ func (m *GRPCClient) Init(driver string, dsn string, verbose bool) error

+ type GRPCServer struct

+ Impl CQProvider

+ func (m *GRPCServer) Fetch(ctx context.Context, req *proto.FetchRequest) (*proto.FetchResponse, error)

+ func (m *GRPCServer) GenConfig(ctx context.Context, req *proto.GenConfigRequest) (*proto.GenConfigResponse, error)

+ func (m *GRPCServer) Init(ctx context.Context, req *proto.InitRequest) (*proto.InitResponse, error)