handlers

Documentation

Index

• func RFC5424PassThroughFormatter(p syslog.Priority, hostname, tag, content string) string
• func VersionHandler(version string) echo.HandlerFunc
• type HealthHandler
  • func (h HealthHandler) Handler(ctx context.Context, tracer trace.Tracer) echo.HandlerFunc
• type LogData
• type LogEvent
• type RabbitMQHandler
  • func NewRabbitMQHandler(promtailAddr string) (*RabbitMQHandler, error)
  • func (h *RabbitMQHandler) CreateWorker(exchange, exchangeType, routingKey, queueName, consumerTag string) (chan bool, error)
  • func (h *RabbitMQHandler) RabbitMQRFC5424Worker(doneChannel <-chan bool) rabbitmq.ConsumerHandlerFunc
• type RabbitMQMessage
• type SyslogHandler
  • func NewSyslogHandler(token, promtailAddr string) (*SyslogHandler, error)
  • func (h *SyslogHandler) Handler(ctx context.Context, tracer trace.Tracer) echo.HandlerFunc

Functions

func RFC5424PassThroughFormatter

func RFC5424PassThroughFormatter(p syslog.Priority, hostname, tag, content string) string

func VersionHandler

func VersionHandler(version string) echo.HandlerFunc

Types

type HealthHandler

type HealthHandler struct {
}

func (HealthHandler) Handler

func (h HealthHandler) Handler(ctx context.Context, tracer trace.Tracer) echo.HandlerFunc

type LogData

type LogData struct {
	Message string `json:"message"`
}

type LogEvent

type LogEvent struct {
	LogData             LogData   `json:"logData"`
	ApplicationName     string    `json:"applicationName"`
	ServiceName         string    `json:"serviceName"`
	EventId             string    `json:"eventId"`
	ServerName          string    `json:"serverName"`
	OriginatingUser     string    `json:"originatingUser"`
	Id                  string    `json:"id"`
	LogTime             time.Time `json:"logTime"`
	TransactionId       string    `json:"transactionId"`
	ApplicationVersion  string    `json:"applicationVersion"`
	ProductName         string    `json:"productName"`
	Category            string    `json:"category"`
	ApplicationInstance string    `json:"applicationInstance"`
	Severity            string    `json:"severity"`
	Component           string    `json:"component"`
	ResourceType        string    `json:"resourceType"`
}

type RabbitMQHandler

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

func NewRabbitMQHandler

func NewRabbitMQHandler(promtailAddr string) (*RabbitMQHandler, error)

func (*RabbitMQHandler) CreateWorker

func (h *RabbitMQHandler) CreateWorker(exchange, exchangeType, routingKey, queueName, consumerTag string) (chan bool, error)

func (*RabbitMQHandler) RabbitMQRFC5424Worker

func (h *RabbitMQHandler) RabbitMQRFC5424Worker(doneChannel <-chan bool) rabbitmq.ConsumerHandlerFunc

type RabbitMQMessage

type RabbitMQMessage struct {
	Syslog5424Sd string    `json:"syslog5424_sd,omitempty"`
	Type         string    `json:"type"`
	LogEvent     LogEvent  `json:"LogEvent"`
	Timestamp    time.Time `json:"@timestamp,omitempty"`
	Tags         []string  `json:"tags,omitempty"`
	Version      string    `json:"@version,omitempty"`
}

type SyslogHandler

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

func NewSyslogHandler

func NewSyslogHandler(token, promtailAddr string) (*SyslogHandler, error)

func (*SyslogHandler) Handler

func (h *SyslogHandler) Handler(ctx context.Context, tracer trace.Tracer) echo.HandlerFunc