processor

Documentation

Index

• type Getter
• type HTTPClient
• type Processor
  • func New(g Getter, c HTTPClient, apiBaseURL, apiKey string) *Processor
  • func (p *Processor) Run()

Types

type Getter

type Getter func() ([]byte, bool)

Getter is used to get rfc5424 encoded bytes to send to datadog.

type HTTPClient

type HTTPClient interface {
	Post(url, contentType string, body io.Reader) (*http.Response, error)
}

HTTPClient is used to communicate to the datadog API.

type Processor

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

Processor gets rfc5424 messages and sends them to the datadog API.

func New

func New(g Getter, c HTTPClient, apiBaseURL, apiKey string) *Processor

New creates a new Processor.

func (*Processor) Run

func (p *Processor) Run()

Run reads from the Getter and writes to datadog. It blocks while reading.