lib_gc_messages_collector

Documentation

Index

• Variables
• type Message
  • func BuildMessageHelper(content interface{}, id int64, specializedSender string, Ttl time.Duration) *Message
• type MessageSenderFactory_I
• type MessageSenderFunc
• type Package

Variables

var CURRENT_ON_BUILDING_PACKAGE_LENGTH = expvar.NewInt("CURRENT_ON_BUILDING_PACKAGE_LENGTH")

Initializing counters

var DISCARDED_MESSAGES = expvar.NewInt("DISCARDED_MESSAGES")

var Dummy struct{}

var EchoSendingErrors bool

If is set to true, the sending errors will be sent to SendingErrorsChan channel

var MessagesCollectorChan chan *Message

Messages collector chan

var PACKAGES_SENDING_ERRORS = expvar.NewInt("PACKAGES_SENDING_ERRORS")

var PENDING_RETRYING_PAKCAGES = expvar.NewInt("PENDING_RETRYING_PAKCAGES")

var SendingErrorsChan chan *Package

Sending's errors chan. The failed sending tries, will be sent to this channel This channel must be consumed it EcoSendingErrors property is set to true

var TIMEOUT_INITIALIZING_LOT = 1000

var TIMEOUT_PACKAGE_CLOSING = 1000

var TIMEOUT_PUTTING_MESSAGE = 10000

var TIMEOUT_SENDING_CHECKING = 1000

Types

type Message

type Message struct {
	Id             int64
	CreationTime   int64
	Ttl            time.Duration
	SendingRetries int16
	Content        interface{}
	Sender         string
}

func BuildMessageHelper

func BuildMessageHelper(content interface{}, id int64, specializedSender string, Ttl time.Duration) *Message

---------------------------------------- helpers

type MessageSenderFactory_I

type MessageSenderFactory_I interface {
	AddMessageSender(string, MessageSenderFunc)
	RemoveMessageSender(string) (MessageSenderFunc, error)
	GetSender(string) (MessageSenderFunc, error)
}

List of available senders. Each one of them, specialized in an specific sending target.

var MessageSenderFactory MessageSenderFactory_I

type MessageSenderFunc

type MessageSenderFunc func(message *Package) (*Package, error)

type Package

type Package struct {
	Sender        string
	Queue         *lib_gc_fifo.Fifo
	Id            int64
	SendingErrors []error
}