Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use New method of dashapi Package

Best Syzkaller code snippet using dashapi.New

proxy.go

Source:proxy.go

...24	"github.com/google/syzkaller/dashboard/dashapi"25	"github.com/prometheus/client_golang/prometheus/promhttp"26)27var (28	errUnknownMethod = errors.New("unknown method")29)30// Proxy is a syzkaller dashboard proxy.31type Proxy interface {32	Proxy(*gin.Context)33	Metrics(*gin.Context)34}35type proxy struct {36	dashMu sync.RWMutex37	dashes map[string]*dashapi.Dashboard38}39// New returns a new proxy40func New(forward []string) Proxy {41	dashes := map[string]*dashapi.Dashboard{}42	for _, f := range forward {43		dashes[f] = dashapi.New("proxy", f, "")44	}45	return &proxy{46		dashes: dashes,47	}48}49// Metrics implements the metrics interface.50func (p *proxy) Metrics(c *gin.Context) {51	promhttp.Handler().ServeHTTP(c.Writer, c.Request)52}53// Proxy implements the Proxy interface.54func (p *proxy) Proxy(c *gin.Context) {55	client := c.PostForm("client")56	key := c.PostForm("key")57	method := c.PostForm("method")58	fmt.Printf("client: %q, key: %q, method: %q", client, key, method)59	switch method {60	case "upload_build":61		p.uploadBuild(c, client, key)62	case "builder_poll":63		p.builderPoll(c, client, key)64	case "job_poll":65		p.jobPoll(c, client, key)66	case "job_done":67		p.jobDone(c, client, key)68	case "report_build_error":69		p.reportBuildError(c, client, key)70	case "commit_poll":71		p.commitPoll(c, client, key)72	case "upload_commits":73		p.uploadCommits(c, client, key)74	case "report_crash":75		p.reportCrash(c, client, key)76	case "need_repro":77		p.needRepro(c, client, key)78	case "report_failed_repro":79		p.reportFailedRepro(c, client, key)80	case "log_error":81		p.logError(c, client, key)82	case "reporting_poll_bugs":83		p.reportingPollBugs(c, client, key)84	case "reporting_poll_notifs":85		p.reportingPollNotifs(c, client, key)86	case "reporting_poll_closed":87		p.reportingPollClosed(c, client, key)88	case "reporting_update":89		p.reportingUpdate(c, client, key)90	case "manager_stats":91		p.managerStats(c, client, key)92		rpcCounters.WithLabelValues(client, method).Inc()93		return94	case "bug_list":95		p.bugList(c, client, key)96	case "load_bug":97		p.loadBug(c, client, key)98	default:99		rpcCounters.WithLabelValues(client, "invalid").Inc()100		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})101		return102	}103	rpcCounters.WithLabelValues(client, method).Inc()104}105func (p *proxy) uploadBuild(c *gin.Context, client, key string) {106	var (107		build dashapi.Build108		// Payload is gzip'd json.109		payload = c.PostForm("payload")110		buf     = bytes.NewBufferString(payload)111	)112	r, err := gzip.NewReader(buf)113	if err != nil {114		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})115		return116	}117	d := json.NewDecoder(r)118	if err := d.Decode(&build); err != nil {119		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})120		return121	}122	if err := r.Close(); err != nil {123		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})124		return125	}126	p.dashMu.RLock()127	for _, dash := range p.dashes {128		err := dash.UploadBuild(&build)129		if err != nil {130			p.dashMu.RUnlock()131			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})132			return133		}134	}135	p.dashMu.RUnlock()136}137func (p *proxy) builderPoll(c *gin.Context, client, key string) {138	var (139		pollReq dashapi.BuilderPollReq140		payload = c.PostForm("payload")141		buf     = bytes.NewBufferString(payload)142	)143	r, err := gzip.NewReader(buf)144	if err != nil {145		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})146		return147	}148	d := json.NewDecoder(r)149	if err := d.Decode(&pollReq); err != nil {150		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})151		return152	}153	if err := r.Close(); err != nil {154		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})155		return156	}157	p.dashMu.RLock()158	for _, dash := range p.dashes {159		_, err := dash.BuilderPoll(pollReq.Manager)160		if err != nil {161			p.dashMu.RUnlock()162			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})163			return164		}165	}166	p.dashMu.RUnlock()167}168func (p *proxy) jobPoll(c *gin.Context, client, key string) {169	var (170		jobPollReq dashapi.JobPollReq171		payload    = c.PostForm("payload")172		buf        = bytes.NewBufferString(payload)173	)174	r, err := gzip.NewReader(buf)175	if err != nil {176		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})177		return178	}179	d := json.NewDecoder(r)180	if err := d.Decode(&jobPollReq); err != nil {181		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})182		return183	}184	if err := r.Close(); err != nil {185		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})186		return187	}188	p.dashMu.RLock()189	for _, dash := range p.dashes {190		_, err := dash.JobPoll(&jobPollReq)191		if err != nil {192			p.dashMu.RUnlock()193			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})194			return195		}196	}197	p.dashMu.RUnlock()198}199func (p *proxy) jobDone(c *gin.Context, client, key string) {200	var (201		jobDoneReq dashapi.JobDoneReq202		payload    = c.PostForm("payload")203		buf        = bytes.NewBufferString(payload)204	)205	r, err := gzip.NewReader(buf)206	if err != nil {207		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})208		return209	}210	d := json.NewDecoder(r)211	if err := d.Decode(&jobDoneReq); err != nil {212		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})213		return214	}215	if err := r.Close(); err != nil {216		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})217		return218	}219	p.dashMu.RLock()220	for _, dash := range p.dashes {221		err := dash.JobDone(&jobDoneReq)222		if err != nil {223			p.dashMu.RUnlock()224			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})225			return226		}227	}228	p.dashMu.RUnlock()229}230func (p *proxy) reportBuildError(c *gin.Context, client, key string) {231	var (232		buildErrReq dashapi.BuildErrorReq233		payload     = c.PostForm("payload")234		buf         = bytes.NewBufferString(payload)235	)236	r, err := gzip.NewReader(buf)237	if err != nil {238		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})239		return240	}241	d := json.NewDecoder(r)242	if err := d.Decode(&buildErrReq); err != nil {243		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})244		return245	}246	if err := r.Close(); err != nil {247		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})248		return249	}250	p.dashMu.RLock()251	for _, dash := range p.dashes {252		err := dash.ReportBuildError(&buildErrReq)253		if err != nil {254			p.dashMu.RUnlock()255			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})256			return257		}258	}259	p.dashMu.RUnlock()260}261func (p *proxy) commitPoll(c *gin.Context, client, key string) {262	p.dashMu.RLock()263	for _, dash := range p.dashes {264		_, err := dash.CommitPoll()265		if err != nil {266			p.dashMu.RUnlock()267			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})268			return269		}270	}271	p.dashMu.RUnlock()272}273func (p *proxy) uploadCommits(c *gin.Context, client, key string) {274	var (275		req     dashapi.CommitPollResultReq276		payload = c.PostForm("payload")277		buf     = bytes.NewBufferString(payload)278	)279	r, err := gzip.NewReader(buf)280	if err != nil {281		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})282		return283	}284	d := json.NewDecoder(r)285	if err := d.Decode(&req); err != nil {286		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})287		return288	}289	if err := r.Close(); err != nil {290		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})291		return292	}293	p.dashMu.RLock()294	for _, dash := range p.dashes {295		err := dash.UploadCommits(req.Commits)296		if err != nil {297			p.dashMu.RUnlock()298			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})299			return300		}301	}302	p.dashMu.RUnlock()303}304func (p *proxy) reportCrash(c *gin.Context, client, key string) {305	var (306		req     dashapi.Crash307		payload = c.PostForm("payload")308		buf     = bytes.NewBufferString(payload)309	)310	r, err := gzip.NewReader(buf)311	if err != nil {312		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})313		return314	}315	d := json.NewDecoder(r)316	if err := d.Decode(&req); err != nil {317		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})318		return319	}320	if err := r.Close(); err != nil {321		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})322		return323	}324	p.dashMu.RLock()325	for _, dash := range p.dashes {326		_, err := dash.ReportCrash(&req)327		if err != nil {328			p.dashMu.RUnlock()329			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})330			return331		}332	}333	p.dashMu.RUnlock()334}335func (p *proxy) needRepro(c *gin.Context, client, key string) {336	var (337		req     dashapi.CrashID338		payload = c.PostForm("payload")339		buf     = bytes.NewBufferString(payload)340	)341	r, err := gzip.NewReader(buf)342	if err != nil {343		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})344		return345	}346	d := json.NewDecoder(r)347	if err := d.Decode(&req); err != nil {348		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})349		return350	}351	if err := r.Close(); err != nil {352		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})353		return354	}355	p.dashMu.RLock()356	for _, dash := range p.dashes {357		_, err := dash.NeedRepro(&req)358		if err != nil {359			p.dashMu.RUnlock()360			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})361			return362		}363	}364	p.dashMu.RUnlock()365}366func (p *proxy) reportFailedRepro(c *gin.Context, client, key string) {367	var (368		req     dashapi.CrashID369		payload = c.PostForm("payload")370		buf     = bytes.NewBufferString(payload)371	)372	r, err := gzip.NewReader(buf)373	if err != nil {374		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})375		return376	}377	d := json.NewDecoder(r)378	if err := d.Decode(&req); err != nil {379		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})380		return381	}382	if err := r.Close(); err != nil {383		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})384		return385	}386	p.dashMu.RLock()387	for _, dash := range p.dashes {388		err := dash.ReportFailedRepro(&req)389		if err != nil {390			p.dashMu.RUnlock()391			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})392			return393		}394	}395	p.dashMu.RUnlock()396}397func (p *proxy) logError(c *gin.Context, client, key string) {398	var (399		req     dashapi.LogEntry400		payload = c.PostForm("payload")401		buf     = bytes.NewBufferString(payload)402	)403	r, err := gzip.NewReader(buf)404	if err != nil {405		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})406		return407	}408	d := json.NewDecoder(r)409	if err := d.Decode(&req); err != nil {410		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})411		return412	}413	if err := r.Close(); err != nil {414		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})415		return416	}417	p.dashMu.RLock()418	for _, dash := range p.dashes {419		dash.LogError(req.Name, req.Text)420	}421	p.dashMu.RUnlock()422}423func (p *proxy) reportingPollBugs(c *gin.Context, client, key string) {424	var (425		req     dashapi.PollBugsRequest426		payload = c.PostForm("payload")427		buf     = bytes.NewBufferString(payload)428	)429	r, err := gzip.NewReader(buf)430	if err != nil {431		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})432		return433	}434	d := json.NewDecoder(r)435	if err := d.Decode(&req); err != nil {436		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})437		return438	}439	if err := r.Close(); err != nil {440		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})441		return442	}443	p.dashMu.RLock()444	for _, dash := range p.dashes {445		_, err := dash.ReportingPollBugs(req.Type)446		if err != nil {447			p.dashMu.RUnlock()448			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})449			return450		}451	}452	p.dashMu.RUnlock()453}454func (p *proxy) reportingPollNotifs(c *gin.Context, client, key string) {455	var (456		req     dashapi.PollNotificationsRequest457		payload = c.PostForm("payload")458		buf     = bytes.NewBufferString(payload)459	)460	r, err := gzip.NewReader(buf)461	if err != nil {462		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})463		return464	}465	d := json.NewDecoder(r)466	if err := d.Decode(&req); err != nil {467		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})468		return469	}470	if err := r.Close(); err != nil {471		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})472		return473	}474	p.dashMu.RLock()475	for _, dash := range p.dashes {476		_, err := dash.ReportingPollNotifications(req.Type)477		if err != nil {478			p.dashMu.RUnlock()479			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})480			return481		}482	}483	p.dashMu.RUnlock()484}485func (p *proxy) reportingPollClosed(c *gin.Context, client, key string) {486	var (487		req     dashapi.PollClosedRequest488		payload = c.PostForm("payload")489		buf     = bytes.NewBufferString(payload)490	)491	r, err := gzip.NewReader(buf)492	if err != nil {493		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})494		return495	}496	d := json.NewDecoder(r)497	if err := d.Decode(&req); err != nil {498		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})499		return500	}501	if err := r.Close(); err != nil {502		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})503		return504	}505	p.dashMu.RLock()506	for _, dash := range p.dashes {507		_, err := dash.ReportingPollClosed(req.IDs)508		if err != nil {509			p.dashMu.RUnlock()510			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})511			return512		}513	}514	p.dashMu.RUnlock()515}516func (p *proxy) reportingUpdate(c *gin.Context, client, key string) {517	var (518		req     dashapi.BugUpdate519		payload = c.PostForm("payload")520		buf     = bytes.NewBufferString(payload)521	)522	r, err := gzip.NewReader(buf)523	if err != nil {524		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})525		return526	}527	d := json.NewDecoder(r)528	if err := d.Decode(&req); err != nil {529		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})530		return531	}532	if err := r.Close(); err != nil {533		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})534		return535	}536	p.dashMu.RLock()537	for _, dash := range p.dashes {538		_, err := dash.ReportingUpdate(&req)539		if err != nil {540			p.dashMu.RUnlock()541			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})542			return543		}544	}545	p.dashMu.RUnlock()546}547func (p *proxy) managerStats(c *gin.Context, client, key string) {548	var (549		req     dashapi.ManagerStatsReq550		payload = c.PostForm("payload")551		buf     = bytes.NewBufferString(payload)552	)553	r, err := gzip.NewReader(buf)554	if err != nil {555		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})556		return557	}558	d := json.NewDecoder(r)559	if err := d.Decode(&req); err != nil {560		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})561		return562	}563	if err := r.Close(); err != nil {564		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})565		return566	}567	managerUptimeGauges.WithLabelValues(req.Name).Set(float64(req.UpTime))568	managerCorpusGauges.WithLabelValues(req.Name).Set(float64(req.Corpus))569	managerPCsGauges.WithLabelValues(req.Name).Set(float64(req.PCs))570	managerCoverageGauges.WithLabelValues(req.Name).Set(float64(req.Cover))571	managerCrashesCounters.WithLabelValues(req.Name).Add(float64(req.Crashes))572	managerExecsCounters.WithLabelValues(req.Name).Add(float64(req.Execs))573	managerSuppCrashesCounters.WithLabelValues(req.Name).Add(float64(req.SuppressedCrashes))574	managerFuzzingDurCounters.WithLabelValues(req.Name).Add(float64(req.FuzzingTime))575	p.dashMu.RLock()576	for _, dash := range p.dashes {577		err := dash.UploadManagerStats(&req)578		if err != nil {579			p.dashMu.RUnlock()580			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})581			return582		}583	}584	p.dashMu.RUnlock()585}586func (p *proxy) bugList(c *gin.Context, client, key string) {587	p.dashMu.RLock()588	for _, dash := range p.dashes {589		_, err := dash.BugList()590		if err != nil {591			p.dashMu.RUnlock()592			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})593			return594		}595	}596	p.dashMu.RUnlock()597}598func (p *proxy) loadBug(c *gin.Context, client, key string) {599	var (600		req     dashapi.LoadBugReq601		payload = c.PostForm("payload")602		buf     = bytes.NewBufferString(payload)603	)604	r, err := gzip.NewReader(buf)605	if err != nil {606		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})607		return608	}609	d := json.NewDecoder(r)610	if err := d.Decode(&req); err != nil {611		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})612		return613	}614	if err := r.Close(); err != nil {615		c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})616		return617	}618	p.dashMu.RLock()619	for _, dash := range p.dashes {620		_, err := dash.LoadBug(req.ID)621		if err != nil {622			p.dashMu.RUnlock()623			c.JSON(http.StatusBadRequest, gin.H{"error": errUnknownMethod.Error()})...

