stream

Documentation

Index

• type C2S
• type InOutStream
• type InStream
• type MockC2S
  • func NewMockC2S(id string, jid *jid.JID) *MockC2S
  • func (m *MockC2S) Context() map[string]interface{}
  • func (m *MockC2S) Disconnect(err error)
  • func (m *MockC2S) Domain() string
  • func (m *MockC2S) GetBool(key string) bool
  • func (m *MockC2S) GetFloat(key string) float64
  • func (m *MockC2S) GetInt(key string) int
  • func (m *MockC2S) GetString(key string) string
  • func (m *MockC2S) ID() string
  • func (m *MockC2S) IsAuthenticated() bool
  • func (m *MockC2S) IsDisconnected() bool
  • func (m *MockC2S) IsSecured() bool
  • func (m *MockC2S) JID() *jid.JID
  • func (m *MockC2S) Presence() *xmpp.Presence
  • func (m *MockC2S) ReceiveElement() xmpp.XElement
  • func (m *MockC2S) Resource() string
  • func (m *MockC2S) SendElement(elem xmpp.XElement)
  • func (m *MockC2S) SetAuthenticated(authenticated bool)
  • func (m *MockC2S) SetBool(key string, value bool)
  • func (m *MockC2S) SetFloat(key string, value float64)
  • func (m *MockC2S) SetInt(key string, value int)
  • func (m *MockC2S) SetJID(jid *jid.JID)
  • func (m *MockC2S) SetPresence(presence *xmpp.Presence)
  • func (m *MockC2S) SetSecured(secured bool)
  • func (m *MockC2S) SetString(key string, value string)
  • func (m *MockC2S) Username() string
  • func (m *MockC2S) WaitDisconnection() error
• type S2SIn
• type S2SOut

Types

type C2S

type C2S interface {
	InOutStream

	Context() map[string]interface{}

	SetString(key string, value string)
	GetString(key string) string

	SetInt(key string, value int)
	GetInt(key string) int

	SetFloat(key string, value float64)
	GetFloat(key string) float64

	SetBool(key string, value bool)
	GetBool(key string) bool

	Username() string
	Domain() string
	Resource() string

	JID() *jid.JID

	IsSecured() bool
	IsAuthenticated() bool

	Presence() *xmpp.Presence
}

C2S represents a client-to-server XMPP stream.

type InOutStream

type InOutStream interface {
	InStream
	SendElement(elem xmpp.XElement)
}

InOutStream represents a generic incoming/outgoing stream.

type InStream

type InStream interface {
	ID() string
	Disconnect(err error)
}

InStream represents a generic incoming stream.

type MockC2S

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

MockC2S represents a mocked c2s stream.

func NewMockC2S

func NewMockC2S(id string, jid *jid.JID) *MockC2S

NewMockC2S returns a new mocked stream instance.

func (*MockC2S) Context

func (m *MockC2S) Context() map[string]interface{}

Context returns a copy of the stream associated context.

func (*MockC2S) Disconnect

func (m *MockC2S) Disconnect(err error)

Disconnect disconnects mocked stream.

func (*MockC2S) Domain

func (m *MockC2S) Domain() string

Domain returns current mocked stream domain.

func (*MockC2S) GetBool

func (m *MockC2S) GetBool(key string) bool

GetBool returns the context value associated with the key as a boolean.

func (*MockC2S) GetFloat

func (m *MockC2S) GetFloat(key string) float64

GetFloat returns the context value associated with the key as a float64.

func (*MockC2S) GetInt

func (m *MockC2S) GetInt(key string) int

GetInt returns the context value associated with the key as an integer.

func (*MockC2S) GetString

func (m *MockC2S) GetString(key string) string

GetString returns the context value associated with the key as a string.

func (*MockC2S) ID

func (m *MockC2S) ID() string

ID returns mocked stream identifier.

func (*MockC2S) IsAuthenticated

func (m *MockC2S) IsAuthenticated() bool

IsAuthenticated returns whether or not the mocked stream has successfully authenticated.

func (*MockC2S) IsDisconnected

func (m *MockC2S) IsDisconnected() bool

IsDisconnected returns whether or not the mocked stream has been disconnected.

func (*MockC2S) IsSecured

func (m *MockC2S) IsSecured() bool

IsSecured returns whether or not the mocked stream has been secured.

func (*MockC2S) JID

func (m *MockC2S) JID() *jid.JID

JID returns current user JID.

func (*MockC2S) Presence

func (m *MockC2S) Presence() *xmpp.Presence

Presence returns last sent presence element.

func (*MockC2S) ReceiveElement

func (m *MockC2S) ReceiveElement() xmpp.XElement

ReceiveElement waits until a new XML element is sent to the mocked stream and returns it.

func (*MockC2S) Resource

func (m *MockC2S) Resource() string

Resource returns current mocked stream resource.

func (*MockC2S) SendElement

func (m *MockC2S) SendElement(elem xmpp.XElement)

SendElement sends the given XML element.

func (*MockC2S) SetAuthenticated

func (m *MockC2S) SetAuthenticated(authenticated bool)

SetAuthenticated sets whether or not the a mocked stream has been authenticated.

func (*MockC2S) SetBool

func (m *MockC2S) SetBool(key string, value bool)

SetBool associates a boolean context value to a key.

func (*MockC2S) SetFloat

func (m *MockC2S) SetFloat(key string, value float64)

SetFloat associates a float context value to a key.

func (*MockC2S) SetInt

func (m *MockC2S) SetInt(key string, value int)

SetInt associates an integer context value to a key.

func (*MockC2S) SetJID

func (m *MockC2S) SetJID(jid *jid.JID)

SetJID sets the mocked stream JID value.

func (*MockC2S) SetPresence

func (m *MockC2S) SetPresence(presence *xmpp.Presence)

SetPresence sets the mocked stream last received presence element.

func (*MockC2S) SetSecured

func (m *MockC2S) SetSecured(secured bool)

SetSecured sets whether or not the a mocked stream has been secured.

func (*MockC2S) SetString

func (m *MockC2S) SetString(key string, value string)

SetString associates a string context value to a key.

func (*MockC2S) Username

func (m *MockC2S) Username() string

Username returns current mocked stream username.

func (*MockC2S) WaitDisconnection

func (m *MockC2S) WaitDisconnection() error

WaitDisconnection waits until the mocked stream disconnects.

type S2SIn

type S2SIn interface {
	InStream
}

S2SIn represents an incoming server-to-server XMPP stream.

type S2SOut

type S2SOut interface {
	InOutStream
}

S2SOut represents an outgoing server-to-server XMPP stream.