Documentation ¶
Index ¶
- Variables
- func NewStream(rw io.ReadWriteCloser) *stream
- type Connection
- type DependencyManageable
- type Feature
- type FeatureContainable
- type FeatureContainer
- func (fc *FeatureContainer) AddFeature(f Feature)
- func (fc *FeatureContainer) DependencyGraph() DependencyManageable
- func (fc *FeatureContainer) HasRequired() bool
- func (fc *FeatureContainer) MarshalXML(e *xml.Encoder, start xml.StartElement) error
- func (fc *FeatureContainer) RemoveFeature(name string)
- type RawConfig
- type ServerStream
- type State
- type Stream
- type StreamHandler
- type SwapRW
Constants ¶
This section is empty.
Variables ¶
View Source
var StreamXMLName = xml.Name{Local: "stream:stream"}
Functions ¶
func NewStream ¶
func NewStream(rw io.ReadWriteCloser) *stream
Types ¶
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) Close ¶
func (self *Connection) Close() error
func (*Connection) SetRW ¶
func (self *Connection) SetRW(rw io.ReadWriteCloser)
func (*Connection) UpdateRW ¶
func (self *Connection) UpdateRW(srw SwapRW) error
type DependencyManageable ¶
type FeatureContainable ¶
type FeatureContainable interface { AddFeature(Feature) RemoveFeature(string) HasRequired() bool DependencyGraph() DependencyManageable }
type FeatureContainer ¶
type FeatureContainer struct {
// contains filtered or unexported fields
}
func NewFeatureContainer ¶
func NewFeatureContainer(dg DependencyManageable) *FeatureContainer
func (*FeatureContainer) AddFeature ¶
func (fc *FeatureContainer) AddFeature(f Feature)
func (*FeatureContainer) DependencyGraph ¶
func (fc *FeatureContainer) DependencyGraph() DependencyManageable
func (*FeatureContainer) HasRequired ¶
func (fc *FeatureContainer) HasRequired() bool
func (*FeatureContainer) MarshalXML ¶
func (fc *FeatureContainer) MarshalXML(e *xml.Encoder, start xml.StartElement) error
func (*FeatureContainer) RemoveFeature ¶
func (fc *FeatureContainer) RemoveFeature(name string)
type RawConfig ¶
type RawConfig map[string]json.RawMessage
type ServerStream ¶
type ServerStream interface { Stream FeatureContainable SendFeatures() error RequestedServerName() string ClientJID() string SetClientJID(string) ReOpen() Config() RawConfig }
func NewServerStream ¶
func NewServerStream(rw io.ReadWriteCloser, depGraph DependencyManageable, conf RawConfig) ServerStream
type StreamHandler ¶
type StreamHandler func(ServerStream) error
type SwapRW ¶
type SwapRW func(source_rw io.ReadWriteCloser) (io.ReadWriteCloser, error)
Click to show internal directories.
Click to hide internal directories.