event

Documentation

Index

• func Close()
• 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(EvenMessage)) (err error)
• func Subscribe(channel string, f func(EvenMessage)) (err error)
• func Test(w http.ResponseWriter, r *http.Request)
• 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 EvenMessage
  • func (m EvenMessage) ToString() string
  • func (m EvenMessage) Type() string
• type Message

Functions

func Close

func Close()

func Done

func Done(work_id, event string)

* * Done * @param work_id string * @param event string *

func Log

func Log(event string, data et.Json)

* * Log * @param event string * @param 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 * @param work_id string * @param event string *

func Stack

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

Basic function to subscrite kind stack to a channel

func Subscribe

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

Basic function to subscribe to a channel

func Test

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

* * Test event, testing message broker * @param w http.ResponseWriter * @param r *http.Request *

func Work

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

* * Work * @param worker string * @param work_id string * @param data et.Json *

func Worker

func Worker(event string, data et.Json)

* * Worker * @param event string * @param data et.Json *

func Working

func Working(worker, work_id string)

* * Working * @param worker string * @param work_id string *

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 EvenMessage

type EvenMessage 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 (EvenMessage) ToString

func (m EvenMessage) ToString() string

func (EvenMessage) Type

func (m EvenMessage) Type() string

type Message

type Message interface {
	Type() string
}