How to use WithMethod method of wait Package

Best Testcontainers-go code snippet using wait.WithMethod

dms_meta.go

Source:dms_meta.go

...5	"net/http"6)7func GenReqDefForBatchCreateOrDeleteQueueTag() *def.HttpRequestDef {8	reqDefBuilder := def.NewHttpRequestDefBuilder().9		WithMethod(http.MethodPost).10		WithPath("/v2/{project_id}/queue/{queue_id}/tags/action").11		WithResponse(new(model.BatchCreateOrDeleteQueueTagResponse)).12		WithContentType("application/json")13	reqDefBuilder.WithRequestField(def.NewFieldDef().14		WithName("QueueId").15		WithJsonTag("queue_id").16		WithLocationType(def.Path))17	reqDefBuilder.WithRequestField(def.NewFieldDef().18		WithName("Body").19		WithLocationType(def.Body))20	requestDef := reqDefBuilder.Build()21	return requestDef22}23func GenReqDefForConfirmConsumptionMessages() *def.HttpRequestDef {24	reqDefBuilder := def.NewHttpRequestDefBuilder().25		WithMethod(http.MethodPost).26		WithPath("/v2/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/ack").27		WithResponse(new(model.ConfirmConsumptionMessagesResponse)).28		WithContentType("application/json")29	reqDefBuilder.WithRequestField(def.NewFieldDef().30		WithName("QueueId").31		WithJsonTag("queue_id").32		WithLocationType(def.Path))33	reqDefBuilder.WithRequestField(def.NewFieldDef().34		WithName("ConsumerGroupId").35		WithJsonTag("consumer_group_id").36		WithLocationType(def.Path))37	reqDefBuilder.WithRequestField(def.NewFieldDef().38		WithName("Body").39		WithLocationType(def.Body))40	requestDef := reqDefBuilder.Build()41	return requestDef42}43func GenReqDefForConfirmDeadLettersMessages() *def.HttpRequestDef {44	reqDefBuilder := def.NewHttpRequestDefBuilder().45		WithMethod(http.MethodPost).46		WithPath("/v2/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters/ack").47		WithResponse(new(model.ConfirmDeadLettersMessagesResponse)).48		WithContentType("application/json")49	reqDefBuilder.WithRequestField(def.NewFieldDef().50		WithName("QueueId").51		WithJsonTag("queue_id").52		WithLocationType(def.Path))53	reqDefBuilder.WithRequestField(def.NewFieldDef().54		WithName("ConsumerGroupId").55		WithJsonTag("consumer_group_id").56		WithLocationType(def.Path))57	reqDefBuilder.WithRequestField(def.NewFieldDef().58		WithName("Body").59		WithLocationType(def.Body))60	requestDef := reqDefBuilder.Build()61	return requestDef62}63func GenReqDefForConsumeDeadlettersMessage() *def.HttpRequestDef {64	reqDefBuilder := def.NewHttpRequestDefBuilder().65		WithMethod(http.MethodGet).66		WithPath("/v2/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/deadletters").67		WithResponse(new(model.ConsumeDeadlettersMessageResponse)).68		WithContentType("application/json")69	reqDefBuilder.WithRequestField(def.NewFieldDef().70		WithName("QueueId").71		WithJsonTag("queue_id").72		WithLocationType(def.Path))73	reqDefBuilder.WithRequestField(def.NewFieldDef().74		WithName("ConsumerGroupId").75		WithJsonTag("consumer_group_id").76		WithLocationType(def.Path))77	reqDefBuilder.WithRequestField(def.NewFieldDef().78		WithName("MaxMsgs").79		WithJsonTag("max_msgs").80		WithLocationType(def.Query))81	reqDefBuilder.WithRequestField(def.NewFieldDef().82		WithName("TimeWait").83		WithJsonTag("time_wait").84		WithLocationType(def.Query))85	reqDefBuilder.WithRequestField(def.NewFieldDef().86		WithName("AckWait").87		WithJsonTag("ack_wait").88		WithLocationType(def.Query))89	reqDefBuilder.WithResponseField(def.NewFieldDef().90		WithName("Body").91		WithLocationType(def.Body))92	requestDef := reqDefBuilder.Build()93	return requestDef94}95func GenReqDefForConsumeMessages() *def.HttpRequestDef {96	reqDefBuilder := def.NewHttpRequestDefBuilder().97		WithMethod(http.MethodGet).98		WithPath("/v2/{project_id}/queues/{queue_id}/groups/{consumer_group_id}/messages").99		WithResponse(new(model.ConsumeMessagesResponse)).100		WithContentType("application/json")101	reqDefBuilder.WithRequestField(def.NewFieldDef().102		WithName("QueueId").103		WithJsonTag("queue_id").104		WithLocationType(def.Path))105	reqDefBuilder.WithRequestField(def.NewFieldDef().106		WithName("ConsumerGroupId").107		WithJsonTag("consumer_group_id").108		WithLocationType(def.Path))109	reqDefBuilder.WithRequestField(def.NewFieldDef().110		WithName("MaxMsgs").111		WithJsonTag("max_msgs").112		WithLocationType(def.Query))113	reqDefBuilder.WithRequestField(def.NewFieldDef().114		WithName("TimeWait").115		WithJsonTag("time_wait").116		WithLocationType(def.Query))117	reqDefBuilder.WithRequestField(def.NewFieldDef().118		WithName("AckWait").119		WithJsonTag("ack_wait").120		WithLocationType(def.Query))121	reqDefBuilder.WithRequestField(def.NewFieldDef().122		WithName("Tag").123		WithJsonTag("tag").124		WithLocationType(def.Query))125	reqDefBuilder.WithRequestField(def.NewFieldDef().126		WithName("TagType").127		WithJsonTag("tag_type").128		WithLocationType(def.Query))129	reqDefBuilder.WithResponseField(def.NewFieldDef().130		WithName("Body").131		WithLocationType(def.Body))132	requestDef := reqDefBuilder.Build()133	return requestDef134}135func GenReqDefForCreateConsumerGroup() *def.HttpRequestDef {136	reqDefBuilder := def.NewHttpRequestDefBuilder().137		WithMethod(http.MethodPost).138		WithPath("/v2/{project_id}/queues/{queue_id}/groups").139		WithResponse(new(model.CreateConsumerGroupResponse)).140		WithContentType("application/json")141	reqDefBuilder.WithRequestField(def.NewFieldDef().142		WithName("QueueId").143		WithJsonTag("queue_id").144		WithLocationType(def.Path))145	reqDefBuilder.WithRequestField(def.NewFieldDef().146		WithName("Body").147		WithLocationType(def.Body))148	requestDef := reqDefBuilder.Build()149	return requestDef150}151func GenReqDefForCreateQueue() *def.HttpRequestDef {152	reqDefBuilder := def.NewHttpRequestDefBuilder().153		WithMethod(http.MethodPost).154		WithPath("/v2/{project_id}/queues").155		WithResponse(new(model.CreateQueueResponse)).156		WithContentType("application/json")157	reqDefBuilder.WithRequestField(def.NewFieldDef().158		WithName("Body").159		WithLocationType(def.Body))160	requestDef := reqDefBuilder.Build()161	return requestDef162}163func GenReqDefForDeleteQueue() *def.HttpRequestDef {164	reqDefBuilder := def.NewHttpRequestDefBuilder().165		WithMethod(http.MethodDelete).166		WithPath("/v2/{project_id}/queues/{queue_id}").167		WithResponse(new(model.DeleteQueueResponse)).168		WithContentType("application/json")169	reqDefBuilder.WithRequestField(def.NewFieldDef().170		WithName("QueueId").171		WithJsonTag("queue_id").172		WithLocationType(def.Path))173	requestDef := reqDefBuilder.Build()174	return requestDef175}176func GenReqDefForDeleteSpecifiedConsumerGroup() *def.HttpRequestDef {177	reqDefBuilder := def.NewHttpRequestDefBuilder().178		WithMethod(http.MethodDelete).179		WithPath("/v2/{project_id}/queues/{queue_id}/groups/{group_id}").180		WithResponse(new(model.DeleteSpecifiedConsumerGroupResponse)).181		WithContentType("application/json")182	reqDefBuilder.WithRequestField(def.NewFieldDef().183		WithName("QueueId").184		WithJsonTag("queue_id").185		WithLocationType(def.Path))186	reqDefBuilder.WithRequestField(def.NewFieldDef().187		WithName("GroupId").188		WithJsonTag("group_id").189		WithLocationType(def.Path))190	requestDef := reqDefBuilder.Build()191	return requestDef192}193func GenReqDefForListConsumerGroups() *def.HttpRequestDef {194	reqDefBuilder := def.NewHttpRequestDefBuilder().195		WithMethod(http.MethodGet).196		WithPath("/v2/{project_id}/queues/{queue_id}/groups").197		WithResponse(new(model.ListConsumerGroupsResponse)).198		WithContentType("application/json")199	reqDefBuilder.WithRequestField(def.NewFieldDef().200		WithName("QueueId").201		WithJsonTag("queue_id").202		WithLocationType(def.Path))203	reqDefBuilder.WithRequestField(def.NewFieldDef().204		WithName("IncludeDeadletter").205		WithJsonTag("include_deadletter").206		WithLocationType(def.Query))207	reqDefBuilder.WithRequestField(def.NewFieldDef().208		WithName("IncludeMessagesNum").209		WithJsonTag("include_messages_num").210		WithLocationType(def.Query))211	reqDefBuilder.WithRequestField(def.NewFieldDef().212		WithName("PageSize").213		WithJsonTag("page_size").214		WithLocationType(def.Query))215	reqDefBuilder.WithRequestField(def.NewFieldDef().216		WithName("CurrentPage").217		WithJsonTag("current_page").218		WithLocationType(def.Query))219	requestDef := reqDefBuilder.Build()220	return requestDef221}222func GenReqDefForListQueues() *def.HttpRequestDef {223	reqDefBuilder := def.NewHttpRequestDefBuilder().224		WithMethod(http.MethodGet).225		WithPath("/v2/{project_id}/queues").226		WithResponse(new(model.ListQueuesResponse)).227		WithContentType("application/json")228	reqDefBuilder.WithRequestField(def.NewFieldDef().229		WithName("IncludeDeadletter").230		WithJsonTag("include_deadletter").231		WithLocationType(def.Query))232	requestDef := reqDefBuilder.Build()233	return requestDef234}235func GenReqDefForSendMessages() *def.HttpRequestDef {236	reqDefBuilder := def.NewHttpRequestDefBuilder().237		WithMethod(http.MethodPost).238		WithPath("/v2/{project_id}/queues/{queue_id}/messages").239		WithResponse(new(model.SendMessagesResponse)).240		WithContentType("application/json")241	reqDefBuilder.WithRequestField(def.NewFieldDef().242		WithName("QueueId").243		WithJsonTag("queue_id").244		WithLocationType(def.Path))245	reqDefBuilder.WithRequestField(def.NewFieldDef().246		WithName("Body").247		WithLocationType(def.Body))248	requestDef := reqDefBuilder.Build()249	return requestDef250}251func GenReqDefForShowQueue() *def.HttpRequestDef {252	reqDefBuilder := def.NewHttpRequestDefBuilder().253		WithMethod(http.MethodGet).254		WithPath("/v2/{project_id}/queues/{queue_id}").255		WithResponse(new(model.ShowQueueResponse)).256		WithContentType("application/json")257	reqDefBuilder.WithRequestField(def.NewFieldDef().258		WithName("QueueId").259		WithJsonTag("queue_id").260		WithLocationType(def.Path))261	reqDefBuilder.WithRequestField(def.NewFieldDef().262		WithName("IncludeDeadletter").263		WithJsonTag("include_deadletter").264		WithLocationType(def.Query))265	requestDef := reqDefBuilder.Build()266	return requestDef267}268func GenReqDefForShowQueueProjectTags() *def.HttpRequestDef {269	reqDefBuilder := def.NewHttpRequestDefBuilder().270		WithMethod(http.MethodGet).271		WithPath("/v2/{project_id}/queue/tags").272		WithResponse(new(model.ShowQueueProjectTagsResponse)).273		WithContentType("application/json")274	requestDef := reqDefBuilder.Build()275	return requestDef276}277func GenReqDefForShowQueueTags() *def.HttpRequestDef {278	reqDefBuilder := def.NewHttpRequestDefBuilder().279		WithMethod(http.MethodGet).280		WithPath("/v2/{project_id}/queue/{queue_id}/tags").281		WithResponse(new(model.ShowQueueTagsResponse)).282		WithContentType("application/json")283	reqDefBuilder.WithRequestField(def.NewFieldDef().284		WithName("QueueId").285		WithJsonTag("queue_id").286		WithLocationType(def.Path))287	requestDef := reqDefBuilder.Build()288	return requestDef289}290func GenReqDefForShowQuotas() *def.HttpRequestDef {291	reqDefBuilder := def.NewHttpRequestDefBuilder().292		WithMethod(http.MethodGet).293		WithPath("/v2/{project_id}/quotas").294		WithResponse(new(model.ShowQuotasResponse)).295		WithContentType("application/json")296	requestDef := reqDefBuilder.Build()297	return requestDef298}...

