event

package
v0.1.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2025 License: MIT Imports: 16 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	QUEUE_STACK      = "stack"
	EVENT            = "event"
	EVENT_LOG        = "event:log"
	EVENT_OVERFLOW   = "event:overflow"
	EVENT_WORK       = "event:worker"
	EVENT_WORK_STATE = "event:worker:state"
	EVENT_SUBSCRIBED = "event:subscribed"
)
View Source 
const (
	ERR_ENV_REQUIRED     = "variables de entorno requerida (%s)"
	ERR_NOT_CONNECT      = "no se conecto a nats"
	ERR_PARAM_NOT_FOUND  = "parametro no encontrado"
	ERR_CLIENT_ID_EMPTY  = "id de cliente esta vacio"
	ERR_CHANNEL_REQUIRED = "canal requerido"
	PARAMS_UPDATED       = "parametros actualizados"
)
View Source 
const PackageName = "event"

Variables

This section is empty.

Functions

func Close 

func Close()

* * Close the connection to the service pubsub *

func Emit 

func Emit(channel string, data et.Json)

* * Emit * @param channel string, data et.Json *

func Error 

func Error(event string, err error) error

* * Error * @param event string, * @return error *

func Events 

func Events() []string

* * Events * @return []string *

func HealthCheck added in v0.1.18 

func HealthCheck() bool

* * HealthCheck * @return bool *

func HttpEventPublish added in v0.1.17 

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

* * HttpEventPublish * @param w http.ResponseWriter, r *http.Request *

func Id added in v0.1.1 

func Id() string

* * Id * @return string *

func Load 

func Load() error

* * Load * @return error *

func Log 

func Log(event string, data et.Json)

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

func On 

func On(channel string, handler Handler)

* * On * @param channel string, handler Handler *

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, data et.Json * @return error *

func Queue 

func Queue(channel, queue string, f func(Message)) (err error)

* * Queue * @param channel string, queue string, f func(Message) * @return error *

func Reset added in v0.1.17 

func Reset() error

* * Reset * @return error *

func Source 

func Source(channel string, f func(Message)) error

* * Source * @param channel string, f func(Message) * @return error *

func Stack 

func Stack(channel string, f func(Message)) error

* * Stack * @param channel string, f func(Message) * @return error *

func Subscribe 

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

* * Subscribe * @param channel string, f func(Message) * @return error *

func Unsubscribe added in v0.0.2 

func Unsubscribe(channel string) error

* * Unsubscribe * @param channel string * @return error *

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)

* * Connect to a host * @param host, user, password string * @return *Conn, error *

func (*Conn) Remove added in v0.1.17 

func (s *Conn) Remove(event string) (bool, error)

* * Remove * @return error *

func (*Conn) Reset added in v0.1.17 

func (s *Conn) Reset() error

* * Reset * @return error *

type EventEmiter 

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

func NewEventEmiter 

func NewEventEmiter() *EventEmiter

* * NewEventEmiter * @return *EventEmiter *

func (*EventEmiter) Emit 

func (s *EventEmiter) Emit(channel string, data et.Json)

* * Emit * @param channel string, data et.Json *

func (*EventEmiter) On 

func (s *EventEmiter) On(channel string, handler Handler)

* * On * @param channel string, handler Handler *

func (*EventEmiter) Start 

func (s *EventEmiter) Start()

* * Start *

type Handler 

type Handler func(message Message)

type Message 

type Message struct {
	CreatedAt time.Time `json:"created_at"`
	FromId    string    `json:"from_id"`
	Id        string    `json:"id"`
	Channel   string    `json:"channel"`
	Data      et.Json   `json:"data"`
	Myself    bool      `json:"myself"`
}

func DecodeMessage 

func DecodeMessage(data []byte) (Message, error)

* * DecodeMessage * @param []byte data * @return Message, error *

func NewEvenMessage 

func NewEvenMessage(channel string, data et.Json) Message

* * NewEvenMessage * @param string channel * @param et.Json data * @return Message *

func (Message) Encode 

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

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

func (Message) ToJson 

func (s Message) ToJson() (et.Json, error)

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

func (Message) ToString 

func (s Message) 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 *

func (WorkStatus) String 

func (s WorkStatus) String() string

* * String * @return string *

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.