How to use Fifteen method of source Package

Best Mock code snippet using source.Fifteen

extractor_test.go

Source:extractor_test.go

...30					Total:         203,31					Mean:          15.336248690597982,32					OneMinute:     10.855857873186165,33					FiveMinute:    10.652891347770824,34					FifteenMinute: 10.617728486384332,35				},36				DurationUnit: "microseconds",37				RateUnit:     "events/second",38			},39			Condition: &graylog.ExtractorMetric{40				Time: &graylog.ExtractorMetricTime{41					Max:            40,42					Mean:           2,43					StdDev:         3,44					Percentile95th: 5,45					Percentile98th: 6,46					Percentile99th: 6,47				},48				Rate: &graylog.ExtractorMetricRate{49					Total:         203,50					Mean:          15.33216150262438,51					OneMinute:     10.855857873186165,52					FiveMinute:    10.652891347770824,53					FifteenMinute: 10.617728486384332,54				},55				DurationUnit: "microseconds",56				RateUnit:     "events/second",57			},58			Execution: &graylog.ExtractorMetric{59				Time:         &graylog.ExtractorMetricTime{},60				Rate:         &graylog.ExtractorMetricRate{},61				DurationUnit: "microseconds",62				RateUnit:     "events/second",63			},64			Converters: &graylog.ExtractorMetric{65				Time:         &graylog.ExtractorMetricTime{},66				Rate:         &graylog.ExtractorMetricRate{},67				DurationUnit: "microseconds",...

resource_test.go

Source:resource_test.go

1package extractor2import (3	"io/ioutil"4	"net/http"5	"strings"6	"testing"7	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"8	"github.com/suzuki-shunsuke/flute/v2/flute"9	"github.com/terraform-provider-graylog/terraform-provider-graylog/graylog/testutil"10)11func TestAccExtractor(t *testing.T) {12	if err := testutil.SetEnv(); err != nil {13		t.Fatal(err)14	}15	conditionBody := ""16	postURLPath := "/api/system/inputs/5e9989952ab79c001156f7d2/extractors"17	resourceURLPath := postURLPath + "/553e37b0-86a8-11ea-a7d4-0242ac120004"18	resourceName := "graylog_extractor.test_json"19	getRoute := flute.Route{20		Name: "get a extractor",21		Matcher: flute.Matcher{22			Method: "GET",23		},24		Tester: flute.Tester{25			Path:         resourceURLPath,26			PartOfHeader: testutil.Header(),27		},28		Response: flute.Response{29			Response: func(req *http.Request) (*http.Response, error) {30				return &http.Response{31					StatusCode: 200,32					Body:       ioutil.NopCloser(strings.NewReader(conditionBody)),33				}, nil34			},35		},36	}37	postRoute := flute.Route{38		Name: "create a extractor",39		Matcher: flute.Matcher{40			Method: "POST",41		},42		Tester: flute.Tester{43			Path:         postURLPath,44			PartOfHeader: testutil.Header(),45			BodyJSONString: `{46  "title": "test",47  "extractor_type": "json",48  "converters": {},49  "order": 0,50  "cut_or_copy": "copy",51  "source_field": "message",52  "target_field": "none",53  "extractor_config": {54    "list_separator": ", ",55    "kv_separator": "=",56    "key_prefix": "visit_",57    "key_separator": "_",58    "replace_key_whitespace": false,59    "key_whitespace_replacement": "_"60  },61  "condition_type": "none",62  "condition_value": ""63}`,64			Test: func(t *testing.T, req *http.Request, svc flute.Service, route flute.Route) {65				conditionBody = `{66  "id": "553e37b0-86a8-11ea-a7d4-0242ac120004",67  "title": "test",68  "type": "json",69  "converters": [],70  "order": 0,71  "exceptions": 0,72  "metrics": {73    "total": {74      "time": {75        "min": 0,76        "max": 0,77        "mean": 0,78        "std_dev": 0,79        "95th_percentile": 0,80        "98th_percentile": 0,81        "99th_percentile": 082      },83      "rate": {84        "total": 0,85        "mean": 0,86        "one_minute": 0,87        "five_minute": 0,88        "fifteen_minute": 089      },90      "duration_unit": "microseconds",91      "rate_unit": "events/second"92    },93    "condition": {94      "time": {95        "min": 0,96        "max": 0,97        "mean": 0,98        "std_dev": 0,99        "95th_percentile": 0,100        "98th_percentile": 0,101        "99th_percentile": 0102      },103      "rate": {104        "total": 0,105        "mean": 0,106        "one_minute": 0,107        "five_minute": 0,108        "fifteen_minute": 0109      },110      "duration_unit": "microseconds",111      "rate_unit": "events/second"112    },113    "execution": {114      "time": {115        "min": 0,116        "max": 0,117        "mean": 0,118        "std_dev": 0,119        "95th_percentile": 0,120        "98th_percentile": 0,121        "99th_percentile": 0122      },123      "rate": {124        "total": 0,125        "mean": 0,126        "one_minute": 0,127        "five_minute": 0,128        "fifteen_minute": 0129      },130      "duration_unit": "microseconds",131      "rate_unit": "events/second"132    },133    "converters": {134      "time": {135        "min": 0,136        "max": 0,137        "mean": 0,138        "std_dev": 0,139        "95th_percentile": 0,140        "98th_percentile": 0,141        "99th_percentile": 0142      },143      "rate": {144        "total": 0,145        "mean": 0,146        "one_minute": 0,147        "five_minute": 0,148        "fifteen_minute": 0149      },150      "duration_unit": "microseconds",151      "rate_unit": "events/second"152    },153    "condition_hits": 0,154    "condition_misses": 0155  },156  "cursor_strategy": "copy",157  "source_field": "message",158  "target_field": "none",159  "extractor_config": {160    "list_separator": ", ",161    "kv_separator": "=",162    "key_prefix": "visit_",163    "key_separator": "_",164    "replace_key_whitespace": false,165    "key_whitespace_replacement": "_"166  },167  "creator_user_id": "admin",168  "condition_type": "none",169  "condition_value": "",170  "converter_exceptions": 0171}`172			},173		},174		Response: flute.Response{175			Base: http.Response{176				StatusCode: 201,177			},178			BodyString: `{179  "extractor_id": "553e37b0-86a8-11ea-a7d4-0242ac120004"180}`,181		},182	}183	deleteRoute := flute.Route{184		Name: "delete a extractor",185		Matcher: flute.Matcher{186			Method: "DELETE",187		},188		Tester: flute.Tester{189			Path:         resourceURLPath,190			PartOfHeader: testutil.Header(),191		},192		Response: flute.Response{193			Base: http.Response{194				StatusCode: 204,195			},196		},197	}198	createStep := resource.TestStep{199		ResourceName: resourceName,200		PreConfig: func() {201			testutil.SetHTTPClient(t, getRoute, postRoute, deleteRoute)202		},203		Config: `204resource "graylog_extractor" "test_json" {205  input_id        = "5e9989952ab79c001156f7d2"206  title           = "test"207  type            = "json"208  cursor_strategy = "copy"209  source_field    = "message"210  target_field    = "none"211  condition_type  = "none"212  condition_value = ""213  order           = 0214  extractor_config = <<EOF215{216  "list_separator": ", ",217  "kv_separator": "=",218  "key_prefix": "visit_",219  "key_separator": "_",220  "replace_key_whitespace": false,221  "key_whitespace_replacement": "_"222}223EOF224}225`,226		Check: resource.ComposeTestCheckFunc(227			resource.TestCheckResourceAttr(resourceName, "title", "test"),228		),229	}230	updateRoute := flute.Route{231		Name: "update a extractor",232		Matcher: flute.Matcher{233			Method: "PUT",234		},235		Tester: flute.Tester{236			Path:         resourceURLPath,237			PartOfHeader: testutil.Header(),238			BodyJSONString: `{239  "title": "test updated",240  "extractor_type": "json",241  "converters": {},242  "order": 0,243  "cut_or_copy": "copy",244  "source_field": "message",245  "target_field": "none",246  "extractor_config": {247    "list_separator": ", ",248    "kv_separator": "=",249    "key_prefix": "visit_updated_",250    "key_separator": "_",251    "replace_key_whitespace": false,252    "key_whitespace_replacement": "_"253  },254  "condition_type": "none",255  "condition_value": ""256}257`,258			Test: func(t *testing.T, req *http.Request, svc flute.Service, route flute.Route) {259				conditionBody = `{260  "id": "553e37b0-86a8-11ea-a7d4-0242ac120004",261  "title": "test updated",262  "type": "json",263  "converters": [],264  "order": 0,265  "exceptions": 0,266  "metrics": {267    "total": {268      "time": {269        "min": 0,270        "max": 0,271        "mean": 0,272        "std_dev": 0,273        "95th_percentile": 0,274        "98th_percentile": 0,275        "99th_percentile": 0276      },277      "rate": {278        "total": 0,279        "mean": 0,280        "one_minute": 0,281        "five_minute": 0,282        "fifteen_minute": 0283      },284      "duration_unit": "microseconds",285      "rate_unit": "events/second"286    },287    "condition": {288      "time": {289        "min": 0,290        "max": 0,291        "mean": 0,292        "std_dev": 0,293        "95th_percentile": 0,294        "98th_percentile": 0,295        "99th_percentile": 0296      },297      "rate": {298        "total": 0,299        "mean": 0,300        "one_minute": 0,301        "five_minute": 0,302        "fifteen_minute": 0303      },304      "duration_unit": "microseconds",305      "rate_unit": "events/second"306    },307    "execution": {308      "time": {309        "min": 0,310        "max": 0,311        "mean": 0,312        "std_dev": 0,313        "95th_percentile": 0,314        "98th_percentile": 0,315        "99th_percentile": 0316      },317      "rate": {318        "total": 0,319        "mean": 0,320        "one_minute": 0,321        "five_minute": 0,322        "fifteen_minute": 0323      },324      "duration_unit": "microseconds",325      "rate_unit": "events/second"326    },327    "converters": {328      "time": {329        "min": 0,330        "max": 0,331        "mean": 0,332        "std_dev": 0,333        "95th_percentile": 0,334        "98th_percentile": 0,335        "99th_percentile": 0336      },337      "rate": {338        "total": 0,339        "mean": 0,340        "one_minute": 0,341        "five_minute": 0,342        "fifteen_minute": 0343      },344      "duration_unit": "microseconds",345      "rate_unit": "events/second"346    },347    "condition_hits": 0,348    "condition_misses": 0349  },350  "cursor_strategy": "copy",351  "source_field": "message",352  "target_field": "none",353  "extractor_config": {354    "list_separator": ", ",355    "kv_separator": "=",356    "key_prefix": "visit_updated_",357    "key_separator": "_",358    "replace_key_whitespace": false,359    "key_whitespace_replacement": "_"360  },361  "creator_user_id": "admin",362  "condition_type": "none",363  "condition_value": "",364  "converter_exceptions": 0365}`366			},367		},368		Response: flute.Response{369			Base: http.Response{370				StatusCode: 200,371			},372			BodyString: `{373  "id": "553e37b0-86a8-11ea-a7d4-0242ac120004",374  "title": "test updated",375  "type": "json",376  "converters": [],377  "order": 0,378  "exceptions": 0,379  "metrics": {380    "total": {381      "time": {382        "min": 0,383        "max": 0,384        "mean": 0,385        "std_dev": 0,386        "95th_percentile": 0,387        "98th_percentile": 0,388        "99th_percentile": 0389      },390      "rate": {391        "total": 0,392        "mean": 0,393        "one_minute": 0,394        "five_minute": 0,395        "fifteen_minute": 0396      },397      "duration_unit": "microseconds",398      "rate_unit": "events/second"399    },400    "condition": {401      "time": {402        "min": 0,403        "max": 0,404        "mean": 0,405        "std_dev": 0,406        "95th_percentile": 0,407        "98th_percentile": 0,408        "99th_percentile": 0409      },410      "rate": {411        "total": 0,412        "mean": 0,413        "one_minute": 0,414        "five_minute": 0,415        "fifteen_minute": 0416      },417      "duration_unit": "microseconds",418      "rate_unit": "events/second"419    },420    "execution": {421      "time": {422        "min": 0,423        "max": 0,424        "mean": 0,425        "std_dev": 0,426        "95th_percentile": 0,427        "98th_percentile": 0,428        "99th_percentile": 0429      },430      "rate": {431        "total": 0,432        "mean": 0,433        "one_minute": 0,434        "five_minute": 0,435        "fifteen_minute": 0436      },437      "duration_unit": "microseconds",438      "rate_unit": "events/second"439    },440    "converters": {441      "time": {442        "min": 0,443        "max": 0,444        "mean": 0,445        "std_dev": 0,446        "95th_percentile": 0,447        "98th_percentile": 0,448        "99th_percentile": 0449      },450      "rate": {451        "total": 0,452        "mean": 0,453        "one_minute": 0,454        "five_minute": 0,455        "fifteen_minute": 0456      },457      "duration_unit": "microseconds",458      "rate_unit": "events/second"459    },460    "condition_hits": 0,461    "condition_misses": 0462  },463  "cursor_strategy": "copy",464  "source_field": "message",465  "target_field": "none",466  "extractor_config": {467    "list_separator": ", ",468    "kv_separator": "=",469    "key_prefix": "visit_updated_",470    "key_separator": "_",471    "replace_key_whitespace": false,472    "key_whitespace_replacement": "_"473  },474  "creator_user_id": "admin",475  "condition_type": "none",476  "condition_value": "",477  "converter_exceptions": 0478}`,479		},480	}481	updateStep := resource.TestStep{482		ResourceName: resourceName,483		PreConfig: func() {484			testutil.SetHTTPClient(t, getRoute, updateRoute, deleteRoute)485		},486		Config: `487resource "graylog_extractor" "test_json" {488  input_id        = "5e9989952ab79c001156f7d2"489  title           = "test updated"490  type            = "json"491  cursor_strategy = "copy"492  source_field    = "message"493  target_field    = "none"494  condition_type  = "none"495  condition_value = ""496  order           = 0497  extractor_config = <<EOF498{499  "list_separator": ", ",500  "kv_separator": "=",501  "key_prefix": "visit_updated_",502  "key_separator": "_",503  "replace_key_whitespace": false,504  "key_whitespace_replacement": "_"505}506EOF507}508`,509		Check: resource.ComposeTestCheckFunc(510			resource.TestCheckResourceAttr(resourceName, "title", "test updated"),511		),512	}513	resource.Test(t, resource.TestCase{514		Providers: testutil.SingleResourceProviders("graylog_extractor", Resource()),515		Steps: []resource.TestStep{516			createStep,517			updateStep,518		},519	})520}...

watcher.go

Source:watcher.go

...30)31const (32	BaseUrl         = "/watcher"33	HealthCheckUrl  = "/watcher/health"34	FifteenMinutes  = "15m"35	TenMinutes      = "10m"36	FiveMinutes     = "5m"37	CPU             = "CPU"38	Memory          = "Memory"39	Average         = "AVG"40	Std             = "STD"41	Latest          = "Latest"42	UnknownOperator = "Unknown"43)44type Watcher struct {45	mutex         sync.RWMutex // For thread safe access to cache46	fifteenMinute []WatcherMetrics47	tenMinute     []WatcherMetrics48	fiveMinute    []WatcherMetrics49	cacheSize     int50	client        MetricsProviderClient51	isStarted     bool // Indicates if the Watcher is started by calling StartWatching()52	shutdown      chan os.Signal53}54type Window struct {55	Duration string `json:"duration"`56	Start    int64  `json:"start"`57	End      int64  `json:"end"`58}59type Metric struct {60	Name     string  `json:"name"`             // Name of metric at the provider61	Type     string  `json:"type"`             // CPU or Memory62	Operator string  `json:"operator"`         // STD or AVE or SUM, etc.63	Rollup   string  `json:"rollup,omitempty"` // Rollup used for metric calculation64	Value    float64 `json:"value"`            // Value is expected to be in %65}66type NodeMetricsMap map[string]NodeMetrics67type Data struct {68	NodeMetricsMap NodeMetricsMap69}70type WatcherMetrics struct {71	Timestamp int64  `json:"timestamp"`72	Window    Window `json:"window"`73	Source    string `json:"source"`74	Data      Data   `json:"data"`75}76type Tags struct {77}78type Metadata struct {79	DataCenter string `json:"dataCenter,omitempty"`80}81type NodeMetrics struct {82	Metrics  []Metric `json:"metrics,omitempty"`83	Tags     Tags     `json:"tags,omitempty"`84	Metadata Metadata `json:"metadata,omitempty"`85}86// NewWatcher Returns a new initialised Watcher87func NewWatcher(client MetricsProviderClient) *Watcher {88	sizePerWindow := 589	return &Watcher{90		mutex:         sync.RWMutex{},91		fifteenMinute: make([]WatcherMetrics, 0, sizePerWindow),92		tenMinute:     make([]WatcherMetrics, 0, sizePerWindow),93		fiveMinute:    make([]WatcherMetrics, 0, sizePerWindow),94		cacheSize:     sizePerWindow,95		client:        client,96		shutdown:      make(chan os.Signal, 1),97	}98}99// StartWatching This function needs to be called to begin actual watching100func (w *Watcher) StartWatching() {101	w.mutex.RLock()102	if w.isStarted {103		w.mutex.RUnlock()104		return105	}106	w.mutex.RUnlock()107	fetchOnce := func(duration string) {108		curWindow, metric := w.getCurrentWindow(duration)109		hostMetrics, err := w.client.FetchAllHostsMetrics(curWindow)110		if err != nil {111			log.Errorf("received error while fetching metrics: %v", err)112			return113		}114		log.Debugf("fetched metrics for window: %v", curWindow)115		// TODOï¼ add tags, etc.116		watcherMetrics := metricMapToWatcherMetrics(hostMetrics, w.client.Name(), *curWindow)117		w.appendWatcherMetrics(metric, &watcherMetrics)118	}119	windowWatcher := func(duration string) {120		for {121			fetchOnce(duration)122			// This is assuming fetching of metrics won't exceed more than 1 minute. If it happens we need to throttle rate of fetches123			time.Sleep(time.Minute)124		}125	}126	durations := [3]string{FifteenMinutes, TenMinutes, FiveMinutes}127	for _, duration := range durations {128		// Populate cache initially before returning129		fetchOnce(duration)130		go windowWatcher(duration)131	}132	http.HandleFunc(BaseUrl, w.handler)133	http.HandleFunc(HealthCheckUrl, w.healthCheckHandler)134	server := &http.Server{135		Addr:    ":2020",136		Handler: http.DefaultServeMux,137	}138	go func() {139		log.Warn(server.ListenAndServe())140	}()141	signal.Notify(w.shutdown, os.Interrupt, syscall.SIGTERM)142	go func() {143		<-w.shutdown144		ctx, cancel := context.WithTimeout(context.Background(), time.Minute)145		defer cancel()146		if err := server.Shutdown(ctx); err != nil {147			log.Errorf("Unable to shutdown server: %v", err)148		}149	}()150	w.mutex.Lock()151	w.isStarted = true152	w.mutex.Unlock()153	log.Info("Started watching metrics")154}155// GetLatestWatcherMetrics It starts from 15 minute window, and falls back to 10 min, 5 min windows subsequently156// if metrics are not present. StartWatching() should be called before calling this.157func (w *Watcher) GetLatestWatcherMetrics(duration string) (*WatcherMetrics, error) {158	w.mutex.RLock()159	defer w.mutex.RUnlock()160	if !w.isStarted {161		return nil, errors.New("need to call StartWatching() first")162	}163	switch {164	case duration == FifteenMinutes && len(w.fifteenMinute) > 0:165		return w.deepCopyWatcherMetrics(&w.fifteenMinute[len(w.fifteenMinute)-1]), nil166	case (duration == FifteenMinutes || duration == TenMinutes) && len(w.tenMinute) > 0:167		return w.deepCopyWatcherMetrics(&w.tenMinute[len(w.tenMinute)-1]), nil168	case (duration == TenMinutes || duration == FiveMinutes) && len(w.fiveMinute) > 0:169		return w.deepCopyWatcherMetrics(&w.fiveMinute[len(w.fiveMinute)-1]), nil170	default:171		return nil, errors.New("unable to get any latest metrics")172	}173}174func (w *Watcher) getCurrentWindow(duration string) (*Window, *[]WatcherMetrics) {175	var curWindow *Window176	var watcherMetrics *[]WatcherMetrics177	switch duration {178	case FifteenMinutes:179		curWindow = CurrentFifteenMinuteWindow()180		watcherMetrics = &w.fifteenMinute181	case TenMinutes:182		curWindow = CurrentTenMinuteWindow()183		watcherMetrics = &w.tenMinute184	case FiveMinutes:185		curWindow = CurrentFiveMinuteWindow()186		watcherMetrics = &w.fiveMinute187	default:188		log.Error("received unexpected window duration, defaulting to 15m")189		curWindow = CurrentFifteenMinuteWindow()190	}191	return curWindow, watcherMetrics192}193func (w *Watcher) appendWatcherMetrics(recentMetrics *[]WatcherMetrics, metric *WatcherMetrics) {194	w.mutex.Lock()195	defer w.mutex.Unlock()196	if len(*recentMetrics) == w.cacheSize {197		*recentMetrics = (*recentMetrics)[1:]198	}199	*recentMetrics = append(*recentMetrics, *metric)200}201func (w *Watcher) deepCopyWatcherMetrics(src *WatcherMetrics) *WatcherMetrics {202	nodeMetricsMap := make(map[string]NodeMetrics)203	for host, fetchedMetric := range src.Data.NodeMetricsMap {204		nodeMetric := NodeMetrics{205			Metrics: make([]Metric, len(fetchedMetric.Metrics)),206			Tags:    fetchedMetric.Tags,207		}208		copy(nodeMetric.Metrics, fetchedMetric.Metrics)209		nodeMetric.Metadata = fetchedMetric.Metadata210		nodeMetricsMap[host] = nodeMetric211	}212	return &WatcherMetrics{213		Timestamp: src.Timestamp,214		Window:    src.Window,215		Source:    src.Source,216		Data: Data{217			NodeMetricsMap: nodeMetricsMap,218		},219	}220}221// HTTP Handler for BaseUrl endpoint222func (w *Watcher) handler(resp http.ResponseWriter, r *http.Request) {223	resp.Header().Set("Content-Type", "application/json")224	metrics, err := w.GetLatestWatcherMetrics(FifteenMinutes)225	if metrics == nil {226		if err != nil {227			resp.WriteHeader(http.StatusInternalServerError)228			log.Error(err)229			return230		}231		resp.WriteHeader(http.StatusNotFound)232		return233	}234	host := r.URL.Query().Get("host")235	var bytes []byte236	if host != "" {237		if _, ok := metrics.Data.NodeMetricsMap[host]; ok {238			hostMetricsData := make(map[string]NodeMetrics)239			hostMetricsData[host] = metrics.Data.NodeMetricsMap[host]240			hostMetrics := WatcherMetrics{Timestamp: metrics.Timestamp,241				Window: metrics.Window,242				Source: metrics.Source,243				Data:   Data{NodeMetricsMap: hostMetricsData},244			}245			bytes, err = gojay.MarshalJSONObject(&hostMetrics)246		} else {247			resp.WriteHeader(http.StatusNotFound)248			return249		}250	} else {251		bytes, err = gojay.MarshalJSONObject(metrics)252	}253	if err != nil {254		log.Error(err)255		resp.WriteHeader(http.StatusInternalServerError)256		return257	}258	_, err = resp.Write(bytes)259	if err != nil {260		log.Error(err)261		resp.WriteHeader(http.StatusInternalServerError)262	}263}264// Simple server status handler265func (w *Watcher) healthCheckHandler(resp http.ResponseWriter, r *http.Request) {266	if status, err := w.client.Health(); status != 0 {267		log.Warnf("health check failed with: %v", err)268		resp.WriteHeader(http.StatusServiceUnavailable)269		return270	}271	resp.WriteHeader(http.StatusOK)272}273// Utility functions274func metricMapToWatcherMetrics(metricMap map[string][]Metric, clientName string, window Window) WatcherMetrics {275	metricsMap := make(map[string]NodeMetrics)276	for host, metricList := range metricMap {277		nodeMetric := NodeMetrics{278			Metrics: make([]Metric, len(metricList)),279		}280		copy(nodeMetric.Metrics, metricList)281		metricsMap[host] = nodeMetric282	}283	watcherMetrics := WatcherMetrics{Timestamp: time.Now().Unix(),284		Data:   Data{NodeMetricsMap: metricsMap},285		Source: clientName,286		Window: window,287	}288	return watcherMetrics289}290func CurrentFifteenMinuteWindow() *Window {291	curTime := time.Now().Unix()292	return &Window{FifteenMinutes, curTime - 15*60, curTime}293}294func CurrentTenMinuteWindow() *Window {295	curTime := time.Now().Unix()296	return &Window{TenMinutes, curTime - 10*60, curTime}297}298func CurrentFiveMinuteWindow() *Window {299	curTime := time.Now().Unix()300	return &Window{FiveMinutes, curTime - 5*60, curTime}301}...

Fifteen

Using AI Code Generation

1import "fmt"2import "source"3func main() {4    fmt.Println(source.Fifteen())5}6import "fmt"7import "source"8func main() {9    fmt.Println(source.Twenty())10}11import "fmt"12import "source"13func main() {14    fmt.Println(source.TwentyFive())15}

Fifteen

Using AI Code Generation

1import (2func main() {3	fmt.Println(source.Fifteen())4}5func Fifteen() int {6}7./1.go:5: import /Users/steve/go/src/source/source.go: cannot import absolute path8The following is a valid import statement:9import (10func main() {11	fmt.Println(source.Fifteen())12}13func Fifteen() int {14}15import

Fifteen

Using AI Code Generation

1import "fmt"2import "test"3func main() {4   ret = test.Fifteen(a, b)5   fmt.Printf( "Fifteen() value is : %d6}7Fifteen() value is : 158Fifteen() value is : 15

Fifteen

Using AI Code Generation

1import "fmt"2func main() {3a.Fifteen()4}5import "fmt"6func main() {7a.Twenty()8}9import "fmt"10func main() {11a.Ten()12}13import "fmt"14func main() {15a.Five()16}17import "fmt"18func main() {19a.Three()20}21import "fmt"22func main() {23a.Two()24}25import "fmt"26func main() {27a.One()28}29import "fmt"30func main() {31a.Zero()32}33import "fmt"34func main() {35a.NegativeOne()36}37import "fmt"38func main() {39a.NegativeTwo()40}41import "fmt"42func main() {43a.NegativeThree()44}45import "fmt"46func main() {47a.NegativeFive()48}49import "fmt"50func main() {51a.NegativeTen()52}53import "fmt"54func main() {55a.NegativeFifteen()56}57import "fmt"58func main() {

Fifteen

Using AI Code Generation

1import "github.com/abhishekkr/gol/gol"2func main() {3  gol.Fifteen()4}5import "github.com/abhishekkr/gol/gol"6func main() {7  gol.Twenty()8}9import "github.com/abhishekkr/gol/gol"10func main() {11  gol.Thirty()12}

Fifteen

Using AI Code Generation

1import "fmt"2func main() {3    fmt.Println("Hello, playground")4    target.Fifteen()5}6import "fmt"7func main() {8    fmt.Println("Hello, playground")9    target.Fifteen()10}11import "fmt"12func main() {13    fmt.Println("Hello, playground")14    target.Fifteen()15}16import "fmt"17func main() {18    fmt.Println("Hello, playground")19    target.Fifteen()20}21import "fmt"22func main() {23    fmt.Println("Hello, playground")24    target.Fifteen()25}26import "fmt"27func main() {28    fmt.Println("Hello, playground")29    target.Fifteen()30}31import "fmt"32func main() {33    fmt.Println("Hello, playground")34    target.Fifteen()35}36import "fmt"37func main() {38    fmt.Println("Hello, playground")39    target.Fifteen()40}41import "fmt"42func main() {43    fmt.Println("Hello, playground

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.