event

Documentation

Index

• func Close()
• func Connect(w http.ResponseWriter, r *http.Request)
• func Done(work_id, event string)
• func Log(event string, data et.Json)
• 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(worker, work_id string, data et.Json)
• func Worker(event string, data et.Json)
• func Working(worker, work_id string)
• 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 Close

func Close()

func Connect

func Connect(w http.ResponseWriter, r *http.Request)

http

func Done

func Done(work_id, event string)

Done work

func Log

func Log(event string, data et.Json)

func Publish

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

Basic function to publish a message to a channel

func Rejected

func Rejected(work_id, event string)

Rejected work

func Stack

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

Basic function to subscrite kind stack to a channel

func Subscribe

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

Basic function to subscribe to a channel

func Work

func Work(worker, work_id string, data et.Json)

Publish event asigned to a worker

func Worker

func Worker(event string, data et.Json)

Publish event

func Working

func Working(worker, work_id string)

Publish event begin work

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
}