http

package
v0.0.0-...-b60b6a8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 9, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL