dialtesting

type ConfigVar struct {
	ID      string `json:"id,omitempty"`
	Type    string `json:"type,omitempty"`
	Name    string `json:"name"`
	Value   string `json:"value,omitempty"`
	Example string `json:"example,omitempty"`
	Secure  bool   `json:"secure"`
}

type DialResult struct {
	Success bool
	Reasons []string
}

type GRPCAdvanceOption struct {
	RequestOptions *GRPCOptRequest     `json:"request_options,omitempty"`
	Certificate    *GRPCOptCertificate `json:"certificate,omitempty"`
	Secret         *GRPCSecret         `json:"secret,omitempty"`
}

type GRPCHealthCheckDiscovery struct {
	Service string `json:"service,omitempty"`
}

type GRPCOptCertificate 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 GRPCOptRequest struct {
	Metadata       map[string]string         `json:"metadata,omitempty"`
	RequestTimeout string                    `json:"request_timeout,omitempty"`
	ProtoFiles     *GRPCProtoFilesDiscovery  `json:"proto_files,omitempty"`
	Reflection     *GRPCReflectionDiscovery  `json:"reflection,omitempty"`
	HealthCheck    *GRPCHealthCheckDiscovery `json:"health_check,omitempty"`
}

type GRPCProtoFilesDiscovery struct {
	ProtoFiles  map[string]string `json:"protofiles"`
	FullMethod  string            `json:"full_method"`
	JSONRequest string            `json:"request,omitempty"`
}

type GRPCReflectionDiscovery struct {
	FullMethod  string `json:"full_method"`
	JSONRequest string `json:"request,omitempty"`
}

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

type GRPCSuccess struct {
	Body         []*SuccessOption `json:"body,omitempty"`
	ResponseTime string           `json:"response_time,omitempty"`
	// contains filtered or unexported fields
}

type GRPCTask struct {
	*Task
	Server           string             `json:"server"`
	PostScript       string             `json:"post_script,omitempty"`
	SuccessWhenLogic string             `json:"success_when_logic"`
	SuccessWhen      []*GRPCSuccess     `json:"success_when"`
	AdvanceOptions   *GRPCAdvanceOption `json:"advance_options,omitempty"`
	// contains filtered or unexported fields
}

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"`
	RequestTimeout string              `json:"request_timeout,omitempty"`
}

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

type HTTPOptBody struct {
	BodyType string            `json:"body_type,omitempty"`
	Body     string            `json:"body,omitempty"`
	Files    []HTTPOptBodyFile `json:"files,omitempty"`
	Form     map[string]string `json:"form,omitempty"`
	// contains filtered or unexported fields
}

type HTTPOptBodyFile struct {
	Name             string `json:"name"`                // field name
	Content          string `json:"content"`             // file content in base64
	Type             string `json:"type"`                // file type, e.g. image/jpeg
	Size             int64  `json:"size"`                // Content size
	Encoding         string `json:"encoding"`            // Content encoding, base64 only
	OriginalFileName string `json:"original_file_name"`  // Original file name
	FilePath         string `json:"file_path,omitempty"` // file path in storage

	Hash string `json:"_"`
}

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 struct {
	URL     string            `json:"url,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
}

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 struct {
	NoSaveResponseBody bool `json:"not_save,omitempty"`
}

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 struct {
	*Task
	URL              string             `json:"url"`
	Method           string             `json:"method"`
	PostScript       string             `json:"post_script,omitempty"`
	SuccessWhenLogic string             `json:"success_when_logic"`
	SuccessWhen      []*HTTPSuccess     `json:"success_when"`
	AdvanceOptions   *HTTPAdvanceOption `json:"advance_options,omitempty"`
	// contains filtered or unexported fields
}

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

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 struct {
	*Task
	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"`
	// contains filtered or unexported fields
}

type ITask interface {
	ID() string
	Status() string
	Run() error
	Clear()
	CheckResult() ([]string, bool)
	Class() string
	GetResults() (map[string]string, map[string]interface{})
	PostURLStr() string
	MetricName() string
	Stop()
	RegionName() string
	AccessKey() string
	Check() error
	CheckTask() error
	UpdateTimeUs() int64
	GetFrequency() string
	GetOwnerExternalID() string
	GetExternalID() string
	SetOwnerExternalID(string)
	GetLineData() string
	GetHostName() ([]string, error)
	GetWorkspaceLanguage() string
	GetDFLabel() string
	GetScheduleType() string
	GetCrontab() string

	SetOption(map[string]string)
	GetOption() map[string]string
	SetRegionID(string)
	SetAk(string)
	SetStatus(string)
	SetUpdateTime(int64)
	SetChild(TaskChild)
	SetTaskJSONString(string)
	GetTaskJSONString() string
	SetDisabled(uint8)

	GetVariableValue(Variable) (string, error)
	GetGlobalVars() []string
	RenderTemplateAndInit(globalVariables map[string]Variable) error
	AddExtractedVar(*ConfigVar)
	SetCustomVars([]*ConfigVar)
	GetPostScriptVars() Vars
	GetIsTemplate() bool
	SetIsTemplate(bool)
	SetBeforeRun(func(*Task) error)

	String() string
}

