event

Documentation

Index

• func Action(action string, data map[string]interface{})
• func Close()
• func Done(work_id, event string)
• func Event(event string, data interface{})
• func Publish(clientId, channel string, data map[string]interface{}) error
• func Rejected(work_id, event string)
• func Stack(channel string, f func(CreatedEvenMessage)) (err error)
• func Subscribe(channel string, f func(CreatedEvenMessage)) (err error)
• func Work(work, work_id string, data interface{})
• func Working(worker, work_id string)
• func WsBroadcast(message interface{}, ignoreId string)
• func WsPublish(channel string, message interface{}, ignoreId string)
• func WsSendMessage(clientId, channel string, message interface{})
• type Conn
  • func Load() (*Conn, error)
  • func (c *Conn) Lock(key string) bool
• type CreatedEvenMessage
  • func (m CreatedEvenMessage) ToString() string
  • func (m CreatedEvenMessage) Type() string
• type Message

Functions

func Action

func Action(action string, data map[string]interface{})

func Close

func Close()

func Done

func Done(work_id, event string)

func Event

func Event(event string, data interface{})

func Publish

func Publish(clientId, channel string, data map[string]interface{}) error

func Rejected

func Rejected(work_id, event string)

func Stack

func Stack(channel string, f func(CreatedEvenMessage)) (err error)

func Subscribe

func Subscribe(channel string, f func(CreatedEvenMessage)) (err error)

func Work

func Work(work, work_id string, data interface{})

func Working

func Working(worker, work_id string)

func WsBroadcast

func WsBroadcast(message interface{}, ignoreId string)

func WsPublish

func WsPublish(channel string, message interface{}, ignoreId string)

func WsSendMessage

func WsSendMessage(clientId, channel string, message interface{})

Types

type Conn

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

func Load

func Load() (*Conn, error)

func (*Conn) Lock

func (c *Conn) Lock(key string) bool

type CreatedEvenMessage

type CreatedEvenMessage struct {
	Created_at time.Time              `json:"created_at"`
	Id         string                 `json:"id"`
	ClientId   string                 `json:"client_id"`
	Channel    string                 `json:"channel"`
	Data       map[string]interface{} `json:"data"`
}

func (CreatedEvenMessage) ToString

func (m CreatedEvenMessage) ToString() string

func (CreatedEvenMessage) Type

func (m CreatedEvenMessage) Type() string

type Message

type Message interface {
	Type() string
}