handler

Documentation

Index

• func Serve(ctx context.Context, conf *Config) (*http.ServeMux, error)
• type Config
• type Receiver
  • func NewReceiver(tmpl *template.Template, conf *ReceiverConfig) (*Receiver, error)
  • func (d *Receiver) NewMessage(ctx context.Context, r io.Reader) error
• type ReceiverConfig

Functions

func Serve

func Serve(ctx context.Context, conf *Config) (*http.ServeMux, error)

Types

type Config

type Config struct {
	// path to global template files
	Templates []string          `json:"templates,omitempty"`
	Receivers []*ReceiverConfig `json:"receivers,omitempty"`
}

type Receiver

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

func NewReceiver

func NewReceiver(tmpl *template.Template, conf *ReceiverConfig) (*Receiver, error)

func (*Receiver) NewMessage

func (d *Receiver) NewMessage(ctx context.Context, r io.Reader) error

type ReceiverConfig

type ReceiverConfig struct {
	// name should be a valid dns label, and identical
	Name              string            `json:"name,omitempty"`
	URL               config.URL        `json:"url,omitempty"`
	Body              string            `json:"body,omitempty"`
	AdditionalHeaders map[string]string `json:"additional_headers,omitempty"`
	DownstreamTimeout duration.Duration `json:"downstream_timeout,omitempty"`
}