forwarder

Documentation

Index

• Constants
• type AuditLogEvent
  • func NewAuditLogEvent(message, logType, serverName string) AuditLogEvent
• type EventForwarder
  • func NewEventForwarderFromConfig(signals chan os.Signal, cfg *Configuration) (EventForwarder, error)
  • func (forwarder *EventForwarder) MessageProcessingLoop(uri, queueName, consumerTag string) error
  • func (forwarder *EventForwarder) RunUntilExit()
  • func (forwarder *EventForwarder) StartOutput() error
  • func (forwarder *EventForwarder) Startup(hostname string) error
• type FileConsumer
  • func NewFileConsumer(fName string) (*FileConsumer, <-chan string, error)
• type InputWorker
  • func NewInputWorker(outputFormat int, outputs chan<- string, cfg *Configuration, status *Status) InputWorker
  • func (inputWorker InputWorker) OutputMessages(msgs [][]byte)
• type OutputWithParameters
• type Status
  • func NewStatus() *Status

Constants

const OUTPUTCHANNELSIZE = 1000000

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
}

func NewStatus

func NewStatus() *Status