stream

Documentation

Index

• Constants
• func NewPlugin(p StreamAPIExtension) plugin.Plugin
• type Server
• type StreamAPIExtension
• type StreamClientDisconnectHandler
• type StreamClientHandler

Constants

const (
	StreamAPIExtensionPluginID = "opni.apiextensions.StreamAPIExtension"
	ServiceID                  = "apiextensions.StreamAPIExtension"
)

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

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.