sdk

Feb 28, 2021

Changes in this version

+ type ServeOpts struct

+ Logger hclog.Logger

+ Name string

+ NoLogOutputOverride bool

+ Provider plugin.CQProvider

Feb 11, 2021

Changes in this version

+ func KillProviderPluginClient(path string)

Feb 5, 2021

Changes in this version

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

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

+ func ServePlugin(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)

+ 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)