http

Documentation

Index

• Constants
• func IsValidWSProto(proto string) bool
• type CustomProbe
  • func NewCustomProbe(xc *app.ExecutionContext, inspector *container.Inspector, ...) (*CustomProbe, error)
  • func (p *CustomProbe) DoneChan() <-chan struct{}
  • func (p *CustomProbe) Start()
• type WebsocketClient
  • func NewWebsocketClient(proto, host, port string) (*WebsocketClient, error)
  • func (wc *WebsocketClient) CheckConnection() error
  • func (wc *WebsocketClient) Connect() error
  • func (wc *WebsocketClient) Disconnect() error
  • func (wc *WebsocketClient) WriteBinary(data []byte) error
  • func (wc *WebsocketClient) WriteString(data string) error
• type WebsocketMessage

Constants

const (
	ProtoWS  = "ws"
	ProtoWSS = "wss"
)

Functions

func IsValidWSProto

func IsValidWSProto(proto string) bool

Types

type CustomProbe

type CustomProbe struct {
	PrintState         bool
	PrintPrefix        string
	Ports              []string
	Cmds               []config.HTTPProbeCmd
	StartWait          int
	RetryCount         int
	RetryWait          int
	TargetPorts        []uint16
	ProbeFull          bool
	ProbeExitOnFailure bool
	APISpecs           []string
	APISpecFiles       []string
	APISpecProbes      []apiSpecInfo
	ProbeApps          []string
	ContainerInspector *container.Inspector
	CallCount          uint64
	ErrCount           uint64
	OkCount            uint64
	// contains filtered or unexported fields
}

CustomProbe is a custom HTTP probe

func NewCustomProbe

func NewCustomProbe(
	xc *app.ExecutionContext,
	inspector *container.Inspector,
	cmds []config.HTTPProbeCmd,
	startWait int,
	retryCount int,
	retryWait int,
	targetPorts []uint16,
	crawlMaxDepth int,
	crawlMaxPageCount int,
	crawlConcurrency int,
	maxConcurrentCrawlers int,
	probeFull bool,
	probeExitOnFailure bool,
	apiSpecs []string,
	apiSpecFiles []string,
	probeApps []string,
	printState bool,
	printPrefix string) (*CustomProbe, error)

NewCustomProbe creates a new custom HTTP probe

func (*CustomProbe) DoneChan

func (p *CustomProbe) DoneChan() <-chan struct{}

DoneChan returns the 'done' channel for the HTTP probe instance

func (*CustomProbe) Start

func (p *CustomProbe) Start()

Start starts the HTTP probe instance execution

type WebsocketClient

type WebsocketClient struct {
	OnRead    func(mtype int, mdata []byte)
	ReadCh    chan WebsocketMessage
	Conn      *websocket.Conn
	ReadCount acounter.Type
	PongCount acounter.Type
	PingCount acounter.Type
	Addr      string
	// contains filtered or unexported fields
}

func NewWebsocketClient

func NewWebsocketClient(proto, host, port string) (*WebsocketClient, error)

func (*WebsocketClient) CheckConnection

func (wc *WebsocketClient) CheckConnection() error

func (*WebsocketClient) Connect

func (wc *WebsocketClient) Connect() error

func (*WebsocketClient) Disconnect

func (wc *WebsocketClient) Disconnect() error

func (*WebsocketClient) WriteBinary

func (wc *WebsocketClient) WriteBinary(data []byte) error

func (*WebsocketClient) WriteString

func (wc *WebsocketClient) WriteString(data string) error

type WebsocketMessage

type WebsocketMessage struct {
	Type int
	Data []byte
}