httpcheck

Documentation

Index

• Constants
• type Config
• type Input
  • func (i *Input) Collect(accumulator api.Accumulator) error
  • func (i *Input) ExecuteRequest(configBytes []byte) ([]byte, error)
  • func (i *Input) GenerateErrorMetrics(a api.Accumulator)
  • func (i *Input) GetDefaultPrefix() string
  • func (i *Input) NetworkMode() string
  • func (i *Input) ProcessResponse(_ interface{}, respBytes []byte, err error, accumulator api.Accumulator) error
  • func (i *Input) SerializeRequest() (interface{}, string, []byte, time.Duration, error)

Constants

const (
	MaxBodyLimit = 10 * 1024 * 1024
)

Types

type Config

type Config struct {
	URL            string            `json:"url"`
	Headers        map[string]string `json:"headers"`
	Timeout        time.Duration     `json:"timeout"`
	Method         string            `json:"method"`
	SuccessCodes   []int             `json:"successCodes"`
	SuccessRegexps []*regexp.Regexp  `json:"successRegexps"`
	BodyLimit      int64             `json:"bodyLimit"`
	NetworkMode    string            `json:"networkMode"`
}

我们的插件必须是最少依赖的, 可以被直接运行的

type Input

type Input struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*Input) Collect

func (i *Input) Collect(accumulator api.Accumulator) error

func (*Input) ExecuteRequest

func (i *Input) ExecuteRequest(configBytes []byte) ([]byte, error)

func (*Input) GenerateErrorMetrics

func (i *Input) GenerateErrorMetrics(a api.Accumulator)

func (*Input) GetDefaultPrefix

func (i *Input) GetDefaultPrefix() string

func (*Input) NetworkMode

func (i *Input) NetworkMode() string

func (*Input) ProcessResponse

func (i *Input) ProcessResponse(_ interface{}, respBytes []byte, err error, accumulator api.Accumulator) error

func (*Input) SerializeRequest

func (i *Input) SerializeRequest() (interface{}, string, []byte, time.Duration, error)