metrics.go

Source:metrics.go

...13// limitations under the License.14package proxy15import "github.com/prometheus/client_golang/prometheus"16var (17	rpcCounters = prometheus.NewCounterVec(18		prometheus.CounterOpts{19			Name: "requests_total",20			Help: "Number of requests.",21		},22		[]string{"client", "method"},23	)24)25// dashapi.Build metrics26var (27	buildCounters = prometheus.NewCounterVec(28		prometheus.CounterOpts{29			Name: "builds_total",30			Help: "Number of builds.",31		},32		[]string{"manager", "id", "os", "arch", "vmarch"},33	)34)35// dashapi.JobPollReq metrics36var (37	jobPollCounters = prometheus.NewCounterVec(38		prometheus.CounterOpts{39			Name: "job_poll_total",40			Help: "Number of job polls.",41		},42		[]string{"manager"},43	)44)45// dashapi.JobDoneReq metrics46var (47	jobDoneCounters = prometheus.NewCounterVec(48		prometheus.CounterOpts{49			Name: "job_done_total",50			Help: "Number of jobs completed.",51		},52		[]string{"id", "manager", "build_id", "os", "arch", "vmarch"},53	)54)55// dashapi.BuildErrorReq metrics56var (57	buildErrorCounters = prometheus.NewCounterVec(58		prometheus.CounterOpts{59			Name: "build_error_total",60			Help: "Number of job build errors.",61		},62		[]string{"manager", "id", "os", "arch", "vmarch"},63	)64)65// dashapi.ManagerStatsReq metrics66var (67	managerUptimeGauges = prometheus.NewGaugeVec(68		prometheus.GaugeOpts{69			Name: "manager_uptime_total",70			Help: "Manager uptime.",71		},72		[]string{"manager"},73	)74	managerCorpusGauges = prometheus.NewGaugeVec(75		prometheus.GaugeOpts{76			Name: "manager_corpus_total",77			Help: "Manager corpus total.",78		},79		[]string{"manager"},80	)81	managerPCsGauges = prometheus.NewGaugeVec(82		prometheus.GaugeOpts{83			Name: "manager_pcs_total",84			Help: "Manager pcs total.",85		},86		[]string{"manager"},87	)88	managerCoverageGauges = prometheus.NewGaugeVec(89		prometheus.GaugeOpts{90			Name: "manager_coverage_total",91			Help: "Manager coverage total.",92		},93		[]string{"manager"},94	)95	managerCrashesCounters = prometheus.NewCounterVec(96		prometheus.CounterOpts{97			Name: "manager_crashes_total",98			Help: "Manager crashes total.",99		},100		[]string{"manager"},101	)102	managerSuppCrashesCounters = prometheus.NewCounterVec(103		prometheus.CounterOpts{104			Name: "manager_supp_crashes_total",105			Help: "Manager suppressed crashes total.",106		},107		[]string{"manager"},108	)109	managerExecsCounters = prometheus.NewCounterVec(110		prometheus.CounterOpts{111			Name: "manager_execs_total",112			Help: "Manager execs total.",113		},114		[]string{"manager"},115	)116	managerFuzzingDurCounters = prometheus.NewCounterVec(117		prometheus.CounterOpts{118			Name: "manager_fuzzing_dur_total",119			Help: "Manager fuzzing duration total.",120		},121		[]string{"manager"},122	)123)124func init() {125	prometheus.MustRegister(rpcCounters)126	prometheus.MustRegister(buildCounters)127	prometheus.MustRegister(jobPollCounters)128	prometheus.MustRegister(buildErrorCounters)129	prometheus.MustRegister(managerUptimeGauges)130	prometheus.MustRegister(managerCorpusGauges)...

