Documentation ¶
Index ¶
Constants ¶
View Source
const ( StreamAPIExtensionPluginID = "opni.apiextensions.StreamAPIExtension" ServiceID = "apiextensions.StreamAPIExtension" )
Variables ¶
This section is empty.
Functions ¶
func NewPlugin ¶
func NewPlugin(p StreamAPIExtension) plugin.Plugin
Types ¶
type Server ¶
type Server struct { Desc *grpc.ServiceDesc Impl interface{} RequireCapability string }
type StreamAPIExtension ¶
type StreamAPIExtension interface {
StreamServers() []Server
}
type StreamClientDisconnectHandler ¶ added in v0.6.1
type StreamClientDisconnectHandler interface {
StreamDisconnected()
}
A plugin can optionally implement StreamClientDisconnectHandler to be notified when the stream disconnects
type StreamClientHandler ¶
type StreamClientHandler interface {
UseStreamClient(client grpc.ClientConnInterface)
}
A plugin can optionally implement StreamClientHandler to obtain a grpc.ClientConnInterface to the plugin's side of the spliced stream.
Click to show internal directories.
Click to hide internal directories.