Documentation
¶
Index ¶
- Constants
- Variables
- func Close()
- func Data(channel string, data et.Json) error
- func Error(event string, err error) error
- func FromId() string
- func HttpEventWork(w http.ResponseWriter, r *http.Request)
- func Log(event string, data et.Json)
- func Overflow(data et.Json)
- func Publish(channel string, data et.Json) error
- func Queue(channel, queue string, f func(EvenMessage)) (err error)
- func Source(channel string, f func(EvenMessage)) error
- func Stack(channel string, f func(EvenMessage)) error
- func Subscribe(channel string, f func(EvenMessage)) (err error)
- func Telemetry(data et.Json)
- func TokenLastUse(data et.Json)
- func Work(event string, data et.Json) et.Json
- func WorkState(work_id string, status WorkStatus, data et.Json)
- type Conn
- type EvenMessage
- type Message
- type WorkStatus
Constants ¶
const ( ERR_ENV_REQUIRED = "Variables de entorno requerida (%s)" ERR_NOT_CONNECT = "Not connect nats" ERR_PARAM_NOT_FOUND = "Param not found" ERR_CLIENT_ID_EMPTY = "Client id is empty" PARAMS_UPDATED = "Params updated" )
const EVENT_LOG = "log"
const EVENT_MODEL_DELETE = "model:delete"
const EVENT_MODEL_ERROR = "model:error"
const EVENT_MODEL_INSERT = "model:insert"
const EVENT_MODEL_UPDATE = "model:update"
const EVENT_OVERFLOW = "requests:overflow"
const EVENT_TELEMETRY = "telemetry"
const EVENT_TELEMETRY_TOKEN_LAST_USE = "telemetry:token:last_use"
const EVENT_WEBHOOK = "event:webhook"
const EVENT_WORK = "event:worker"
const EVENT_WORK_STATE = "event:worker:state"
const PackageName = "event"
const QUEUE_STACK = "stack"
Variables ¶
var Events = []string{}
Functions ¶
func Data ¶ added in v0.0.4
* * Data * @param string channel * @param func(Message) reciveFn * @return error *
func HttpEventWork ¶
func HttpEventWork(w http.ResponseWriter, r *http.Request)
* * HttpEventWork * @param w http.ResponseWriter * @param r *http.Request *
func Queue ¶
func Queue(channel, queue string, f func(EvenMessage)) (err error)
* * Queue * @param string channel * @param func(EvenMessage) f * @return error *
func Source ¶
func Source(channel string, f func(EvenMessage)) error
* * Source * @param string channel * @param func(Message) reciveFn * @return error *
func Stack ¶
func Stack(channel string, f func(EvenMessage)) error
* * Stack * @param channel string * @param f func(EvenMessage) * @return error *
func Subscribe ¶
func Subscribe(channel string, f func(EvenMessage)) (err error)
* * Subscribe * @param channel string * @param f func(EvenMessage) * @return error *
Types ¶
type Conn ¶
type EvenMessage ¶ added in v0.0.4
type EvenMessage struct {
Created_at time.Time `json:"created_at"`
Id string `json:"id"`
Channel string `json:"channel"`
Data et.Json `json:"data"`
}
func DecodeMessage ¶
func DecodeMessage(data []byte) (EvenMessage, error)
* * DecodeMessage * @param []byte data * @return EvenMessage, error *
func NewEvenMessage ¶
func NewEvenMessage(channel string, data et.Json) EvenMessage
* * NewEvenMessage * @param string channel * @param et.Json data * @return EvenMessage *
func (EvenMessage) Encode ¶ added in v0.0.4
func (m EvenMessage) Encode() ([]byte, error)
* * Encode * @return []byte, error *
func (EvenMessage) ToJson ¶ added in v0.0.4
func (m EvenMessage) ToJson() (et.Json, error)
* * ToJson * @return et.Json, error *
func (EvenMessage) ToString ¶ added in v0.0.4
func (m EvenMessage) ToString() string
* * ToString * @return string *
type WorkStatus ¶
type WorkStatus int
const ( WorkStatusPending WorkStatus = iota WorkStatusAccepted WorkStatusProcessing WorkStatusCompleted WorkStatusFailed )
func ToWorkStatus ¶
func ToWorkStatus(n int) WorkStatus
* * ToWorkStatus * @param int n * @return WorkStatus *
Source Files