stream

Documentation

Index

• Variables
• func NewStream(rw io.ReadWriteCloser) *stream
• type Connection
  • func (self *Connection) Close() error
  • func (self *Connection) SetRW(rw io.ReadWriteCloser)
  • func (self *Connection) UpdateRW(srw SwapRW) error
• type DependencyManageable
• type Feature
• type FeatureContainable
• type FeatureContainer
  • func NewFeatureContainer(dg DependencyManageable) *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
  • func NewServerStream(rw io.ReadWriteCloser, depGraph DependencyManageable, conf RawConfig) ServerStream
• type State
  • func (self *State) Get(res interface{}) error
  • func (self *State) Push(states ...interface{})
• type Stream
• type StreamHandler
• type SwapRW

Variables

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 DependencyManageable interface {
	Add(name string, depends ...string)
	Get(name string) []string
}

type Feature

type Feature interface {
	Name() string
	Required() bool
}

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 State

type State struct {
	// contains filtered or unexported fields
}

func (*State) Get

func (self *State) Get(res interface{}) error

func (*State) Push

func (self *State) Push(states ...interface{})

type Stream

type Stream interface {
	xtream.Factory

	ID() string
	ServerName() string
	SetServerName(string)
	Open(StreamHandler) error
	Close() error
	State() *State
	Opened() bool
	Version() string
	SetVersion(string)
	UpdateRW(SwapRW) error
	ReadElement() (xtream.Element, error)
	WriteElement(xtream.Element) error
}

type StreamHandler

type StreamHandler func(ServerStream) error

type SwapRW

type SwapRW func(source_rw io.ReadWriteCloser) (io.ReadWriteCloser, error)