app

Documentation

Index

• type Queue
  • func NewQueue(size int) *Queue
  • func (q *Queue) Pop() ([]byte, bool)
  • func (q *Queue) Push(eb []byte)
• type Server
  • func NewServer(addr, datadogKey string, opts ...ServerOption) *Server
  • func (s *Server) Addr() string
  • func (s *Server) Run()
• type ServerOption
  • func WithDatadogBaseURL(baseURL string) ServerOption

Types

type Queue

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

Queue is a thread safe queue.

func NewQueue

func NewQueue(size int) *Queue

NewQueue returns a new Queue configured with the given size.

func (*Queue) Pop

func (q *Queue) Pop() ([]byte, bool)

Pop pulls a slice of bytes off the queue and returns the slice. If the queue is empty the returned slice will be nil and the bool will be false.

func (*Queue) Push

func (q *Queue) Push(eb []byte)

Push adds a slice of bytes to the queue. If the queue is full the given slice will be dropped.

type Server

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

Server handles initilizing an HTTP server as well as a rfc 5425 message processor.

func NewServer

func NewServer(addr, datadogKey string, opts ...ServerOption) *Server

NewServer will start a listener on the given addr and configure a server for processing rfc5424 messages.

func (*Server) Addr

func (s *Server) Addr() string

Addr returns the address the listener is bound to.

func (*Server) Run

func (s *Server) Run()

Run will start the message processor and serve the HTTP server.

type ServerOption

type ServerOption func(*Server)

ServerOption is a func that can be passed into NewServer to configure optional settings on the Server.

func WithDatadogBaseURL

func WithDatadogBaseURL(baseURL string) ServerOption

WithDatadogBaseURL sets the base url for the datadog API.