main.go

Source:main.go

...24func main() {25	// Define Fiber config.26	config := configs.FiberConfig()27	// Define a new Fiber app with config.28	app := fiber.New(config)29	// Middlewares.30	middleware.FiberMiddleware(app) // Register Fiber's middleware for app.31	// Routes.32	routes.SwaggerRoute(app)  // Register a route for API Docs (Swagger).33	routes.PublicRoutes(app)  // Register a public routes for app.34	routes.PrivateRoutes(app) // Register a private routes for app.35	routes.NotFoundRoute(app) // Register route for 404 Error.36	// Start server (with or without graceful shutdown).37	if os.Getenv("STAGE_STATUS") == "dev" {38		utils.StartServer(app)39	} else {40		utils.StartServerWithGracefulShutdown(app)41	}42}...

New

Using AI Code Generation

1import (2func init() {3	orm.RegisterModel(new(models.Dashapi))4	orm.RegisterDataBase("default", "sqlite3", "database.db")5	orm.RunSyncdb("default", false, true)6}7func main() {8	o := orm.NewOrm()9	id, err := o.Insert(&dashapi)10	fmt.Printf("ID: %d, ERR: %v11	num, err := o.Update(&dashapi)12	fmt.Printf("NUM: %d, ERR: %v13	dashapi1 := models.Dashapi{Id: dashapi.Id}14	err = o.Read(&dashapi1)15	fmt.Printf("ERR: %v16	num, err = o.Delete(&dashapi)17	fmt.Printf("NUM: %d, ERR: %v18}19import "github.com/astaxie/beego/orm"20type Dashapi struct {21	Url string `orm:"size(100)"`22}23func init() {24	orm.RegisterModel(new(Dashapi))25}26import (27type MainController struct {28}29func (c *MainController) Get() {30	o := orm.NewOrm()31	id, err := o.Insert(&dashapi)32	c.Ctx.WriteString("ID: " + string(id) + ", ERR: " + err.Error())33}

New

Using AI Code Generation

1import (2func main() {3  d := dashapi.New()4  fmt.Println(d)5}6import (7func main() {8  d := dashapi.New()9  d.SetDashPath("/usr/local/bin/dash")10  fmt.Println(d)11}12import (13func main() {14  d := dashapi.New()15  d.SetDashPath("/usr/local/bin/dash")16  d.SetDashArgs("-f")17  fmt.Println(d)18}19import (20func main() {21  d := dashapi.New()22  d.SetDashPath("/usr/local/bin/dash")23  d.SetDashArgs("-f")24  d.SetDashQuery("ls")25  fmt.Println(d)26}27import (28func main() {29  d := dashapi.New()30  d.SetDashPath("/usr/local/bin/dash")31  d.SetDashArgs("-f")32  d.SetDashQuery("ls")33  d.SetDashQuery("pwd")34  fmt.Println(d)35}36import (37func main() {38  d := dashapi.New()39  d.SetDashPath("/usr/local/bin/dash")40  d.SetDashArgs("-f")41  d.SetDashQuery("ls")42  d.SetDashQuery("pwd")43  d.SetDashQuery("date")44  fmt.Println(d)45}46import (

New

Using AI Code Generation

1import (2func main() {3	dash := dashapi.New()4	fmt.Println(dash)5}6import (7func main() {8	dash := dashapi.New()9	fmt.Println(dash)10	dash.DashAPI()11}12import (13func main() {14	dash := dashapi.New()15	fmt.Println(dash)16	dash.DashAPI()17	dash.DashAPI()18}19import (20func main() {21	dash := dashapi.New()22	fmt.Println(dash)23	dash.DashAPI()24	dash.DashAPI()25	dash.DashAPI()26}27import (28func main() {29	dash := dashapi.New()30	fmt.Println(dash)31	dash.DashAPI()32	dash.DashAPI()33	dash.DashAPI()34	dash.DashAPI()35}36import (37func main() {38	dash := dashapi.New()39	fmt.Println(dash)40	dash.DashAPI()41	dash.DashAPI()42	dash.DashAPI()43	dash.DashAPI()44	dash.DashAPI()45}46import (47func main() {48	dash := dashapi.New()49	fmt.Println(dash)50	dash.DashAPI()51	dash.DashAPI()52	dash.DashAPI()53	dash.DashAPI()54	dash.DashAPI()55	dash.DashAPI()56}

New

Using AI Code Generation

1import (2func main() {3	dash := dashapi.New()4	dash.Dash()5}6import "fmt"7type Dashapi struct {8}9func New() *Dashapi {10	return &Dashapi{}11}12func (d *Dashapi) Dash() {13	fmt.Println("Dash method called")14}

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.