Documentation
¶
Index ¶
- Variables
- type 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
- type UDPStats
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ResultTmpl = `` /* 379-byte string literal not displayed */
)
Functions ¶
This section is empty.
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) 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"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.