queueNats

Documentation

Index

• type QueueNats
  • func (e *QueueNats) Connect(connection interface{}, options ...interface{})
  • func (e *QueueNats) Disconnect()
  • func (e *QueueNats) New() (object interface{}, err error)
  • func (e *QueueNats) Publish(subject string, data []byte) (err error)
  • func (e *QueueNats) SetReport(function func(status commomTypes.QueueStatus))
  • func (e *QueueNats) Subscribe(subject string, function func(subject string, data []byte) (err error)) (err error)

Types

type QueueNats

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

func (*QueueNats) Connect

func (e *QueueNats) Connect(connection interface{}, options ...interface{})

Connect (Português): conecta ao servidor de fila

func (*QueueNats) Disconnect

func (e *QueueNats) Disconnect()

Disconnect (Português): desconecta do servidor de fila

func (*QueueNats) New

func (e *QueueNats) New() (object interface{}, err error)

New (Português): fábrica do objeto

func (*QueueNats) Publish

func (e *QueueNats) Publish(subject string, data []byte) (err error)

Publish (Português): publica uma informação no canal específico da fila

func (*QueueNats) SetReport

func (e *QueueNats) SetReport(function func(status commomTypes.QueueStatus))

SetReport (Português): invoca uma função periodicamente para informar o status da conexão

func (*QueueNats) Subscribe

func (e *QueueNats) Subscribe(subject string, function func(subject string, data []byte) (err error)) (err error)

Subscribe (Português): adicina uma função para ser invocada quando um novo evento ocorre no canal