Documentation
¶
Index ¶
- Constants
- func DefaultGRPCServer(opts []grpc.ServerOption) *grpc.Server
- func DefaultPluginSet(servers CapabilityServers) plugin.PluginSet
- func HandshakeConfig() plugin.HandshakeConfig
- func Serve(cfg ServeConfig)
- type CapabilityServers
- type Client
- func (c *Client) AuthProvider() pluginv1.AuthProviderClient
- func (c *Client) Conn() *grpc.ClientConn
- func (c *Client) EventConsumer() pluginv1.EventConsumerClient
- func (c *Client) HttpRoutes() pluginv1.HttpRoutesClient
- func (c *Client) MediaAnalyzer() pluginv1.MediaAnalyzerClient
- func (c *Client) MetadataProvider() pluginv1.MetadataProviderClient
- func (c *Client) Runtime() pluginv1.RuntimeClient
- func (c *Client) ScheduledTask() pluginv1.ScheduledTaskClient
- type GRPCPlugin
- type ServeConfig
Constants ¶
View Source
const ( ProtocolVersion = 1 MagicCookieKey = "CONTINUUM_PLUGIN" MagicCookieValue = "continuum-rpc-plugin-v1" PluginSetName = "continuum" )
Variables ¶
This section is empty.
Functions ¶
func DefaultGRPCServer ¶
func DefaultGRPCServer(opts []grpc.ServerOption) *grpc.Server
func DefaultPluginSet ¶
func DefaultPluginSet(servers CapabilityServers) plugin.PluginSet
func HandshakeConfig ¶
func HandshakeConfig() plugin.HandshakeConfig
func Serve ¶
func Serve(cfg ServeConfig)
Types ¶
type CapabilityServers ¶
type CapabilityServers struct {
Runtime pluginv1.RuntimeServer
MetadataProvider pluginv1.MetadataProviderServer
MediaAnalyzer pluginv1.MediaAnalyzerServer
ScheduledTask pluginv1.ScheduledTaskServer
EventConsumer pluginv1.EventConsumerServer
AuthProvider pluginv1.AuthProviderServer
HttpRoutes pluginv1.HttpRoutesServer
}
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(conn *grpc.ClientConn) *Client
func (*Client) AuthProvider ¶
func (c *Client) AuthProvider() pluginv1.AuthProviderClient
func (*Client) Conn ¶
func (c *Client) Conn() *grpc.ClientConn
func (*Client) EventConsumer ¶
func (c *Client) EventConsumer() pluginv1.EventConsumerClient
func (*Client) HttpRoutes ¶
func (c *Client) HttpRoutes() pluginv1.HttpRoutesClient
func (*Client) MediaAnalyzer ¶
func (c *Client) MediaAnalyzer() pluginv1.MediaAnalyzerClient
func (*Client) MetadataProvider ¶
func (c *Client) MetadataProvider() pluginv1.MetadataProviderClient
func (*Client) Runtime ¶
func (c *Client) Runtime() pluginv1.RuntimeClient
func (*Client) ScheduledTask ¶
func (c *Client) ScheduledTask() pluginv1.ScheduledTaskClient
type GRPCPlugin ¶
type GRPCPlugin struct {
plugin.Plugin
Servers CapabilityServers
}
func (*GRPCPlugin) GRPCClient ¶
func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, conn *grpc.ClientConn) (interface{}, error)
func (*GRPCPlugin) GRPCServer ¶
func (p *GRPCPlugin) GRPCServer(_ *plugin.GRPCBroker, server *grpc.Server) error
type ServeConfig ¶
type ServeConfig struct {
Plugins plugin.PluginSet
Logger hclog.Logger
Servers CapabilityServers
}
Source Files
Click to show internal directories.
Click to hide internal directories.