udp

Documentation

Index

• Variables
• type UDPBuilder
  • func NewBuilder() *UDPBuilder
  • func (builder *UDPBuilder) CreateTask(configArgs *config.ProtoConfigArgs) (string, error)
  • func (builder *UDPBuilder) Destroy(obj interface{}) error
  • func (builder *UDPBuilder) Done(total time.Duration) (interface{}, error)
  • func (builder *UDPBuilder) Init(ctx context.Context, taskReq *pb.ExecuteTaskRequest) error
  • func (builder *UDPBuilder) Merge(messages []string) (interface{}, error)
  • func (builder *UDPBuilder) PostRequest(result interface{}) error
  • func (builder *UDPBuilder) PreRequest(taskReq *pb.ExecuteTaskRequest) (interface{}, interface{})
  • func (builder *UDPBuilder) Request(ctx context.Context, obj interface{}, taskReq *pb.ExecuteTaskRequest) interface{}
  • func (builder *UDPBuilder) Split(request *pb.ExecuteTaskRequest, count int) []*pb.ExecuteTaskRequest
• type UDPOptions
  • func NewUDPOptions() *UDPOptions
  • func (udpOptions *UDPOptions) Validate(args []string) error
• type UDPStats

Variables

var (
	ResultTmpl = `` /* 379-byte string literal not displayed */

)

Types

type UDPBuilder

type UDPBuilder struct {
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder() *UDPBuilder

func (*UDPBuilder) CreateTask

func (builder *UDPBuilder) CreateTask(configArgs *config.ProtoConfigArgs) (string, error)

func (*UDPBuilder) Destroy

func (builder *UDPBuilder) Destroy(obj interface{}) error

func (*UDPBuilder) Done

func (builder *UDPBuilder) Done(total time.Duration) (interface{}, error)

func (*UDPBuilder) Init

func (builder *UDPBuilder) Init(ctx context.Context, taskReq *pb.ExecuteTaskRequest) error

func (*UDPBuilder) Merge

func (builder *UDPBuilder) Merge(messages []string) (interface{}, error)

func (*UDPBuilder) PostRequest

func (builder *UDPBuilder) PostRequest(result interface{}) error

func (*UDPBuilder) PreRequest

func (builder *UDPBuilder) PreRequest(taskReq *pb.ExecuteTaskRequest) (interface{}, interface{})

func (*UDPBuilder) Request

func (builder *UDPBuilder) Request(ctx context.Context, obj interface{}, taskReq *pb.ExecuteTaskRequest) interface{}

func (*UDPBuilder) Split

func (builder *UDPBuilder) Split(request *pb.ExecuteTaskRequest, count int) []*pb.ExecuteTaskRequest

type UDPOptions

type UDPOptions struct {
	Addr        string
	Requests    int
	Concurrency int
	Timeout     int
	Duration    int
	MsgLength   int
	MaxResults  int
}

func NewUDPOptions

func NewUDPOptions() *UDPOptions

func (*UDPOptions) Validate

func (udpOptions *UDPOptions) Validate(args []string) error

type UDPStats

type UDPStats struct {
	TotalSize      int64             `json:"totalSize,omitempty"`
	Rps            float64           `json:"rps,omitempty"`
	Duration       float64           `json:"duration,omitempty"`
	TotalDuration  float64           `json:"totalDuration,omitempty"`
	Requests       int64             `json:"requests,omitempty"`
	TotalRequests  int64             `json:"totalRequests,omitempty"`
	TotalResponses int64             `json:"totalResponses,omitempty"`
	AvgSize        int64             `json:"avgSize,omitempty"`
	ErrMap         map[string]uint32 `json:"errMap,omitempty"`
}