websocket

Documentation

Index

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

Variables

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

)

Types

type WebSocketBuilder

type WebSocketBuilder struct {
	Conn *websocket.Conn
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder() *WebSocketBuilder

func (*WebSocketBuilder) CreateTask

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

func (*WebSocketBuilder) Destroy

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

func (*WebSocketBuilder) Done

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

func (*WebSocketBuilder) Init

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

func (*WebSocketBuilder) Merge

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

func (*WebSocketBuilder) PostRequest

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

func (*WebSocketBuilder) PreRequest

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

func (*WebSocketBuilder) Request

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

func (*WebSocketBuilder) Split

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

type WebsocketStats

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

type WsOptions

type WsOptions struct {
	Scheme      string `json:"scheme,omitempty"`
	Host        string `json:"host,omitempty"`
	Path        string `json:"path,omitempty"`
	Requests    int    `json:"requests,omitempty"`
	Concurrency int    `json:"concurrency,omitempty"`
	Timeout     int    `json:"timeout,omitempty"`
	Duration    int    `json:"duration,omitempty"`
	Body        string `json:"body,omitempty"`
	MaxResults  int    `json:"maxResults,omitempty"`
}

WsOptions contains websocket protocol runtime parameters

func NewWsOptions

func NewWsOptions() *WsOptions

func (*WsOptions) Validate

func (wsOptions *WsOptions) Validate(args []string) error