Documentation
¶
Index ¶
- type CQPlugin
- type CQProvider
- type GRPCClient
- type GRPCServer
- func (m *GRPCServer) Fetch(ctx context.Context, req *internal.FetchRequest) (*internal.FetchResponse, error)
- func (m *GRPCServer) GenConfig(ctx context.Context, req *internal.GenConfigRequest) (*internal.GenConfigResponse, error)
- func (m *GRPCServer) Init(ctx context.Context, req *internal.InitRequest) (*internal.InitResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CQPlugin ¶
type CQPlugin struct {
// GRPCPlugin must still implement the Plugin interface
plugin.Plugin
// Concrete implementation, written in Go. This is only used for plugins
// that are written in Go.
Impl CQProvider
}
CQPlugin this is the implementation of plugin.GRPCPlugin so we can serve/consume this.
func (*CQPlugin) GRPCClient ¶
func (p *CQPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
func (*CQPlugin) GRPCServer ¶
type CQProvider ¶
type GRPCClient ¶
type GRPCClient struct {
// contains filtered or unexported fields
}
func (*GRPCClient) Fetch ¶
func (m *GRPCClient) Fetch(data []byte) error
func (*GRPCClient) GenConfig ¶
func (m *GRPCClient) GenConfig() (string, error)
type GRPCServer ¶
type GRPCServer struct {
// This is the real implementation
Impl CQProvider
internal.UnimplementedProviderServer
}
Here is the gRPC server that GRPCClient talks to.
func (*GRPCServer) Fetch ¶
func (m *GRPCServer) Fetch(ctx context.Context, req *internal.FetchRequest) (*internal.FetchResponse, error)
func (*GRPCServer) GenConfig ¶
func (m *GRPCServer) GenConfig(ctx context.Context, req *internal.GenConfigRequest) (*internal.GenConfigResponse, error)
func (*GRPCServer) Init ¶
func (m *GRPCServer) Init(ctx context.Context, req *internal.InitRequest) (*internal.InitResponse, error)
Click to show internal directories.
Click to hide internal directories.