event

Documentation

Index

• func Action(action string, data map[string]interface{})
• func Close()
• func Done(work_id string)
• func Event(event, _group string, data map[string]interface{})
• func Publish(clientId, channel string, data map[string]interface{}) error
• func Rejected(work_id 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 map[string]interface{})
• func Working(worker, work_id string)
• type Conn
  • func Load() (*Conn, error)
  • func (c *Conn) LockStack(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 string)

func Event

func Event(event, _group string, data map[string]interface{})

func Publish

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

func Rejected

func Rejected(work_id 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 map[string]interface{})

func Working

func Working(worker, work_id string)

Types

type Conn

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

func Load

func Load() (*Conn, error)

func (*Conn) LockStack

func (c *Conn) LockStack(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
}