cluster/

Dec 27, 2019

Changes in this version

type Config

+ InTimeout time.Duration

+ func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

Dec 22, 2019

Changes in this version

type Message

+ func (m *Message) FromBytes(buf *bytes.Buffer) error

+ func (m *Message) ToBytes(buf *bytes.Buffer) error

type MessagePayload

+ func (p *MessagePayload) FromBytes(buf *bytes.Buffer) error

+ func (p *MessagePayload) ToBytes(buf *bytes.Buffer) error

Jan 14, 2019

Changes in this version

+ const MsgBatchBind

+ const MsgBind

+ const MsgRouteStanza

+ const MsgUnbind

+ const MsgUpdateContext

+ const MsgUpdatePresence

+ type C2S struct

+ func (s *C2S) Context() map[string]interface{}

+ func (s *C2S) Disconnect(err error)

+ func (s *C2S) Domain() string

+ func (s *C2S) GetBool(key string) bool

+ func (s *C2S) GetFloat(key string) float64

+ func (s *C2S) GetInt(key string) int

+ func (s *C2S) GetString(key string) string

+ func (s *C2S) ID() string

+ func (s *C2S) IsAuthenticated() bool

+ func (s *C2S) IsSecured() bool

+ func (s *C2S) JID() *jid.JID

+ func (s *C2S) Presence() *xmpp.Presence

+ func (s *C2S) Resource() string

+ func (s *C2S) SendElement(elem xmpp.XElement)

+ func (s *C2S) SetBool(key string, value bool)

+ func (s *C2S) SetFloat(key string, value float64)

+ func (s *C2S) SetInt(key string, value int)

+ func (s *C2S) SetPresence(presence *xmpp.Presence)

+ func (s *C2S) SetString(key string, value string)

+ func (s *C2S) UpdateContext(m map[string]interface{})

+ func (s *C2S) Username() string

+ type Cluster struct

+ func New(config *Config, delegate Delegate) (*Cluster, error)

+ func (c *Cluster) BroadcastMessage(msg *Message)

+ func (c *Cluster) C2SStream(jid *jid.JID, presence *xmpp.Presence, context map[string]interface{}, ...) *C2S

+ func (c *Cluster) Join() error

+ func (c *Cluster) LocalNode() string

+ func (c *Cluster) SendMessageTo(node string, msg *Message)

+ func (c *Cluster) Shutdown() error

+ type Config struct

+ BindPort int

+ Hosts []string

+ Name string

+ type Delegate interface

+ NodeJoined func(node *Node)

+ NodeLeft func(node *Node)

+ NodeUpdated func(node *Node)

+ NotifyMessage func(msg *Message)

+ type Message struct

+ Node string

+ Payloads []MessagePayload

+ Type int

+ func (m *Message) FromGob(dec *gob.Decoder) error

+ func (m *Message) ToGob(enc *gob.Encoder)

+ type MessagePayload struct

+ Context map[string]interface{}

+ JID *jid.JID

+ Stanza xmpp.Stanza

+ func (p *MessagePayload) FromGob(dec *gob.Decoder) error

+ func (p *MessagePayload) ToGob(enc *gob.Encoder)

+ type Metadata struct

+ GoVersion string

+ Version string

+ type Node struct

+ Metadata Metadata

+ Name string