forward

Documentation

Index

• func Forward(bufferChan chan *bytes.Buffer, forwarder Forwarder)
• type Config
  • func DefaultConfig() Config
• type FileForwarder
  • func NewFileForwarder(filename string, logger logging.Logger) (*FileForwarder, error)
  • func (f *FileForwarder) Forward(buffer *bytes.Buffer)
• type Forwarder
• type HTTPForwarder
  • func NewHTTPForwarder(apiKey string, config Config) (*HTTPForwarder, error)
  • func (h *HTTPForwarder) Forward(buffer *bytes.Buffer)
• type StdoutForwarder
  • func NewStdoutForwarder(logger logging.Logger) *StdoutForwarder
  • func (s *StdoutForwarder) Forward(buffer *bytes.Buffer)

Functions

func Forward

func Forward(bufferChan chan *bytes.Buffer, forwarder Forwarder)

Types

type Config

type Config struct {
	Endpoint  string
	Metadata  string
	UserAgent string

	Logger logging.Logger
}

func DefaultConfig

func DefaultConfig() Config

type FileForwarder

type FileForwarder struct {
	Filename string
	Logger   logging.Logger
	// contains filtered or unexported fields
}

func NewFileForwarder

func NewFileForwarder(filename string, logger logging.Logger) (*FileForwarder, error)

func (*FileForwarder) Forward

func (f *FileForwarder) Forward(buffer *bytes.Buffer)

type Forwarder

type Forwarder interface {
	Forward(*bytes.Buffer)
}

type HTTPForwarder

type HTTPForwarder struct {
	HTTPClient *retryablehttp.Client
	APIKey     string

	Config
}

func NewHTTPForwarder

func NewHTTPForwarder(apiKey string, config Config) (*HTTPForwarder, error)

func (*HTTPForwarder) Forward

func (h *HTTPForwarder) Forward(buffer *bytes.Buffer)

type StdoutForwarder

type StdoutForwarder struct {
	Logger logging.Logger
}

func NewStdoutForwarder

func NewStdoutForwarder(logger logging.Logger) *StdoutForwarder

func (*StdoutForwarder) Forward

func (s *StdoutForwarder) Forward(buffer *bytes.Buffer)