event

Documentation

Index

• func Close()
• func EventPublish(channel string, data map[string]interface{})
• func Publish(clientId, channel string, data map[string]interface{}) error
• func Stack(channel string, f func(CreatedEvenMessage)) (err error)
• func Subscribe(channel string, f func(CreatedEvenMessage)) (err error)
• type Conn
  • func Load() (*Conn, error)
• type CreatedEvenMessage
  • func (m CreatedEvenMessage) ToString() string
  • func (m CreatedEvenMessage) Type() string
• type Message

Functions

func Close

func Close()

func EventPublish

func EventPublish(channel string, data map[string]interface{})

func Publish

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

func Stack

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

func Subscribe

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

Types

type Conn

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

func Load

func Load() (*Conn, error)

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
}