Documentation
¶
Index ¶
- Constants
- func GetPlugins(pluginType string) map[string]Plugin
- func IncludePlugins(ps ...Plugin)
- func LoadPlugins()
- func PathByName(name string) string
- func RegisterPluginTypes(ts ...Type)
- func ServePlugins(plugins ...Plugin) error
- func UnloadPlugins()
- type CancelCopier
- type Copier
- type DemuxCopier
- type MuxCopier
- type Plugin
- type PluginError
- type StdioClient
- type StdioServer
- type StreamConfig
- type Type
Constants ¶
View Source
const ( ProtocolVersion = 1 MagicCookieKey = "DODO_PLUGIN" MagicCookieValue = "69318785-d741-4150-ac91-8f03fa703530" ErrPluginInvalid PluginError = "invalid plugin" ErrPluginNotImplemented PluginError = "not implemented" ErrPluginNotFound PluginError = "plugin not found" ErrNoValidPluginFound PluginError = "no valid plugin found" )
Variables ¶
This section is empty.
Functions ¶
func GetPlugins ¶
func IncludePlugins ¶
func IncludePlugins(ps ...Plugin)
func LoadPlugins ¶
func LoadPlugins()
func PathByName ¶
func RegisterPluginTypes ¶
func RegisterPluginTypes(ts ...Type)
func ServePlugins ¶
func UnloadPlugins ¶
func UnloadPlugins()
Types ¶
type CancelCopier ¶
func NewCancelCopier ¶
func NewCancelCopier(src io.Reader, dst io.Writer) *CancelCopier
func (*CancelCopier) Close ¶
func (c *CancelCopier) Close()
func (*CancelCopier) Copy ¶
func (c *CancelCopier) Copy() error
type DemuxCopier ¶
type DemuxCopier struct {
Src io.Reader
DstOut io.Writer
DstErr io.Writer
// contains filtered or unexported fields
}
func NewDemuxCopier ¶
func (*DemuxCopier) Copy ¶
func (c *DemuxCopier) Copy() error
type MuxCopier ¶
type PluginError ¶
type PluginError string
const (
ErrNoStreamingConnection PluginError = "no streaming connection established"
)
func (PluginError) Error ¶
func (e PluginError) Error() string
type StdioClient ¶
type StdioClient struct {
// contains filtered or unexported fields
}
func NewStdioClient ¶
func NewStdioClient(url string) (*StdioClient, error)
type StdioServer ¶
type StdioServer struct {
// contains filtered or unexported fields
}
func NewStdioServer ¶
func NewStdioServer() (*StdioServer, error)
func (*StdioServer) Endpoint ¶
func (s *StdioServer) Endpoint() string
type StreamConfig ¶
Click to show internal directories.
Click to hide internal directories.