dialtesting

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2023 License: MIT Imports: 27 Imported by: 0

Documentation

Overview

Package dialtesting defined dialtesting tasks and task implements.

Index

Constants

View Source 
const (
	StatusStop = "stop"

	ClassHTTP      = "HTTP"
	ClassTCP       = "TCP"
	ClassWebsocket = "WEBSOCKET"
	ClassICMP      = "ICMP"
	ClassDNS       = "DNS"
	ClassHeadless  = "BROWSER"

	ClassOther = "OTHER"
)
View Source 
const (
	MaxTimeout = 10 * time.Second
	MaxHops    = 60
	MaxRetry   = 3
)
View Source 
const MaxMsgSize = 15 * 1024 * 1024
View Source 
const (
	PingTimeout = 3 * time.Second
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DialResult 

type DialResult struct {
	Success bool
	Reasons []string
}

type HTTPAdvanceOption 

type HTTPAdvanceOption struct {
	RequestOptions *HTTPOptRequest     `json:"request_options,omitempty"`
	RequestBody    *HTTPOptBody        `json:"request_body,omitempty"`
	Certificate    *HTTPOptCertificate `json:"certificate,omitempty"`
	Proxy          *HTTPOptProxy       `json:"proxy,omitempty"`
	Secret         *HTTPSecret         `json:"secret,omitempty"`
}

type HTTPOptAuth 

type HTTPOptAuth struct {
	// basic auth
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type HTTPOptBody 

type HTTPOptBody struct {
	BodyType string `json:"body_type,omitempty"`
	Body     string `json:"body,omitempty"`
}

type HTTPOptCertificate 

type HTTPOptCertificate struct {
	IgnoreServerCertificateError bool   `json:"ignore_server_certificate_error,omitempty"`
	PrivateKey                   string `json:"private_key,omitempty"`
	Certificate                  string `json:"certificate,omitempty"`
	CaCert                       string `json:"ca,omitempty"`
}

type HTTPOptProxy 

type HTTPOptProxy struct {
	URL     string            `json:"url,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
}

type HTTPOptRequest 

type HTTPOptRequest struct {
	FollowRedirect bool              `json:"follow_redirect,omitempty"`
	Headers        map[string]string `json:"headers,omitempty"`
	Cookies        string            `json:"cookies,omitempty"`
	Auth           *HTTPOptAuth      `json:"auth,omitempty"`
}

type HTTPSecret 

type HTTPSecret struct {
	NoSaveResponseBody bool `json:"not_save,omitempty"`
}

type HTTPSuccess 

type HTTPSuccess struct {
	Body []*SuccessOption `json:"body,omitempty"`

	ResponseTime string `json:"response_time,omitempty"`

	Header     map[string][]*SuccessOption `json:"header,omitempty"`
	StatusCode []*SuccessOption            `json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

type HTTPTask 

type HTTPTask struct {
	ExternalID       string             `json:"external_id"`
	Name             string             `json:"name"`
	AK               string             `json:"access_key"`
	Method           string             `json:"method"`
	URL              string             `json:"url"`
	PostURL          string             `json:"post_url"`
	CurStatus        string             `json:"status"`
	Frequency        string             `json:"frequency"`
	Region           string             `json:"region"` // 冗余进来，便于调试
	OwnerExternalID  string             `json:"owner_external_id"`
	SuccessWhenLogic string             `json:"success_when_logic"`
	SuccessWhen      []*HTTPSuccess     `json:"success_when"`
	Tags             map[string]string  `json:"tags,omitempty"`
	Labels           []string           `json:"labels,omitempty"`
	AdvanceOptions   *HTTPAdvanceOption `json:"advance_options,omitempty"`
	UpdateTime       int64              `json:"update_time,omitempty"`
	Option           map[string]string
	// contains filtered or unexported fields
}

func (*HTTPTask) AccessKey 

func (t *HTTPTask) AccessKey() string

func (*HTTPTask) Check 

func (t *HTTPTask) Check() error

func (*HTTPTask) CheckResult 

func (t *HTTPTask) CheckResult() (reasons []string, succFlag bool)

func (*HTTPTask) Class 

func (t *HTTPTask) Class() string

func (*HTTPTask) Clear 

func (t *HTTPTask) Clear()

func (*HTTPTask) GetFrequency 

func (t *HTTPTask) GetFrequency() string

func (*HTTPTask) GetLineData 

func (t *HTTPTask) GetLineData() string

func (*HTTPTask) GetOwnerExternalID 

func (t *HTTPTask) GetOwnerExternalID() string

func (*HTTPTask) GetResults 

func (t *HTTPTask) GetResults() (tags map[string]string, fields map[string]interface{})

func (*HTTPTask) ID 

func (t *HTTPTask) ID() string

func (*HTTPTask) Init 

func (t *HTTPTask) Init() error

func (*HTTPTask) InitDebug 

func (t *HTTPTask) InitDebug() error

func (*HTTPTask) MetricName 

func (t *HTTPTask) MetricName() string

func (*HTTPTask) PostURLStr 

func (t *HTTPTask) PostURLStr() string

func (*HTTPTask) RegionName 

func (t *HTTPTask) RegionName() string

func (*HTTPTask) Run 

func (t *HTTPTask) Run() error

func (*HTTPTask) SetAk 

func (t *HTTPTask) SetAk(ak string)

func (*HTTPTask) SetOwnerExternalID 

func (t *HTTPTask) SetOwnerExternalID(exid string)

func (*HTTPTask) SetRegionID 

func (t *HTTPTask) SetRegionID(regionID string)

func (*HTTPTask) SetStatus 

func (t *HTTPTask) SetStatus(status string)

func (*HTTPTask) SetUpdateTime 

func (t *HTTPTask) SetUpdateTime(ts int64)

func (*HTTPTask) Status 

func (t *HTTPTask) Status() string

func (*HTTPTask) Stop 

func (t *HTTPTask) Stop() error

func (*HTTPTask) Ticker 

func (t *HTTPTask) Ticker() *time.Ticker

func (*HTTPTask) UpdateTimeUs 

func (t *HTTPTask) UpdateTimeUs() int64

type ICMP 

type ICMP struct {
	Type        uint8
	Code        uint8
	Checksum    uint16
	Identifier  uint16
	SequenceNum uint16
}

type ICMPSuccess 

type ICMPSuccess struct {
	PacketLossPercent []*ValueSuccess       `json:"packet_loss_percent,omitempty"`
	ResponseTime      []*ResponseTimeSucess `json:"response_time,omitempty"`
	Hops              []*ValueSuccess       `json:"hops,omitempty"`
	Packets           []*ValueSuccess       `json:"packets,omitempty"`
}

type ICMPTask 

type ICMPTask struct {
	Host             string            `json:"host"`
	PacketCount      int               `json:"packet_count"`
	Timeout          string            `json:"timeout"`
	EnableTraceroute bool              `json:"enable_traceroute"`
	TracerouteConfig *TracerouteOption `json:"traceroute_config"`
	SuccessWhen      []*ICMPSuccess    `json:"success_when"`
	SuccessWhenLogic string            `json:"success_when_logic"`
	ExternalID       string            `json:"external_id"`
	Name             string            `json:"name"`
	AK               string            `json:"access_key"`
	PostURL          string            `json:"post_url"`
	CurStatus        string            `json:"status"`
	Frequency        string            `json:"frequency"`
	Region           string            `json:"region"`
	OwnerExternalID  string            `json:"owner_external_id"`
	Tags             map[string]string `json:"tags,omitempty"`
	Labels           []string          `json:"labels,omitempty"`
	UpdateTime       int64             `json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ICMPTask) AccessKey 

func (t *ICMPTask) AccessKey() string

func (*ICMPTask) Check 

func (t *ICMPTask) Check() error

func (*ICMPTask) CheckResult 

func (t *ICMPTask) CheckResult() (reasons []string, succFlag bool)

func (*ICMPTask) CheckSum 

func (t *ICMPTask) CheckSum(data []byte) (rt uint16)

func (*ICMPTask) Class 

func (t *ICMPTask) Class() string

func (*ICMPTask) Clear 

func (t *ICMPTask) Clear()

func (*ICMPTask) GetFrequency 

func (t *ICMPTask) GetFrequency() string

func (*ICMPTask) GetLineData 

func (t *ICMPTask) GetLineData() string

func (*ICMPTask) GetOwnerExternalID 

func (t *ICMPTask) GetOwnerExternalID() string

func (*ICMPTask) GetResults 

func (t *ICMPTask) GetResults() (tags map[string]string, fields map[string]interface{})

func (*ICMPTask) ID 

func (t *ICMPTask) ID() string

func (*ICMPTask) Init 

func (t *ICMPTask) Init() error

func (*ICMPTask) InitDebug 

func (t *ICMPTask) InitDebug() error

func (*ICMPTask) MetricName 

func (t *ICMPTask) MetricName() string

func (*ICMPTask) PostURLStr 

func (t *ICMPTask) PostURLStr() string

func (*ICMPTask) RegionName 

func (t *ICMPTask) RegionName() string

func (*ICMPTask) Run 

func (t *ICMPTask) Run() error

func (*ICMPTask) SetAk 

func (t *ICMPTask) SetAk(ak string)

func (*ICMPTask) SetOwnerExternalID 

func (t *ICMPTask) SetOwnerExternalID(exid string)

func (*ICMPTask) SetRegionID 

func (t *ICMPTask) SetRegionID(regionID string)

func (*ICMPTask) SetStatus 

func (t *ICMPTask) SetStatus(status string)

func (*ICMPTask) SetUpdateTime 

func (t *ICMPTask) SetUpdateTime(ts int64)

func (*ICMPTask) Status 

func (t *ICMPTask) Status() string

func (*ICMPTask) Stop 

func (t *ICMPTask) Stop() error

func (*ICMPTask) Ticker 

func (t *ICMPTask) Ticker() *time.Ticker

func (*ICMPTask) UpdateTimeUs 

func (t *ICMPTask) UpdateTimeUs() int64

type Packet 

type Packet struct {
	ID  int
	Dst net.IP
	// contains filtered or unexported fields
}

Packet represent sent packet.

type Response 

type Response struct {
	From         net.IP
	ResponseTime time.Duration
	// contains filtered or unexported fields
}

Response for sent packet, may be failed response when timeout.

type ResponseTimeSucess 

type ResponseTimeSucess struct {
	Func   string `json:"func,omitempty"`
	Op     string `json:"op,omitempty"`
	Target string `json:"target,omitempty"`
	// contains filtered or unexported fields
}

type Route 

type Route struct {
	Total   int          `json:"total"`
	Failed  int          `json:"failed"`
	Loss    float64      `json:"loss"`
	AvgCost float64      `json:"avg_cost"`
	MinCost float64      `json:"min_cost"`
	MaxCost float64      `json:"max_cost"`
	StdCost float64      `json:"std_cost"`
	Items   []*RouteItem `json:"items"`
}

Route is summary for each hop.

func TracerouteIP 

func TracerouteIP(ip string, opt *TracerouteOption) (routes []*Route, err error)

type RouteItem 

type RouteItem struct {
	IP           string  `json:"ip"`
	ResponseTime float64 `json:"response_time"`
}

RouteItem represent each retry response.

type SuccessOption 

type SuccessOption struct {
	Is    string `json:"is,omitempty"`
	IsNot string `json:"is_not,omitempty"`

	MatchRegex    string `json:"match_regex,omitempty"`
	NotMatchRegex string `json:"not_match_regex,omitempty"`

	Contains    string `json:"contains,omitempty"`
	NotContains string `json:"not_contains,omitempty"`
	// contains filtered or unexported fields
}

type TCPResponseTime 

type TCPResponseTime struct {
	IsContainDNS bool   `json:"is_contain_dns"`
	Target       string `json:"target"`
	// contains filtered or unexported fields
}

type TCPSuccess 

type TCPSuccess struct {
	ResponseTime []*TCPResponseTime `json:"response_time,omitempty"`
	Hops         []*ValueSuccess    `json:"hops,omitempty"`
}

type TCPTask 

type TCPTask struct {
	Host             string            `json:"host"`
	Port             string            `json:"port"`
	Timeout          string            `json:"timeout"`
	EnableTraceroute bool              `json:"enable_traceroute"`
	TracerouteConfig *TracerouteOption `json:"traceroute_config"`
	SuccessWhen      []*TCPSuccess     `json:"success_when"`
	SuccessWhenLogic string            `json:"success_when_logic"`
	ExternalID       string            `json:"external_id"`
	Name             string            `json:"name"`
	AK               string            `json:"access_key"`
	PostURL          string            `json:"post_url"`
	CurStatus        string            `json:"status"`
	Frequency        string            `json:"frequency"`
	Region           string            `json:"region"`
	OwnerExternalID  string            `json:"owner_external_id"`
	Tags             map[string]string `json:"tags,omitempty"`
	Labels           []string          `json:"labels,omitempty"`
	UpdateTime       int64             `json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*TCPTask) AccessKey 

func (t *TCPTask) AccessKey() string

func (*TCPTask) Check 

func (t *TCPTask) Check() error

func (*TCPTask) CheckResult 

func (t *TCPTask) CheckResult() (reasons []string, succFlag bool)

func (*TCPTask) Class 

func (t *TCPTask) Class() string

func (*TCPTask) Clear 

func (t *TCPTask) Clear()

func (*TCPTask) GetFrequency 

func (t *TCPTask) GetFrequency() string

func (*TCPTask) GetLineData 

func (t *TCPTask) GetLineData() string

func (*TCPTask) GetOwnerExternalID 

func (t *TCPTask) GetOwnerExternalID() string

func (*TCPTask) GetResults 

func (t *TCPTask) GetResults() (tags map[string]string, fields map[string]interface{})

func (*TCPTask) ID 

func (t *TCPTask) ID() string

func (*TCPTask) Init 

func (t *TCPTask) Init() error

func (*TCPTask) InitDebug 

func (t *TCPTask) InitDebug() error

func (*TCPTask) MetricName 

func (t *TCPTask) MetricName() string

func (*TCPTask) PostURLStr 

func (t *TCPTask) PostURLStr() string

func (*TCPTask) RegionName 

func (t *TCPTask) RegionName() string

func (*TCPTask) Run 

func (t *TCPTask) Run() error

func (*TCPTask) SetAk 

func (t *TCPTask) SetAk(ak string)

func (*TCPTask) SetOwnerExternalID 

func (t *TCPTask) SetOwnerExternalID(exid string)

func (*TCPTask) SetRegionID 

func (t *TCPTask) SetRegionID(regionID string)

func (*TCPTask) SetStatus 

func (t *TCPTask) SetStatus(status string)

func (*TCPTask) SetUpdateTime 

func (t *TCPTask) SetUpdateTime(ts int64)

func (*TCPTask) Status 

func (t *TCPTask) Status() string

func (*TCPTask) Stop 

func (t *TCPTask) Stop() error

func (*TCPTask) Ticker 

func (t *TCPTask) Ticker() *time.Ticker

func (*TCPTask) UpdateTimeUs 

func (t *TCPTask) UpdateTimeUs() int64

type Task 

type Task interface {
	ID() string
	Status() string
	Run() error
	Init() error
	InitDebug() error
	CheckResult() ([]string, bool)
	Class() string
	GetResults() (map[string]string, map[string]interface{})
	PostURLStr() string
	MetricName() string
	Stop() error
	RegionName() string
	AccessKey() string
	Check() error
	UpdateTimeUs() int64
	GetFrequency() string
	GetOwnerExternalID() string
	SetOwnerExternalID(string)
	GetLineData() string

	SetRegionID(string)
	SetAk(string)
	SetStatus(string)
	SetUpdateTime(int64)

	Ticker() *time.Ticker
}

type Traceroute 

type Traceroute struct {
	Host    string
	Hops    int
	Retry   int
	Timeout time.Duration
	// contains filtered or unexported fields
}

Traceroute specified host with max hops and timeout.

func (*Traceroute) Run 

func (t *Traceroute) Run() error

type TracerouteOption 

type TracerouteOption struct {
	Hops    int
	Retry   int
	Timeout string
	// contains filtered or unexported fields
}

TracerouteOption represent traceroute option.

type ValueSuccess 

type ValueSuccess struct {
	Op     string  `json:"op,omitempty"`
	Target float64 `json:"target,omitempty"`
}

type WebsocketAdvanceOption 

type WebsocketAdvanceOption struct {
	RequestOptions *WebsocketOptRequest `json:"request_options,omitempty"`
	Auth           *WebsocketOptAuth    `json:"auth,omitempty"`
}

type WebsocketOptAuth 

type WebsocketOptAuth struct {
	// basic auth
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type WebsocketOptRequest 

type WebsocketOptRequest struct {
	Timeout string            `json:"timeout,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
}

type WebsocketResponseTime 

type WebsocketResponseTime struct {
	IsContainDNS bool   `json:"is_contain_dns"`
	Target       string `json:"target"`
	// contains filtered or unexported fields
}

type WebsocketSuccess 

type WebsocketSuccess struct {
	ResponseTime    []*WebsocketResponseTime    `json:"response_time,omitempty"`
	ResponseMessage []*SuccessOption            `json:"response_message,omitempty"`
	Header          map[string][]*SuccessOption `json:"header,omitempty"`
}

type WebsocketTask 

type WebsocketTask struct {
	URL              string                  `json:"url"`
	Message          string                  `json:"message"`
	SuccessWhen      []*WebsocketSuccess     `json:"success_when"`
	AdvanceOptions   *WebsocketAdvanceOption `json:"advance_options,omitempty"`
	SuccessWhenLogic string                  `json:"success_when_logic"`
	ExternalID       string                  `json:"external_id"`
	Name             string                  `json:"name"`
	AK               string                  `json:"access_key"`
	PostURL          string                  `json:"post_url"`
	CurStatus        string                  `json:"status"`
	Frequency        string                  `json:"frequency"`
	Region           string                  `json:"region"`
	OwnerExternalID  string                  `json:"owner_external_id"`
	Tags             map[string]string       `json:"tags,omitempty"`
	Labels           []string                `json:"labels,omitempty"`
	UpdateTime       int64                   `json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

func (*WebsocketTask) AccessKey 

func (t *WebsocketTask) AccessKey() string

func (*WebsocketTask) Check 

func (t *WebsocketTask) Check() error

func (*WebsocketTask) CheckResult 

func (t *WebsocketTask) CheckResult() (reasons []string, succFlag bool)

func (*WebsocketTask) Class 

func (t *WebsocketTask) Class() string

func (*WebsocketTask) Clear 

func (t *WebsocketTask) Clear()

func (*WebsocketTask) GetFrequency 

func (t *WebsocketTask) GetFrequency() string

func (*WebsocketTask) GetLineData 

func (t *WebsocketTask) GetLineData() string

func (*WebsocketTask) GetOwnerExternalID 

func (t *WebsocketTask) GetOwnerExternalID() string

func (*WebsocketTask) GetResults 

func (t *WebsocketTask) GetResults() (tags map[string]string, fields map[string]interface{})

func (*WebsocketTask) ID 

func (t *WebsocketTask) ID() string

func (*WebsocketTask) Init 

func (t *WebsocketTask) Init() error

func (*WebsocketTask) InitDebug 

func (t *WebsocketTask) InitDebug() error

func (*WebsocketTask) MetricName 

func (t *WebsocketTask) MetricName() string

func (*WebsocketTask) PostURLStr 

func (t *WebsocketTask) PostURLStr() string

func (*WebsocketTask) RegionName 

func (t *WebsocketTask) RegionName() string

func (*WebsocketTask) Run 

func (t *WebsocketTask) Run() error

func (*WebsocketTask) SetAk 

func (t *WebsocketTask) SetAk(ak string)

func (*WebsocketTask) SetOwnerExternalID 

func (t *WebsocketTask) SetOwnerExternalID(exid string)

func (*WebsocketTask) SetRegionID 

func (t *WebsocketTask) SetRegionID(regionID string)

func (*WebsocketTask) SetStatus 

func (t *WebsocketTask) SetStatus(status string)

func (*WebsocketTask) SetUpdateTime 

func (t *WebsocketTask) SetUpdateTime(ts int64)

func (*WebsocketTask) Status 

func (t *WebsocketTask) Status() string

func (*WebsocketTask) Stop 

func (t *WebsocketTask) Stop() error

func (*WebsocketTask) Ticker 

func (t *WebsocketTask) Ticker() *time.Ticker

func (*WebsocketTask) UpdateTimeUs 

func (t *WebsocketTask) UpdateTimeUs() int64

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.