miscmanager

Documentation

Index

• Constants
• func Run(configPath string)
• type BaseResponse
• type Config
  • func ParseConfig(configPath string) (*Config, error)
• type CpuBusyContext
• type CpuBusyTestConfig
• type Manager
  • func (m *Manager) Work()
• type PerfTestConfig
• type SampleWorkerReq
• type SampleWorkerRsp
• type ViperTestConfig
• type WorkerContext
• type WorkerRequest

Constants

const (
	ErrCodeOk                   = 0
	ErrCodeFailedToReadBody     = 10000
	ErrCodeFailedToParseBody    = 10001
	ErrCodeTimeout              = 10002
	ErrCodeGeneral              = 10003
	ErrCodeBadFormat            = 10004
	ErrCodeUnexpected           = 10005
	ErrCodeHTTPErr              = 10006
	ErrCodeFailedToParseRspBody = 10007
)

API response error code

const (
	ErrMsgOk                   = "RESULT_OK"
	ErrMsgFailedToReadBody     = "ErrMsgFailedToReadBody"
	ErrMsgFailedToParseBody    = "ErrMsgFailedToParseBody"
	ErrMsgTimeout              = "ErrMsgTimeout"
	ErrMsgGeneral              = "ErrMsgGeneral"
	ErrMsgBadFormat            = "ErrMsgBadFormat"
	ErrMsgUnexpected           = "ErrMsgUnexpected"
	ErrMsgHTTPErr              = "ErrMsgHTTPErr"
	ErrMsgFailedToParseRspBody = "ErrMsgFailedToParseRspBody"
)

API response error info

const (
	KeyErrCode = "err_code"
	KeyErrMsg  = "err_msg"
)

API response key

const (
	ContentTypeJSON = "application/json"
)

Content Types

const (
	ModuleName string = "Misc"
)

ModuleName for log

const (
	RequestSampleWorkerReq = "RequestSampleWorkerReq"
)

Request Type

Functions

func Run

func Run(configPath string)

Run function to start

Types

type BaseResponse

type BaseResponse struct {
	ErrCode   int    `json:"err_code"`
	ErrMsg    string `json:"err_msg"`
	ErrDetail string `json:"err_detail"`
}

BaseResponse definition

type Config

type Config struct {
	ServerAddr string `json:"server_addr"`

	PerfTest    *PerfTestConfig    `json:"perf_test,omitempty"`
	ViperTest   *ViperTestConfig   `json:"viper_test,omitempty"`
	CpuBusyTest *CpuBusyTestConfig `json:"cpu_busy_test,omitempty"`
}

Config config for Generator

func ParseConfig

func ParseConfig(configPath string) (*Config, error)

ParseConfig parse config

type CpuBusyContext

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

CpuBusyContext def

type CpuBusyTestConfig

type CpuBusyTestConfig struct {
	Enabled   bool `json:"enabled"`
	MaxWorker int  `json:"maxworker"`
	Number    int  `json:"number"`
}

CpuBusyTestConfig CPU Busy test config

type Manager

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

Manager def

func (*Manager) Work

func (m *Manager) Work()

Work work according to config

type PerfTestConfig

type PerfTestConfig struct {
	Enabled   bool `json:"enabled"`
	MaxWorker int  `json:"maxworker"`
	Number    int  `json:"number"`
}

PerfTestConfig performance test config

type SampleWorkerReq

type SampleWorkerReq struct {
	GUID     string `json:"guid"`
	RecvTime string `json:"recv_time"`
}

SampleWorkerReq def

type SampleWorkerRsp

type SampleWorkerRsp struct {
	BaseResponse
	GUID         string `json:"guid"`
	RecvTime     string `json:"recv_time"`
	RealRecvTime string `json:"real_recv_time"`
	SendTime     string `json:"send_time"`
}

SampleWorkerRsp def

type ViperTestConfig

type ViperTestConfig struct {
	Enabled bool   `json:"enabled"`
	Key     string `json:"key"`
}

ViperTestConfig viper test config

type WorkerContext

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

WorkerContext def

type WorkerRequest

type WorkerRequest struct {
	Type     string
	GUID     string
	Body     interface{}
	RspChan  chan interface{}
	DoneChan chan bool
}

WorkerRequest request wrapper