context_id_test.go

Source:context_id_test.go

...11func TestContextId_Simple(t *testing.T) {12	test.WithContext(func(ctx context.Context) {13		h := newHarness()14		const CONTEXT_ID = 1715		call := processCallInput().WithContextId(CONTEXT_ID).WithMethod("BenchmarkContract", "set").WithArgs(uint64(66)).Build()16		h.expectSdkCallMadeWithExecutionContextId(CONTEXT_ID)17		_, err := h.service.ProcessCall(ctx, call)18		require.NoError(t, err, "call should succeed")19		h.verifySdkCallMade(t)20	})21}22func TestContextId_MultipleGoroutines(t *testing.T) {23	test.WithContext(func(ctx context.Context) {24		var wg sync.WaitGroup25		h := newHarness()26		for i := 0; i < 20; i++ {27			wg.Add(1)28			var CONTEXT_ID = sdkContext.ContextId(i + 17)29			go func() {30				call := processCallInput().WithContextId(CONTEXT_ID).WithMethod("BenchmarkContract", "set").WithArgs(uint64(66)).Build()31				h.expectSdkCallMadeWithExecutionContextId(CONTEXT_ID)32				time.Sleep(5 * time.Millisecond)33				_, err := h.service.ProcessCall(ctx, call)34				require.NoError(t, err, "call should succeed")35				wg.Done()36			}()37		}38		wg.Wait()39		h.verifySdkCallMade(t)40	})41}...

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.