server

type AgentStatusResp struct {
	ConnID string `json:"id"`
	Addr   string `json:"addr"`
	Status string `json:"status"`
}

type ClusterInfo struct {
	Data  []AgentStatusResp `json:"data"`
	Error string            `json:"error"`
}

type MasterServer struct {
	ServerBase
	// contains filtered or unexported fields
}

type NodeType int

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

type Server interface {
	Initialize(args *ServerArgs) error
	Start(stopChan <-chan struct{}) error
}

type ServerArgs struct {
	HTTPAddr string // The listening address for http
	GRPCAddr string // The listening address for grpc

	HttpMasterAddr string        // Master's HTTP Address
	GrpcMasterAddr string        // Master's GRPC Address
	ReportInterval time.Duration // Heartbeat reporting interval
	ResultCapacity int
	Args           interface{}
}

type ServerBase struct {
	Mode NodeType
	// contains filtered or unexported fields
}

type SlaveConn struct {
	PeerAddr string

	ConnID   string
	GrpcPort int
	Status   string
	// contains filtered or unexported fields
}

type SlaveServer struct {
	ServerBase
	// contains filtered or unexported fields
}

type SlaveStream interface {
	Send(*pb.HeartBeatResponse) error
	Recv() (*pb.HeartBeatRequest, error)
	grpc.ServerStream
}

type WebServer struct {
	ServerBase
}

type Work struct {
	// Protocol constructor
	Builder build.ProtoBuilder

	// Request task to be executed
	Req *pb.ExecuteTaskRequest

	// Requests is the total number of requests to make.
	Requests int

	// Number of goroutines to run (Concurrent connections)
	Workers int

	Ctx    context.Context
	Cancel context.CancelFunc

	// RateLimit is the rate limit in queries per second.
	RateLimit float64

	// The capacity of the result of the collector channel
	ResultCapacity int
	// contains filtered or unexported fields
}