Documentation ¶
Index ¶
Constants ¶
View Source
const OUTPUTCHANNELSIZE = 1000000
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuditLogEvent ¶
type AuditLogEvent struct { Message string `json:"message"` Type string `json:"type"` CbServer string `json:"cb_server"` }
func NewAuditLogEvent ¶
func NewAuditLogEvent(message, logType, serverName string) AuditLogEvent
type EventForwarder ¶
type EventForwarder struct { *Configuration Output OutputWithParameters *Status // contains filtered or unexported fields }
func NewEventForwarderFromConfig ¶
func NewEventForwarderFromConfig(signals chan os.Signal, cfg *Configuration) (EventForwarder, error)
func (*EventForwarder) MessageProcessingLoop ¶
func (forwarder *EventForwarder) MessageProcessingLoop(uri, queueName, consumerTag string) error
func (*EventForwarder) RunUntilExit ¶
func (forwarder *EventForwarder) RunUntilExit()
func (*EventForwarder) StartOutput ¶
func (forwarder *EventForwarder) StartOutput() error
func (*EventForwarder) Startup ¶
func (forwarder *EventForwarder) Startup(hostname string) error
type FileConsumer ¶
type FileConsumer struct {
// contains filtered or unexported fields
}
func NewFileConsumer ¶
func NewFileConsumer(fName string) (*FileConsumer, <-chan string, error)
type InputWorker ¶
type InputWorker struct { protobufmessageprocessor.ProtobufMessageProcessor jsonmessageprocessor.JsonMessageProcessor *Status DebugFlag bool DebugStore string OutputFormat int // contains filtered or unexported fields }
func NewInputWorker ¶
func NewInputWorker(outputFormat int, outputs chan<- string, cfg *Configuration, status *Status) InputWorker
func (InputWorker) OutputMessages ¶
func (inputWorker InputWorker) OutputMessages(msgs [][]byte)
type OutputWithParameters ¶
type OutputWithParameters struct { Output Parameters string }
type Status ¶
type Status struct { InputEventCount metrics.Meter InputByteCount metrics.Meter OutputEventCount metrics.Meter OutputByteCount metrics.Meter ErrorCount metrics.Meter IsConnected bool LastConnectTime time.Time StartTime time.Time LastConnectError string ErrorTime time.Time Healthy metrics.Healthcheck sync.RWMutex }
Click to show internal directories.
Click to hide internal directories.