diag

Documentation

Index

• Variables
• type CaptureHandler
• type CaptureLoader
  • func (z CaptureLoader) Load(handler CaptureHandler) error
• type Endpoint
  • func (z *Endpoint) Exec(c app_control.Control) error
  • func (z *Endpoint) Preset()
  • func (z *Endpoint) Test(c app_control.Control) error
• type EndpointRow
• type MsgLoader
• type Throughput
  • func (z *Throughput) Exec(c app_control.Control) error
  • func (z *Throughput) Preset()
  • func (z *Throughput) Test(c app_control.Control) error
• type ThroughputRow

Variables

var (
	MLoader = app_msg.Apply(&MsgLoader{}).(*MsgLoader)
)

Types

type CaptureHandler

type CaptureHandler func(history app_job.History, rec nw_capture.Record)

type CaptureLoader

type CaptureLoader struct {
	Ctl   app_control.Control
	JobId mo_string.OptionalString
	Path  mo_string.OptionalString
}

func (CaptureLoader) Load

func (z CaptureLoader) Load(handler CaptureHandler) error

type Endpoint

type Endpoint struct {
	rc_recipe.RemarkSecret
	rc_recipe.RemarkConsole
	JobId  mo_string.OptionalString
	Path   mo_string.OptionalString
	Report rp_model.RowReport
	// contains filtered or unexported fields
}

func (*Endpoint) Exec

func (z *Endpoint) Exec(c app_control.Control) error

func (*Endpoint) Preset

func (z *Endpoint) Preset()

func (*Endpoint) Test

func (z *Endpoint) Test(c app_control.Control) error

type EndpointRow

type EndpointRow struct {
	Endpoint     string `json:"endpoint"`
	Count        int    `json:"count"`
	CountSuccess int    `json:"count_success"`
	CountFailure int    `json:"count_failure"`
}

type MsgLoader

type MsgLoader struct {
	ProgressLoadJob app_msg.Message
}

type Throughput

type Throughput struct {
	rc_recipe.RemarkSecret
	rc_recipe.RemarkConsole
	JobId      mo_string.OptionalString
	Path       mo_string.OptionalString
	Endpoint   mo_filter.Filter
	Bucket     int // bucket time in milli seconds
	Report     rp_model.RowReport
	TimeFormat string
	// contains filtered or unexported fields
}

func (*Throughput) Exec

func (z *Throughput) Exec(c app_control.Control) error

func (*Throughput) Preset

func (z *Throughput) Preset()

func (*Throughput) Test

func (z *Throughput) Test(c app_control.Control) error

type ThroughputRow

type ThroughputRow struct {
	Time               string `json:"time"`
	Concurrency        int    `json:"concurrency"`
	SuccessConcurrency int    `json:"success_concurrency"`
	SuccessSent        int64  `json:"success_sent"`
	SuccessReceived    int64  `json:"success_received"`
	FailureConcurrency int    `json:"failure_concurrency"`
	FailureSent        int64  `json:"failure_sent"`
	FailureReceived    int64  `json:"failure_received"`
}