type MultiExtractedVar struct {
	Name   string `json:"name"`
	Field  string `json:"field"`
	Secure bool   `json:"secure"`
	Value  string `json:"value,omitempty"`
}

type MultiStep struct {
	Type          string              `json:"type"` // http or wait
	Name          string              `json:"name"` // name
	AllowFailure  bool                `json:"allow_failure"`
	Retry         *MultiStepRetry     `json:"retry"`
	TaskString    string              `json:"task,omitempty"`
	Value         int                 `json:"value,omitempty"` // wait seconds for wait task
	ExtractedVars []MultiExtractedVar `json:"extracted_vars,omitempty"`
	// contains filtered or unexported fields
}

type MultiStepRetry struct {
	Retry    int `json:"retry"`    // retry times
	Interval int `json:"interval"` // ms
}

type MultiTask struct {
	*Task
	Steps []*MultiStep `json:"steps"`
	// contains filtered or unexported fields
}

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

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

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 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"`
}

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

type ScriptGRPCMessage struct {
	Response *ScriptGRPCRequestResponse `json:"response"`
	Vars     *Vars                      `json:"vars"`
}

type ScriptGRPCRequestResponse struct {
	Body string `json:"body"`
}

type ScriptHTTPMessage struct {
	Response *ScriptHTTPRequestResponse `json:"response"`
	Vars     *Vars                      `json:"vars"`
}

type ScriptHTTPRequestResponse struct {
	Header     http.Header `json:"header"`
	Body       string      `json:"body"`
	StatusCode int         `json:"status_code"`
}

type ScriptHTTPResult struct {
	IsFailed     bool   `json:"is_failed"`
	ErrorMessage string `json:"error_message"`
}

type ScriptResult struct {
	Result ScriptHTTPResult `json:"result"`
	Vars   Vars             `json:"vars"`
}

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 struct {
	IsContainDNS bool   `json:"is_contain_dns"`
	Target       string `json:"target"`
	// contains filtered or unexported fields
}

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

type TCPTask struct {
	*Task
	Host             string            `json:"host"`
	Port             string            `json:"port"`
	Message          string            `json:"message"`
	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"`
	// contains filtered or unexported fields
}

type Task struct {
	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"`
	WorkspaceLanguage string `json:"workspace_language,omitempty"`
	TagsInfo          string `json:"tags_info,omitempty"` // deprecated
	DFLabel           string `json:"df_label,omitempty"`
	ScheduleType      string `json:"schedule_type,omitempty"` // "frequency" or "crontab"
	Crontab           string `json:"crontab,omitempty"`       // crontab expression like "0 0 * * *"

	Tags          map[string]string `json:"tags,omitempty"`
	Labels        []string          `json:"labels,omitempty"`
	UpdateTime    int64             `json:"update_time,omitempty"`
	ConfigVars    []*ConfigVar      `json:"config_vars,omitempty"`
	ExtractedVars []*ConfigVar
	CustomVars    []*ConfigVar

	Disabled uint8 `json:"disabled"`
	// contains filtered or unexported fields
}

type TaskChild interface {
	ITask
	// contains filtered or unexported methods
}

type TaskConfig struct {
	MaxMsgSize        int `json:"max_msg_size,omitempty"`
	MaxICMPConcurrent int `json:"max_icmp_concurrent,omitempty"`
	Logger            *log.Logger
}

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

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

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

type Variable struct {
	ID          int    `json:"id,omitempty"`
	Name        string `json:"name,omitempty"`
	UUID        string `json:"uuid,omitempty"`
	TaskID      string `json:"task_id,omitempty"`
	TaskVarName string `json:"task_var_name,omitempty"`
	Value       string `json:"value,omitempty"`
	Secure      bool   `json:"secure,omitempty"`
	PostScript  string `json:"post_script,omitempty"`

	UpdatedAt       int64  `json:"updated_at,omitempty"`       // update time
	ValueUpdatedAt  int64  `json:"value_updated_at,omitempty"` // update value time
	FailCount       int    `json:"fail_count,omitempty"`       // update fail count
	DeletedAt       int64  `json:"deleted_at,omitempty"`
	OwnerExternalID string `json:"owner_external_id,omitempty"`
	CreatedAt       int64  `json:"-"`
}

type Vars map[string]interface{}

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

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

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

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

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

type WebsocketTask struct {
	*Task
	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"`
	// contains filtered or unexported fields
}