triggerrun.go

Documentation: github.com/Azure/azure-sdk-for-go/services/preview/synapse/2019-06-01-preview/artifacts

     1  package artifacts
     2  
     3  // Copyright (c) Microsoft Corporation. All rights reserved.
     4  // Licensed under the MIT License. See License.txt in the project root for license information.
     5  //
     6  // Code generated by Microsoft (R) AutoRest Code Generator.
     7  // Changes may cause incorrect behavior and will be lost if the code is regenerated.
     8  
     9  import (
    10  	"context"
    11  	"github.com/Azure/go-autorest/autorest"
    12  	"github.com/Azure/go-autorest/autorest/azure"
    13  	"github.com/Azure/go-autorest/autorest/validation"
    14  	"github.com/Azure/go-autorest/tracing"
    15  	"net/http"
    16  )
    17  
    18  // TriggerRunClient is the client for the TriggerRun methods of the Artifacts service.
    19  type TriggerRunClient struct {
    20  	BaseClient
    21  }
    22  
    23  // NewTriggerRunClient creates an instance of the TriggerRunClient client.
    24  func NewTriggerRunClient(endpoint string) TriggerRunClient {
    25  	return TriggerRunClient{New(endpoint)}
    26  }
    27  
    28  // CancelTriggerInstance cancel single trigger instance by runId.
    29  // Parameters:
    30  // triggerName - the trigger name.
    31  // runID - the pipeline run identifier.
    32  func (client TriggerRunClient) CancelTriggerInstance(ctx context.Context, triggerName string, runID string) (result autorest.Response, err error) {
    33  	if tracing.IsEnabled() {
    34  		ctx = tracing.StartSpan(ctx, fqdn+"/TriggerRunClient.CancelTriggerInstance")
    35  		defer func() {
    36  			sc := -1
    37  			if result.Response != nil {
    38  				sc = result.Response.StatusCode
    39  			}
    40  			tracing.EndSpan(ctx, sc, err)
    41  		}()
    42  	}
    43  	if err := validation.Validate([]validation.Validation{
    44  		{TargetValue: triggerName,
    45  			Constraints: []validation.Constraint{{Target: "triggerName", Name: validation.MaxLength, Rule: 260, Chain: nil},
    46  				{Target: "triggerName", Name: validation.MinLength, Rule: 1, Chain: nil},
    47  				{Target: "triggerName", Name: validation.Pattern, Rule: `^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$`, Chain: nil}}}}); err != nil {
    48  		return result, validation.NewError("artifacts.TriggerRunClient", "CancelTriggerInstance", err.Error())
    49  	}
    50  
    51  	req, err := client.CancelTriggerInstancePreparer(ctx, triggerName, runID)
    52  	if err != nil {
    53  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "CancelTriggerInstance", nil, "Failure preparing request")
    54  		return
    55  	}
    56  
    57  	resp, err := client.CancelTriggerInstanceSender(req)
    58  	if err != nil {
    59  		result.Response = resp
    60  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "CancelTriggerInstance", resp, "Failure sending request")
    61  		return
    62  	}
    63  
    64  	result, err = client.CancelTriggerInstanceResponder(resp)
    65  	if err != nil {
    66  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "CancelTriggerInstance", resp, "Failure responding to request")
    67  		return
    68  	}
    69  
    70  	return
    71  }
    72  
    73  // CancelTriggerInstancePreparer prepares the CancelTriggerInstance request.
    74  func (client TriggerRunClient) CancelTriggerInstancePreparer(ctx context.Context, triggerName string, runID string) (*http.Request, error) {
    75  	urlParameters := map[string]interface{}{
    76  		"endpoint": client.Endpoint,
    77  	}
    78  
    79  	pathParameters := map[string]interface{}{
    80  		"runId":       autorest.Encode("path", runID),
    81  		"triggerName": autorest.Encode("path", triggerName),
    82  	}
    83  
    84  	const APIVersion = "2019-06-01-preview"
    85  	queryParameters := map[string]interface{}{
    86  		"api-version": APIVersion,
    87  	}
    88  
    89  	preparer := autorest.CreatePreparer(
    90  		autorest.AsPost(),
    91  		autorest.WithCustomBaseURL("{endpoint}", urlParameters),
    92  		autorest.WithPathParameters("/triggers/{triggerName}/triggerRuns/{runId}/cancel", pathParameters),
    93  		autorest.WithQueryParameters(queryParameters))
    94  	return preparer.Prepare((&http.Request{}).WithContext(ctx))
    95  }
    96  
    97  // CancelTriggerInstanceSender sends the CancelTriggerInstance request. The method will close the
    98  // http.Response Body if it receives an error.
    99  func (client TriggerRunClient) CancelTriggerInstanceSender(req *http.Request) (*http.Response, error) {
   100  	return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
   101  }
   102  
   103  // CancelTriggerInstanceResponder handles the response to the CancelTriggerInstance request. The method always
   104  // closes the http.Response Body.
   105  func (client TriggerRunClient) CancelTriggerInstanceResponder(resp *http.Response) (result autorest.Response, err error) {
   106  	err = autorest.Respond(
   107  		resp,
   108  		azure.WithErrorUnlessStatusCode(http.StatusOK),
   109  		autorest.ByClosing())
   110  	result.Response = resp
   111  	return
   112  }
   113  
   114  // QueryTriggerRunsByWorkspace query trigger runs.
   115  // Parameters:
   116  // filterParameters - parameters to filter the pipeline run.
   117  func (client TriggerRunClient) QueryTriggerRunsByWorkspace(ctx context.Context, filterParameters RunFilterParameters) (result TriggerRunsQueryResponse, err error) {
   118  	if tracing.IsEnabled() {
   119  		ctx = tracing.StartSpan(ctx, fqdn+"/TriggerRunClient.QueryTriggerRunsByWorkspace")
   120  		defer func() {
   121  			sc := -1
   122  			if result.Response.Response != nil {
   123  				sc = result.Response.Response.StatusCode
   124  			}
   125  			tracing.EndSpan(ctx, sc, err)
   126  		}()
   127  	}
   128  	if err := validation.Validate([]validation.Validation{
   129  		{TargetValue: filterParameters,
   130  			Constraints: []validation.Constraint{{Target: "filterParameters.LastUpdatedAfter", Name: validation.Null, Rule: true, Chain: nil},
   131  				{Target: "filterParameters.LastUpdatedBefore", Name: validation.Null, Rule: true, Chain: nil}}}}); err != nil {
   132  		return result, validation.NewError("artifacts.TriggerRunClient", "QueryTriggerRunsByWorkspace", err.Error())
   133  	}
   134  
   135  	req, err := client.QueryTriggerRunsByWorkspacePreparer(ctx, filterParameters)
   136  	if err != nil {
   137  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "QueryTriggerRunsByWorkspace", nil, "Failure preparing request")
   138  		return
   139  	}
   140  
   141  	resp, err := client.QueryTriggerRunsByWorkspaceSender(req)
   142  	if err != nil {
   143  		result.Response = autorest.Response{Response: resp}
   144  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "QueryTriggerRunsByWorkspace", resp, "Failure sending request")
   145  		return
   146  	}
   147  
   148  	result, err = client.QueryTriggerRunsByWorkspaceResponder(resp)
   149  	if err != nil {
   150  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "QueryTriggerRunsByWorkspace", resp, "Failure responding to request")
   151  		return
   152  	}
   153  
   154  	return
   155  }
   156  
   157  // QueryTriggerRunsByWorkspacePreparer prepares the QueryTriggerRunsByWorkspace request.
   158  func (client TriggerRunClient) QueryTriggerRunsByWorkspacePreparer(ctx context.Context, filterParameters RunFilterParameters) (*http.Request, error) {
   159  	urlParameters := map[string]interface{}{
   160  		"endpoint": client.Endpoint,
   161  	}
   162  
   163  	const APIVersion = "2019-06-01-preview"
   164  	queryParameters := map[string]interface{}{
   165  		"api-version": APIVersion,
   166  	}
   167  
   168  	preparer := autorest.CreatePreparer(
   169  		autorest.AsContentType("application/json; charset=utf-8"),
   170  		autorest.AsPost(),
   171  		autorest.WithCustomBaseURL("{endpoint}", urlParameters),
   172  		autorest.WithPath("/queryTriggerRuns"),
   173  		autorest.WithJSON(filterParameters),
   174  		autorest.WithQueryParameters(queryParameters))
   175  	return preparer.Prepare((&http.Request{}).WithContext(ctx))
   176  }
   177  
   178  // QueryTriggerRunsByWorkspaceSender sends the QueryTriggerRunsByWorkspace request. The method will close the
   179  // http.Response Body if it receives an error.
   180  func (client TriggerRunClient) QueryTriggerRunsByWorkspaceSender(req *http.Request) (*http.Response, error) {
   181  	return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
   182  }
   183  
   184  // QueryTriggerRunsByWorkspaceResponder handles the response to the QueryTriggerRunsByWorkspace request. The method always
   185  // closes the http.Response Body.
   186  func (client TriggerRunClient) QueryTriggerRunsByWorkspaceResponder(resp *http.Response) (result TriggerRunsQueryResponse, err error) {
   187  	err = autorest.Respond(
   188  		resp,
   189  		azure.WithErrorUnlessStatusCode(http.StatusOK),
   190  		autorest.ByUnmarshallingJSON(&result),
   191  		autorest.ByClosing())
   192  	result.Response = autorest.Response{Response: resp}
   193  	return
   194  }
   195  
   196  // RerunTriggerInstance rerun single trigger instance by runId.
   197  // Parameters:
   198  // triggerName - the trigger name.
   199  // runID - the pipeline run identifier.
   200  func (client TriggerRunClient) RerunTriggerInstance(ctx context.Context, triggerName string, runID string) (result autorest.Response, err error) {
   201  	if tracing.IsEnabled() {
   202  		ctx = tracing.StartSpan(ctx, fqdn+"/TriggerRunClient.RerunTriggerInstance")
   203  		defer func() {
   204  			sc := -1
   205  			if result.Response != nil {
   206  				sc = result.Response.StatusCode
   207  			}
   208  			tracing.EndSpan(ctx, sc, err)
   209  		}()
   210  	}
   211  	if err := validation.Validate([]validation.Validation{
   212  		{TargetValue: triggerName,
   213  			Constraints: []validation.Constraint{{Target: "triggerName", Name: validation.MaxLength, Rule: 260, Chain: nil},
   214  				{Target: "triggerName", Name: validation.MinLength, Rule: 1, Chain: nil},
   215  				{Target: "triggerName", Name: validation.Pattern, Rule: `^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$`, Chain: nil}}}}); err != nil {
   216  		return result, validation.NewError("artifacts.TriggerRunClient", "RerunTriggerInstance", err.Error())
   217  	}
   218  
   219  	req, err := client.RerunTriggerInstancePreparer(ctx, triggerName, runID)
   220  	if err != nil {
   221  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "RerunTriggerInstance", nil, "Failure preparing request")
   222  		return
   223  	}
   224  
   225  	resp, err := client.RerunTriggerInstanceSender(req)
   226  	if err != nil {
   227  		result.Response = resp
   228  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "RerunTriggerInstance", resp, "Failure sending request")
   229  		return
   230  	}
   231  
   232  	result, err = client.RerunTriggerInstanceResponder(resp)
   233  	if err != nil {
   234  		err = autorest.NewErrorWithError(err, "artifacts.TriggerRunClient", "RerunTriggerInstance", resp, "Failure responding to request")
   235  		return
   236  	}
   237  
   238  	return
   239  }
   240  
   241  // RerunTriggerInstancePreparer prepares the RerunTriggerInstance request.
   242  func (client TriggerRunClient) RerunTriggerInstancePreparer(ctx context.Context, triggerName string, runID string) (*http.Request, error) {
   243  	urlParameters := map[string]interface{}{
   244  		"endpoint": client.Endpoint,
   245  	}
   246  
   247  	pathParameters := map[string]interface{}{
   248  		"runId":       autorest.Encode("path", runID),
   249  		"triggerName": autorest.Encode("path", triggerName),
   250  	}
   251  
   252  	const APIVersion = "2019-06-01-preview"
   253  	queryParameters := map[string]interface{}{
   254  		"api-version": APIVersion,
   255  	}
   256  
   257  	preparer := autorest.CreatePreparer(
   258  		autorest.AsPost(),
   259  		autorest.WithCustomBaseURL("{endpoint}", urlParameters),
   260  		autorest.WithPathParameters("/triggers/{triggerName}/triggerRuns/{runId}/rerun", pathParameters),
   261  		autorest.WithQueryParameters(queryParameters))
   262  	return preparer.Prepare((&http.Request{}).WithContext(ctx))
   263  }
   264  
   265  // RerunTriggerInstanceSender sends the RerunTriggerInstance request. The method will close the
   266  // http.Response Body if it receives an error.
   267  func (client TriggerRunClient) RerunTriggerInstanceSender(req *http.Request) (*http.Response, error) {
   268  	return client.Send(req, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
   269  }
   270  
   271  // RerunTriggerInstanceResponder handles the response to the RerunTriggerInstance request. The method always
   272  // closes the http.Response Body.
   273  func (client TriggerRunClient) RerunTriggerInstanceResponder(resp *http.Response) (result autorest.Response, err error) {
   274  	err = autorest.Respond(
   275  		resp,
   276  		azure.WithErrorUnlessStatusCode(http.StatusOK),
   277  		autorest.ByClosing())
   278  	result.Response = resp
   279  	return
   280  }
   281
View as plain text