realtime

Documentation

Index

• type Listener
  • func (l *Listener) Receive(res *cyako.Res)
• type Realtime
  • func (r *Realtime) AddListener(groupName string, conn *websocket.Conn, id string, method string)
  • func (r *Realtime) AddListenerDefault(groupName string, ctx *cyako.Ctx)
  • func (r *Realtime) Send(groupName string, res *cyako.Res)

Types

type Listener

type Listener struct {
	Conn   *websocket.Conn
	Id     string
	Method string
}

func (*Listener) Receive

func (l *Listener) Receive(res *cyako.Res)

type Realtime

type Realtime struct {
	// Dependences        dep
	KVStore            *kvstore.KVStore
	NameScopeListeners ns.Scope
}

func (*Realtime) AddListener

func (r *Realtime) AddListener(groupName string, conn *websocket.Conn, id string, method string)

This method add specific *websocket.Conn to listeners list

func (*Realtime) AddListenerDefault

func (r *Realtime) AddListenerDefault(groupName string, ctx *cyako.Ctx)

func (*Realtime) Send

func (r *Realtime) Send(groupName string, res *cyako.Res)

Send response to listeners in some group