event

Documentation

Index

• Constants
• func Close()
• func Data(channel string, data et.Json) 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
  • func ConnectTo(host, user, password string) (*Conn, error)
  • func Load() (*Conn, error)
• type EvenMessage
  • func DecodeMessage(data []byte) (EvenMessage, error)
  • func NewEvenMessage(channel string, data et.Json) EvenMessage
  • func (m EvenMessage) Encode() ([]byte, error)
  • func (m EvenMessage) ToJson() (et.Json, error)
  • func (m EvenMessage) ToString() string
• type Message
• type WorkStatus
  • func ToWorkStatus(n int) WorkStatus
  • func (s WorkStatus) String() string

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_LAT_TOKEN_USE = "telemetry.token.last_use"

const EVENT_LOG = "log"

const EVENT_OVERFLOW = "requests/overflow"

const EVENT_TELEMETRY = "telemetry"

const EVENT_WORK = "event/worker"

const EVENT_WORK_STATE = "event/worker/state"

const PackageName = "event"

const QUEUE_STACK = "stack"

Functions

func Close

func Close()

* * Close the connection to the service pubsub *

func Data

func Data(channel string, data et.Json) error

* * Data * @param string channel * @param func(Message) reciveFn * @return error *

func FromId

func FromId() string

* * FromId return the id of the connection * @return string *

func HttpEventWork

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

* * HttpEventWork * @param w http.ResponseWriter * @param r *http.Request *

func Log

func Log(event string, data et.Json)

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

func Overflow

func Overflow(data et.Json)

* * Overflow * @param data et.Json *

func Publish

func Publish(channel string, data et.Json) error

* * Publish * @param channel string * @param data et.Json * @return error *

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 *

func Telemetry

func Telemetry(data et.Json)

* * Telemetry * @param data et.Json *

func TokenLastUse

func TokenLastUse(data et.Json)

* * TokenLastUse * @param data et.Json *

func Work

func Work(event string, data et.Json) et.Json

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

func WorkState

func WorkState(work_id string, status WorkStatus, data et.Json)

* * WorkState * @param work_id string * @param status WorkStatus * @param data et.Json *

Types

type Conn

type Conn struct {
	*nats.Conn
	// contains filtered or unexported fields
}

func ConnectTo

func ConnectTo(host, user, password string) (*Conn, error)

func Load

func Load() (*Conn, error)

* * Load the connection to the service pubsub * @return *Conn, error *

type EvenMessage

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

func (m EvenMessage) Encode() ([]byte, error)

* * Encode * @return []byte, error *

func (EvenMessage) ToJson

func (m EvenMessage) ToJson() (et.Json, error)

* * ToJson * @return et.Json, error *

func (EvenMessage) ToString

func (m EvenMessage) ToString() string

* * ToString * @return string *

type Message

type Message interface {
	Type() 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 *

func (WorkStatus) String

func (s WorkStatus) String() string

* * String * @return string *