Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Backend ¶
type Backend interface { //Connect(url string, opts interface{}) error Get() GetDefault() chan Message }
type Message ¶
type Message struct { // Source split by path separator TS time.Time // true if it is TS from actual queue, false if it is just receive time TSReliable bool Source []string Headers map[string]interface{} Body []byte }
Message is common message type used by printing/formatting function. it is backend job to fit incoming messages into that template
Click to show internal directories.
Click to hide internal directories.