http

Documentation

Index

• Constants
• func IsValidWSProto(proto string) bool
• type CustomProbe
  • func NewContainerProbe(xc *app.ExecutionContext, inspector *container.Inspector, ...) (*CustomProbe, error)
  • func NewPodProbe(xc *app.ExecutionContext, inspector *pod.Inspector, ...) (*CustomProbe, error)
  • func (p *CustomProbe) DoneChan() <-chan struct{}
  • func (p *CustomProbe) Ports() []string
  • 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 {
	APISpecProbes []apiSpecInfo

	CallCount uint64
	ErrCount  uint64
	OkCount   uint64
	// contains filtered or unexported fields
}

CustomProbe is a custom HTTP probe

func NewContainerProbe

func NewContainerProbe(
	xc *app.ExecutionContext,
	inspector *container.Inspector,
	opts config.HTTPProbeOptions,
	printState bool,
) (*CustomProbe, error)

NewContainerProbe creates a new custom HTTP probe

func NewPodProbe

func NewPodProbe(
	xc *app.ExecutionContext,
	inspector *pod.Inspector,
	opts config.HTTPProbeOptions,
	printState bool,
) (*CustomProbe, error)

func (*CustomProbe) DoneChan

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

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

func (*CustomProbe) Ports

func (p *CustomProbe) Ports() []string

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
}