Documentation ¶
Index ¶
- type Application
- type ApplicationLanguageEnum
- type ApplicationLifecycleStateEnum
- type ApplicationParameter
- type ApplicationSummary
- type CreateApplicationDetails
- type CreateApplicationRequest
- type CreateApplicationResponse
- type CreateRunDetails
- type CreateRunRequest
- type CreateRunResponse
- type DataFlowClient
- func (client *DataFlowClient) ConfigurationProvider() *common.ConfigurationProvider
- func (client DataFlowClient) CreateApplication(ctx context.Context, request CreateApplicationRequest) (response CreateApplicationResponse, err error)
- func (client DataFlowClient) CreateRun(ctx context.Context, request CreateRunRequest) (response CreateRunResponse, err error)
- func (client DataFlowClient) DeleteApplication(ctx context.Context, request DeleteApplicationRequest) (response DeleteApplicationResponse, err error)
- func (client DataFlowClient) DeleteRun(ctx context.Context, request DeleteRunRequest) (response DeleteRunResponse, err error)
- func (client DataFlowClient) GetApplication(ctx context.Context, request GetApplicationRequest) (response GetApplicationResponse, err error)
- func (client DataFlowClient) GetRun(ctx context.Context, request GetRunRequest) (response GetRunResponse, err error)
- func (client DataFlowClient) GetRunLog(ctx context.Context, request GetRunLogRequest) (response GetRunLogResponse, err error)
- func (client DataFlowClient) ListApplications(ctx context.Context, request ListApplicationsRequest) (response ListApplicationsResponse, err error)
- func (client DataFlowClient) ListRunLogs(ctx context.Context, request ListRunLogsRequest) (response ListRunLogsResponse, err error)
- func (client DataFlowClient) ListRuns(ctx context.Context, request ListRunsRequest) (response ListRunsResponse, err error)
- func (client *DataFlowClient) SetRegion(region string)
- func (client DataFlowClient) UpdateApplication(ctx context.Context, request UpdateApplicationRequest) (response UpdateApplicationResponse, err error)
- func (client DataFlowClient) UpdateRun(ctx context.Context, request UpdateRunRequest) (response UpdateRunResponse, err error)
- type DeleteApplicationRequest
- type DeleteApplicationResponse
- type DeleteRunRequest
- type DeleteRunResponse
- type GetApplicationRequest
- type GetApplicationResponse
- type GetRunLogRequest
- type GetRunLogResponse
- type GetRunRequest
- type GetRunResponse
- type ListApplicationsRequest
- type ListApplicationsResponse
- type ListApplicationsSortByEnum
- type ListApplicationsSortOrderEnum
- type ListRunLogsRequest
- type ListRunLogsResponse
- type ListRunsLifecycleStateEnum
- type ListRunsRequest
- type ListRunsResponse
- type ListRunsSortByEnum
- type ListRunsSortOrderEnum
- type Run
- type RunLifecycleStateEnum
- type RunLogSummary
- type RunLogSummarySourceEnum
- type RunLogSummaryTypeEnum
- type RunSummary
- type UpdateApplicationDetails
- type UpdateApplicationRequest
- type UpdateApplicationResponse
- type UpdateRunDetails
- type UpdateRunRequest
- type UpdateRunResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Application ¶
type Application struct { // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // A user-friendly name. This name is not necessarily unique. DisplayName *string `mandatory:"true" json:"displayName"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"true" json:"driverShape"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"true" json:"executorShape"` // An Oracle Cloud Infrastructure URI of the file containing the application to execute. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat FileUri *string `mandatory:"true" json:"fileUri"` // The application ID. Id *string `mandatory:"true" json:"id"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"true" json:"language"` // The current state of this application. LifecycleState ApplicationLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The number of executor VMs requested. NumExecutors *int `mandatory:"true" json:"numExecutors"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"true" json:"ownerPrincipalId"` // The Spark version utilized to run the application. SparkVersion *string `mandatory:"true" json:"sparkVersion"` // The date and time a application was created, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"` // The date and time a application was updated, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"` // The arguments passed to the running application as command line arguments. An argument is // either a plain text or a placeholder. Placeholders are replaced using values from the parameters // map. Each placeholder specified must be represented in the parameters map else the request // (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as // `Service Api Spec`, where `name` is the name of the parameter. // Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` // If "input_file" has a value of "mydata.xml", then the value above will be translated to // `--input mydata.xml --name "John Doe"` Arguments []string `mandatory:"false" json:"arguments"` // The class for the application. ClassName *string `mandatory:"false" json:"className"` // The Spark configuration passed to the running process. // See https://spark.apache.org/docs/latest/configuration.html#available-properties // Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } // Note: Not all Spark properties are permitted to be set. Attempting to set a property that is // not allowed to be overwritten will cause a 400 status to be returned. Configuration map[string]string `mandatory:"false" json:"configuration"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // A user-friendly description. Description *string `mandatory:"false" json:"description"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` // An Oracle Cloud Infrastructure URI of the bucket where the Spark job logs are to be uploaded. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat LogsBucketUri *string `mandatory:"false" json:"logsBucketUri"` // The username of the user who created the resource. If the username of the owner does not exist, // `null` will be returned and the caller should refer to the ownerPrincipalId value instead. OwnerUserName *string `mandatory:"false" json:"ownerUserName"` // An array of name/value pairs used to fill placeholders found in properties like // `Application.arguments`. The name must be a string of one or more word characters // (a-z, A-Z, 0-9, _). The value can be a string of 0 or more characters of any kind. // Example: [ { name: "iterations", value: "10"}, { name: "input_file", value: "mydata.xml" }, { name: "variable_x", value: "${x}"} ] Parameters []ApplicationParameter `mandatory:"false" json:"parameters"` // An Oracle Cloud Infrastructure URI of the bucket to be used as default warehouse directory // for BATCH SQL runs. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat WarehouseBucketUri *string `mandatory:"false" json:"warehouseBucketUri"` }
Application A data flow application object.
func (Application) String ¶
func (m Application) String() string
type ApplicationLanguageEnum ¶
type ApplicationLanguageEnum string
ApplicationLanguageEnum Enum with underlying type: string
const ( ApplicationLanguageScala ApplicationLanguageEnum = "SCALA" ApplicationLanguageJava ApplicationLanguageEnum = "JAVA" ApplicationLanguagePython ApplicationLanguageEnum = "PYTHON" ApplicationLanguageSql ApplicationLanguageEnum = "SQL" )
Set of constants representing the allowable values for ApplicationLanguageEnum
func GetApplicationLanguageEnumValues ¶
func GetApplicationLanguageEnumValues() []ApplicationLanguageEnum
GetApplicationLanguageEnumValues Enumerates the set of values for ApplicationLanguageEnum
type ApplicationLifecycleStateEnum ¶
type ApplicationLifecycleStateEnum string
ApplicationLifecycleStateEnum Enum with underlying type: string
const ( ApplicationLifecycleStateActive ApplicationLifecycleStateEnum = "ACTIVE" ApplicationLifecycleStateDeleted ApplicationLifecycleStateEnum = "DELETED" ApplicationLifecycleStateInactive ApplicationLifecycleStateEnum = "INACTIVE" )
Set of constants representing the allowable values for ApplicationLifecycleStateEnum
func GetApplicationLifecycleStateEnumValues ¶
func GetApplicationLifecycleStateEnumValues() []ApplicationLifecycleStateEnum
GetApplicationLifecycleStateEnumValues Enumerates the set of values for ApplicationLifecycleStateEnum
type ApplicationParameter ¶
type ApplicationParameter struct { // The name of the parameter. It must be a string of one or more word characters // (a-z, A-Z, 0-9, _). // Examples: "iterations", "input_file" Name *string `mandatory:"true" json:"name"` // The value of the parameter. It must be a string of 0 or more characters of any kind. // Examples: "" (empty string), "10", "mydata.xml", "${x}" Value *string `mandatory:"true" json:"value"` }
ApplicationParameter The parameter of an application.
func (ApplicationParameter) String ¶
func (m ApplicationParameter) String() string
type ApplicationSummary ¶
type ApplicationSummary struct { // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"true" json:"definedTags"` // A user-friendly name. This name is not necessarily unique. DisplayName *string `mandatory:"true" json:"displayName"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"true" json:"freeformTags"` // The application ID. Id *string `mandatory:"true" json:"id"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"true" json:"language"` // The current state of this application. LifecycleState ApplicationLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"true" json:"ownerPrincipalId"` // The date and time a application was created, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"` // The date and time a application was updated, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"` // The username of the user who created the resource. If the username of the owner does not exist, // `null` will be returned and the caller should refer to the ownerPrincipalId value instead. OwnerUserName *string `mandatory:"false" json:"ownerUserName"` }
ApplicationSummary A data flow application object used in bulk listings.
func (ApplicationSummary) String ¶
func (m ApplicationSummary) String() string
type CreateApplicationDetails ¶
type CreateApplicationDetails struct { // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // A user-friendly name. It does not have to be unique. Avoid entering confidential information. DisplayName *string `mandatory:"true" json:"displayName"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"true" json:"driverShape"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"true" json:"executorShape"` // An Oracle Cloud Infrastructure URI of the file containing the application to execute. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat FileUri *string `mandatory:"true" json:"fileUri"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"true" json:"language"` // The number of executor VMs requested. NumExecutors *int `mandatory:"true" json:"numExecutors"` // The Spark version utilized to run the application. SparkVersion *string `mandatory:"true" json:"sparkVersion"` // The arguments passed to the running application as command line arguments. An argument is // either a plain text or a placeholder. Placeholders are replaced using values from the parameters // map. Each placeholder specified must be represented in the parameters map else the request // (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as // `Service Api Spec`, where `name` is the name of the parameter. // Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` // If "input_file" has a value of "mydata.xml", then the value above will be translated to // `--input mydata.xml --name "John Doe"` Arguments []string `mandatory:"false" json:"arguments"` // The class for the application. ClassName *string `mandatory:"false" json:"className"` // The Spark configuration passed to the running process. // See https://spark.apache.org/docs/latest/configuration.html#available-properties // Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } // Note: Not all Spark properties are permitted to be set. Attempting to set a property that is // not allowed to be overwritten will cause a 400 status to be returned. Configuration map[string]string `mandatory:"false" json:"configuration"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // A user-friendly description. Avoid entering confidential information. Description *string `mandatory:"false" json:"description"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` // An Oracle Cloud Infrastructure URI of the bucket where the Spark job logs are to be uploaded. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat LogsBucketUri *string `mandatory:"false" json:"logsBucketUri"` // An array of name/value pairs used to fill placeholders found in properties like // `Application.arguments`. The name must be a string of one or more word characters // (a-z, A-Z, 0-9, _). The value can be a string of 0 or more characters of any kind. // Example: [ { name: "iterations", value: "10"}, { name: "input_file", value: "mydata.xml" }, { name: "variable_x", value: "${x}"} ] Parameters []ApplicationParameter `mandatory:"false" json:"parameters"` // An Oracle Cloud Infrastructure URI of the bucket to be used as default warehouse directory // for BATCH SQL runs. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat WarehouseBucketUri *string `mandatory:"false" json:"warehouseBucketUri"` }
CreateApplicationDetails The create application details.
func (CreateApplicationDetails) String ¶
func (m CreateApplicationDetails) String() string
type CreateApplicationRequest ¶
type CreateApplicationRequest struct { // Details to create an application. CreateApplicationDetails `contributesTo:"body"` // A token that uniquely identifies a request so it can be retried in case of a timeout or server error // without risk of executing that same action again. Retry tokens expire after 24 hours, // but can be invalidated before then due to conflicting operations. // For example, if a resource has been deleted and purged from the system, then a retry of the original creation request may be rejected. OpcRetryToken *string `mandatory:"false" contributesTo:"header" name:"opc-retry-token"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
CreateApplicationRequest wrapper for the CreateApplication operation
func (CreateApplicationRequest) HTTPRequest ¶
func (request CreateApplicationRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (CreateApplicationRequest) RetryPolicy ¶
func (request CreateApplicationRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (CreateApplicationRequest) String ¶
func (request CreateApplicationRequest) String() string
type CreateApplicationResponse ¶
type CreateApplicationResponse struct { // The underlying http response RawResponse *http.Response // The Application instance Application `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
CreateApplicationResponse wrapper for the CreateApplication operation
func (CreateApplicationResponse) HTTPResponse ¶
func (response CreateApplicationResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (CreateApplicationResponse) String ¶
func (response CreateApplicationResponse) String() string
type CreateRunDetails ¶
type CreateRunDetails struct { // The application ID. ApplicationId *string `mandatory:"true" json:"applicationId"` // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // A user-friendly name. It does not have to be unique. Avoid entering confidential information. DisplayName *string `mandatory:"true" json:"displayName"` // The arguments passed to the running application as command line arguments. An argument is // either a plain text or a placeholder. Placeholders are replaced using values from the parameters // map. Each placeholder specified must be represented in the parameters map else the request // (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as // `Service Api Spec`, where `name` is the name of the parameter. // Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` // If "input_file" has a value of "mydata.xml", then the value above will be translated to // `--input mydata.xml --name "John Doe"` Arguments []string `mandatory:"false" json:"arguments"` // The Spark configuration passed to the running process. // See https://spark.apache.org/docs/latest/configuration.html#available-properties // Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } // Note: Not all Spark properties are permitted to be set. Attempting to set a property that is // not allowed to be overwritten will cause a 400 status to be returned. Configuration map[string]string `mandatory:"false" json:"configuration"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"false" json:"driverShape"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"false" json:"executorShape"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` // An Oracle Cloud Infrastructure URI of the bucket where the Spark job logs are to be uploaded. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat LogsBucketUri *string `mandatory:"false" json:"logsBucketUri"` // The number of executor VMs requested. NumExecutors *int `mandatory:"false" json:"numExecutors"` // An array of name/value pairs used to fill placeholders found in properties like // `Application.arguments`. The name must be a string of one or more word characters // (a-z, A-Z, 0-9, _). The value can be a string of 0 or more characters of any kind. // Example: [ { name: "iterations", value: "10"}, { name: "input_file", value: "mydata.xml" }, { name: "variable_x", value: "${x}"} ] Parameters []ApplicationParameter `mandatory:"false" json:"parameters"` // An Oracle Cloud Infrastructure URI of the bucket to be used as default warehouse directory // for BATCH SQL runs. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat WarehouseBucketUri *string `mandatory:"false" json:"warehouseBucketUri"` }
CreateRunDetails The create run details. The following properties are optional and override the default values set in the associated application:
- arguments
- configuration
- definedTags
- driverShape
- executorShape
- freeformTags
- logsBucketUri
- numExecutors
- parameters
- warehouseBucketUri
If the optional properties are not specified, they are copied over from the parent application. Once a run is created, its properties (except for definedTags and freeformTags) cannot be changed. If the parent application's properties (including definedTags and freeformTags) are updated, the corresponding properties of the run will not update.
func (CreateRunDetails) String ¶
func (m CreateRunDetails) String() string
type CreateRunRequest ¶
type CreateRunRequest struct { // Details for creating a run of an application. CreateRunDetails `contributesTo:"body"` // A token that uniquely identifies a request so it can be retried in case of a timeout or server error // without risk of executing that same action again. Retry tokens expire after 24 hours, // but can be invalidated before then due to conflicting operations. // For example, if a resource has been deleted and purged from the system, then a retry of the original creation request may be rejected. OpcRetryToken *string `mandatory:"false" contributesTo:"header" name:"opc-retry-token"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
CreateRunRequest wrapper for the CreateRun operation
func (CreateRunRequest) HTTPRequest ¶
func (request CreateRunRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (CreateRunRequest) RetryPolicy ¶
func (request CreateRunRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (CreateRunRequest) String ¶
func (request CreateRunRequest) String() string
type CreateRunResponse ¶
type CreateRunResponse struct { // The underlying http response RawResponse *http.Response // The Run instance Run `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
CreateRunResponse wrapper for the CreateRun operation
func (CreateRunResponse) HTTPResponse ¶
func (response CreateRunResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (CreateRunResponse) String ¶
func (response CreateRunResponse) String() string
type DataFlowClient ¶
type DataFlowClient struct { common.BaseClient // contains filtered or unexported fields }
DataFlowClient a client for DataFlow
func NewDataFlowClientWithConfigurationProvider ¶
func NewDataFlowClientWithConfigurationProvider(configProvider common.ConfigurationProvider) (client DataFlowClient, err error)
NewDataFlowClientWithConfigurationProvider Creates a new default DataFlow client with the given configuration provider. the configuration provider will be used for the default signer as well as reading the region
func NewDataFlowClientWithOboToken ¶
func NewDataFlowClientWithOboToken(configProvider common.ConfigurationProvider, oboToken string) (client DataFlowClient, err error)
NewDataFlowClientWithOboToken Creates a new default DataFlow client with the given configuration provider. The obotoken will be added to default headers and signed; the configuration provider will be used for the signer
as well as reading the region
func (*DataFlowClient) ConfigurationProvider ¶
func (client *DataFlowClient) ConfigurationProvider() *common.ConfigurationProvider
ConfigurationProvider the ConfigurationProvider used in this client, or null if none set
func (DataFlowClient) CreateApplication ¶
func (client DataFlowClient) CreateApplication(ctx context.Context, request CreateApplicationRequest) (response CreateApplicationResponse, err error)
CreateApplication Creates an application.
func (DataFlowClient) CreateRun ¶
func (client DataFlowClient) CreateRun(ctx context.Context, request CreateRunRequest) (response CreateRunResponse, err error)
CreateRun Creates a run for an application.
func (DataFlowClient) DeleteApplication ¶
func (client DataFlowClient) DeleteApplication(ctx context.Context, request DeleteApplicationRequest) (response DeleteApplicationResponse, err error)
DeleteApplication Deletes an application using an `applicationId`.
func (DataFlowClient) DeleteRun ¶
func (client DataFlowClient) DeleteRun(ctx context.Context, request DeleteRunRequest) (response DeleteRunResponse, err error)
DeleteRun Cancels the specified run if it has not already completed or was previously cancelled. If a run is in progress, the executing job will be killed.
func (DataFlowClient) GetApplication ¶
func (client DataFlowClient) GetApplication(ctx context.Context, request GetApplicationRequest) (response GetApplicationResponse, err error)
GetApplication Retrieves an application using an `applicationId`.
func (DataFlowClient) GetRun ¶
func (client DataFlowClient) GetRun(ctx context.Context, request GetRunRequest) (response GetRunResponse, err error)
GetRun Retrieves the run for the specified `runId`.
func (DataFlowClient) GetRunLog ¶
func (client DataFlowClient) GetRunLog(ctx context.Context, request GetRunLogRequest) (response GetRunLogResponse, err error)
GetRunLog Retrieves the content of an run log.
func (DataFlowClient) ListApplications ¶
func (client DataFlowClient) ListApplications(ctx context.Context, request ListApplicationsRequest) (response ListApplicationsResponse, err error)
ListApplications Lists all applications in the specified compartment.
func (DataFlowClient) ListRunLogs ¶
func (client DataFlowClient) ListRunLogs(ctx context.Context, request ListRunLogsRequest) (response ListRunLogsResponse, err error)
ListRunLogs Retrieves summaries of the run's logs.
func (DataFlowClient) ListRuns ¶
func (client DataFlowClient) ListRuns(ctx context.Context, request ListRunsRequest) (response ListRunsResponse, err error)
ListRuns Lists all runs of an application in the specified compartment.
func (*DataFlowClient) SetRegion ¶
func (client *DataFlowClient) SetRegion(region string)
SetRegion overrides the region of this client.
func (DataFlowClient) UpdateApplication ¶
func (client DataFlowClient) UpdateApplication(ctx context.Context, request UpdateApplicationRequest) (response UpdateApplicationResponse, err error)
UpdateApplication Updates an application using an `applicationId`.
func (DataFlowClient) UpdateRun ¶
func (client DataFlowClient) UpdateRun(ctx context.Context, request UpdateRunRequest) (response UpdateRunResponse, err error)
UpdateRun Updates a run using a `runId`.
type DeleteApplicationRequest ¶
type DeleteApplicationRequest struct { // The unique ID for an application. ApplicationId *string `mandatory:"true" contributesTo:"path" name:"applicationId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // For optimistic concurrency control. In the PUT or DELETE call for a resource, // set the `if-match` parameter to the value of the etag from a previous GET or POST response for that resource. // The resource will be updated or deleted only if the etag you provide matches the resource's current etag value. IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
DeleteApplicationRequest wrapper for the DeleteApplication operation
func (DeleteApplicationRequest) HTTPRequest ¶
func (request DeleteApplicationRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (DeleteApplicationRequest) RetryPolicy ¶
func (request DeleteApplicationRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (DeleteApplicationRequest) String ¶
func (request DeleteApplicationRequest) String() string
type DeleteApplicationResponse ¶
type DeleteApplicationResponse struct { // The underlying http response RawResponse *http.Response // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
DeleteApplicationResponse wrapper for the DeleteApplication operation
func (DeleteApplicationResponse) HTTPResponse ¶
func (response DeleteApplicationResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (DeleteApplicationResponse) String ¶
func (response DeleteApplicationResponse) String() string
type DeleteRunRequest ¶
type DeleteRunRequest struct { // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // For optimistic concurrency control. In the PUT or DELETE call for a resource, // set the `if-match` parameter to the value of the etag from a previous GET or POST response for that resource. // The resource will be updated or deleted only if the etag you provide matches the resource's current etag value. IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
DeleteRunRequest wrapper for the DeleteRun operation
func (DeleteRunRequest) HTTPRequest ¶
func (request DeleteRunRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (DeleteRunRequest) RetryPolicy ¶
func (request DeleteRunRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (DeleteRunRequest) String ¶
func (request DeleteRunRequest) String() string
type DeleteRunResponse ¶
type DeleteRunResponse struct { // The underlying http response RawResponse *http.Response // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
DeleteRunResponse wrapper for the DeleteRun operation
func (DeleteRunResponse) HTTPResponse ¶
func (response DeleteRunResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (DeleteRunResponse) String ¶
func (response DeleteRunResponse) String() string
type GetApplicationRequest ¶
type GetApplicationRequest struct { // The unique ID for an application. ApplicationId *string `mandatory:"true" contributesTo:"path" name:"applicationId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
GetApplicationRequest wrapper for the GetApplication operation
func (GetApplicationRequest) HTTPRequest ¶
func (request GetApplicationRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (GetApplicationRequest) RetryPolicy ¶
func (request GetApplicationRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (GetApplicationRequest) String ¶
func (request GetApplicationRequest) String() string
type GetApplicationResponse ¶
type GetApplicationResponse struct { // The underlying http response RawResponse *http.Response // The Application instance Application `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
GetApplicationResponse wrapper for the GetApplication operation
func (GetApplicationResponse) HTTPResponse ¶
func (response GetApplicationResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (GetApplicationResponse) String ¶
func (response GetApplicationResponse) String() string
type GetRunLogRequest ¶
type GetRunLogRequest struct { // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // The name of the log. Avoid entering confidential information. Name *string `mandatory:"true" contributesTo:"path" name:"name"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
GetRunLogRequest wrapper for the GetRunLog operation
func (GetRunLogRequest) HTTPRequest ¶
func (request GetRunLogRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (GetRunLogRequest) RetryPolicy ¶
func (request GetRunLogRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (GetRunLogRequest) String ¶
func (request GetRunLogRequest) String() string
type GetRunLogResponse ¶
type GetRunLogResponse struct { // The underlying http response RawResponse *http.Response // The io.ReadCloser instance Content io.ReadCloser `presentIn:"body" encoding:"binary"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Indicates the size of the data as described in RFC 2616, section 14.13. ContentLength *int64 `presentIn:"header" name:"content-length"` // Specifies the media type of the underlying data as described in RFC 2616, section 14.17. ContentType *string `presentIn:"header" name:"content-type"` // Indicates the encoding of the data, as described in RFC 2616, section 14.11. ContentEncoding *string `presentIn:"header" name:"content-encoding"` // The user-defined metadata for the log. OpcMeta map[string]string `presentIn:"header-collection" prefix:"opc-meta-"` }
GetRunLogResponse wrapper for the GetRunLog operation
func (GetRunLogResponse) HTTPResponse ¶
func (response GetRunLogResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (GetRunLogResponse) String ¶
func (response GetRunLogResponse) String() string
type GetRunRequest ¶
type GetRunRequest struct { // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
GetRunRequest wrapper for the GetRun operation
func (GetRunRequest) HTTPRequest ¶
func (request GetRunRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (GetRunRequest) RetryPolicy ¶
func (request GetRunRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (GetRunRequest) String ¶
func (request GetRunRequest) String() string
type GetRunResponse ¶
type GetRunResponse struct { // The underlying http response RawResponse *http.Response // The Run instance Run `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
GetRunResponse wrapper for the GetRun operation
func (GetRunResponse) HTTPResponse ¶
func (response GetRunResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (GetRunResponse) String ¶
func (response GetRunResponse) String() string
type ListApplicationsRequest ¶
type ListApplicationsRequest struct { // The OCID of the compartment. CompartmentId *string `mandatory:"true" contributesTo:"query" name:"compartmentId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // The maximum number of results to return in a paginated `List` call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // The value of the `opc-next-page` or `opc-prev-page` response header from the last `List` call // to sent back to server for getting the next page of results. Page *string `mandatory:"false" contributesTo:"query" name:"page"` // The field used to sort the results. Multiple fields are not supported. SortBy ListApplicationsSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"` // The ordering of results in ascending or descending order. SortOrder ListApplicationsSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"` // The query parameter for the Spark application name. DisplayName *string `mandatory:"false" contributesTo:"query" name:"displayName"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"false" contributesTo:"query" name:"ownerPrincipalId"` // The displayName prefix. DisplayNameStartsWith *string `mandatory:"false" contributesTo:"query" name:"displayNameStartsWith"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
ListApplicationsRequest wrapper for the ListApplications operation
func (ListApplicationsRequest) HTTPRequest ¶
func (request ListApplicationsRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListApplicationsRequest) RetryPolicy ¶
func (request ListApplicationsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListApplicationsRequest) String ¶
func (request ListApplicationsRequest) String() string
type ListApplicationsResponse ¶
type ListApplicationsResponse struct { // The underlying http response RawResponse *http.Response // A list of []ApplicationSummary instances Items []ApplicationSummary `presentIn:"body"` // Retrieves the previous page of results. // When this header appears in the response, previous pages of results exist. // See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"` // Retrieves the next page of results. When this header appears in the response, // additional pages of results remain. See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcNextPage *string `presentIn:"header" name:"opc-next-page"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
ListApplicationsResponse wrapper for the ListApplications operation
func (ListApplicationsResponse) HTTPResponse ¶
func (response ListApplicationsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListApplicationsResponse) String ¶
func (response ListApplicationsResponse) String() string
type ListApplicationsSortByEnum ¶
type ListApplicationsSortByEnum string
ListApplicationsSortByEnum Enum with underlying type: string
const ( ListApplicationsSortByTimecreated ListApplicationsSortByEnum = "timeCreated" ListApplicationsSortByDisplayname ListApplicationsSortByEnum = "displayName" ListApplicationsSortByLanguage ListApplicationsSortByEnum = "language" )
Set of constants representing the allowable values for ListApplicationsSortByEnum
func GetListApplicationsSortByEnumValues ¶
func GetListApplicationsSortByEnumValues() []ListApplicationsSortByEnum
GetListApplicationsSortByEnumValues Enumerates the set of values for ListApplicationsSortByEnum
type ListApplicationsSortOrderEnum ¶
type ListApplicationsSortOrderEnum string
ListApplicationsSortOrderEnum Enum with underlying type: string
const ( ListApplicationsSortOrderAsc ListApplicationsSortOrderEnum = "ASC" ListApplicationsSortOrderDesc ListApplicationsSortOrderEnum = "DESC" )
Set of constants representing the allowable values for ListApplicationsSortOrderEnum
func GetListApplicationsSortOrderEnumValues ¶
func GetListApplicationsSortOrderEnumValues() []ListApplicationsSortOrderEnum
GetListApplicationsSortOrderEnumValues Enumerates the set of values for ListApplicationsSortOrderEnum
type ListRunLogsRequest ¶
type ListRunLogsRequest struct { // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // The maximum number of results to return in a paginated "List" call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // The value of the `opc-next-page` or `opc-prev-page` response header from the last `List` call // to sent back to server for getting the next page of results. Page *string `mandatory:"false" contributesTo:"query" name:"page"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
ListRunLogsRequest wrapper for the ListRunLogs operation
func (ListRunLogsRequest) HTTPRequest ¶
func (request ListRunLogsRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListRunLogsRequest) RetryPolicy ¶
func (request ListRunLogsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListRunLogsRequest) String ¶
func (request ListRunLogsRequest) String() string
type ListRunLogsResponse ¶
type ListRunLogsResponse struct { // The underlying http response RawResponse *http.Response // A list of []RunLogSummary instances Items []RunLogSummary `presentIn:"body"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` // Retrieves the previous page of results. // When this header appears in the response, previous pages of results exist. // See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"` // Retrieves the next page of results. When this header appears in the response, // additional pages of results remain. See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcNextPage *string `presentIn:"header" name:"opc-next-page"` }
ListRunLogsResponse wrapper for the ListRunLogs operation
func (ListRunLogsResponse) HTTPResponse ¶
func (response ListRunLogsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListRunLogsResponse) String ¶
func (response ListRunLogsResponse) String() string
type ListRunsLifecycleStateEnum ¶
type ListRunsLifecycleStateEnum string
ListRunsLifecycleStateEnum Enum with underlying type: string
const ( ListRunsLifecycleStateAccepted ListRunsLifecycleStateEnum = "ACCEPTED" ListRunsLifecycleStateInProgress ListRunsLifecycleStateEnum = "IN_PROGRESS" ListRunsLifecycleStateCanceling ListRunsLifecycleStateEnum = "CANCELING" ListRunsLifecycleStateCanceled ListRunsLifecycleStateEnum = "CANCELED" ListRunsLifecycleStateFailed ListRunsLifecycleStateEnum = "FAILED" ListRunsLifecycleStateSucceeded ListRunsLifecycleStateEnum = "SUCCEEDED" )
Set of constants representing the allowable values for ListRunsLifecycleStateEnum
func GetListRunsLifecycleStateEnumValues ¶
func GetListRunsLifecycleStateEnumValues() []ListRunsLifecycleStateEnum
GetListRunsLifecycleStateEnumValues Enumerates the set of values for ListRunsLifecycleStateEnum
type ListRunsRequest ¶
type ListRunsRequest struct { // The OCID of the compartment. CompartmentId *string `mandatory:"true" contributesTo:"query" name:"compartmentId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // The ID of the application. ApplicationId *string `mandatory:"false" contributesTo:"query" name:"applicationId"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"false" contributesTo:"query" name:"ownerPrincipalId"` // The displayName prefix. DisplayNameStartsWith *string `mandatory:"false" contributesTo:"query" name:"displayNameStartsWith"` // The LifecycleState of the run. LifecycleState ListRunsLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"` // The epoch time that the resource was created. TimeCreatedGreaterThan *common.SDKTime `mandatory:"false" contributesTo:"query" name:"timeCreatedGreaterThan"` // The maximum number of results to return in a paginated `List` call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // The value of the `opc-next-page` or `opc-prev-page` response header from the last `List` call // to sent back to server for getting the next page of results. Page *string `mandatory:"false" contributesTo:"query" name:"page"` // The field used to sort the results. Multiple fields are not supported. SortBy ListRunsSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"` // The ordering of results in ascending or descending order. SortOrder ListRunsSortOrderEnum `mandatory:"false" contributesTo:"query" name:"sortOrder" omitEmpty:"true"` // The query parameter for the Spark application name. DisplayName *string `mandatory:"false" contributesTo:"query" name:"displayName"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
ListRunsRequest wrapper for the ListRuns operation
func (ListRunsRequest) HTTPRequest ¶
func (request ListRunsRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListRunsRequest) RetryPolicy ¶
func (request ListRunsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListRunsRequest) String ¶
func (request ListRunsRequest) String() string
type ListRunsResponse ¶
type ListRunsResponse struct { // The underlying http response RawResponse *http.Response // A list of []RunSummary instances Items []RunSummary `presentIn:"body"` // Retrieves the previous page of results. // When this header appears in the response, previous pages of results exist. // See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcPrevPage *string `presentIn:"header" name:"opc-prev-page"` // Retrieves the next page of results. When this header appears in the response, // additional pages of results remain. See List Pagination (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#nine). OpcNextPage *string `presentIn:"header" name:"opc-next-page"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
ListRunsResponse wrapper for the ListRuns operation
func (ListRunsResponse) HTTPResponse ¶
func (response ListRunsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListRunsResponse) String ¶
func (response ListRunsResponse) String() string
type ListRunsSortByEnum ¶
type ListRunsSortByEnum string
ListRunsSortByEnum Enum with underlying type: string
const ( ListRunsSortByTimecreated ListRunsSortByEnum = "timeCreated" ListRunsSortByDisplayname ListRunsSortByEnum = "displayName" ListRunsSortByLanguage ListRunsSortByEnum = "language" ListRunsSortByRundurationinmilliseconds ListRunsSortByEnum = "runDurationInMilliseconds" ListRunsSortByLifecyclestate ListRunsSortByEnum = "lifecycleState" ListRunsSortByTotalocpu ListRunsSortByEnum = "totalOCpu" ListRunsSortByDatareadinbytes ListRunsSortByEnum = "dataReadInBytes" ListRunsSortByDatawritteninbytes ListRunsSortByEnum = "dataWrittenInBytes" )
Set of constants representing the allowable values for ListRunsSortByEnum
func GetListRunsSortByEnumValues ¶
func GetListRunsSortByEnumValues() []ListRunsSortByEnum
GetListRunsSortByEnumValues Enumerates the set of values for ListRunsSortByEnum
type ListRunsSortOrderEnum ¶
type ListRunsSortOrderEnum string
ListRunsSortOrderEnum Enum with underlying type: string
const ( ListRunsSortOrderAsc ListRunsSortOrderEnum = "ASC" ListRunsSortOrderDesc ListRunsSortOrderEnum = "DESC" )
Set of constants representing the allowable values for ListRunsSortOrderEnum
func GetListRunsSortOrderEnumValues ¶
func GetListRunsSortOrderEnumValues() []ListRunsSortOrderEnum
GetListRunsSortOrderEnumValues Enumerates the set of values for ListRunsSortOrderEnum
type Run ¶
type Run struct { // The application ID. ApplicationId *string `mandatory:"true" json:"applicationId"` // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"true" json:"driverShape"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"true" json:"executorShape"` // An Oracle Cloud Infrastructure URI of the file containing the application to execute. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat FileUri *string `mandatory:"true" json:"fileUri"` // The ID of a run. Id *string `mandatory:"true" json:"id"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"true" json:"language"` // The current state of this run. LifecycleState RunLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The number of executor VMs requested. NumExecutors *int `mandatory:"true" json:"numExecutors"` // The Spark version utilized to run the application. SparkVersion *string `mandatory:"true" json:"sparkVersion"` // The date and time a application was created, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"` // The date and time a application was updated, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"` // The arguments passed to the running application as command line arguments. An argument is // either a plain text or a placeholder. Placeholders are replaced using values from the parameters // map. Each placeholder specified must be represented in the parameters map else the request // (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as // `Service Api Spec`, where `name` is the name of the parameter. // Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` // If "input_file" has a value of "mydata.xml", then the value above will be translated to // `--input mydata.xml --name "John Doe"` Arguments []string `mandatory:"false" json:"arguments"` // The class for the application. ClassName *string `mandatory:"false" json:"className"` // The Spark configuration passed to the running process. // See https://spark.apache.org/docs/latest/configuration.html#available-properties // Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } // Note: Not all Spark properties are permitted to be set. Attempting to set a property that is // not allowed to be overwritten will cause a 400 status to be returned. Configuration map[string]string `mandatory:"false" json:"configuration"` // The data read by the run in bytes. DataReadInBytes *int64 `mandatory:"false" json:"dataReadInBytes"` // The data written by the run in bytes. DataWrittenInBytes *int64 `mandatory:"false" json:"dataWrittenInBytes"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // A user-friendly name. This name is not necessarily unique. DisplayName *string `mandatory:"false" json:"displayName"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` // The detailed messages about the lifecycle state. LifecycleDetails *string `mandatory:"false" json:"lifecycleDetails"` // An Oracle Cloud Infrastructure URI of the bucket where the Spark job logs are to be uploaded. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat LogsBucketUri *string `mandatory:"false" json:"logsBucketUri"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `mandatory:"false" json:"opcRequestId"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"false" json:"ownerPrincipalId"` // The username of the user who created the resource. If the username of the owner does not exist, // `null` will be returned and the caller should refer to the ownerPrincipalId value instead. OwnerUserName *string `mandatory:"false" json:"ownerUserName"` // An array of name/value pairs used to fill placeholders found in properties like // `Application.arguments`. The name must be a string of one or more word characters // (a-z, A-Z, 0-9, _). The value can be a string of 0 or more characters of any kind. // Example: [ { name: "iterations", value: "10"}, { name: "input_file", value: "mydata.xml" }, { name: "variable_x", value: "${x}"} ] Parameters []ApplicationParameter `mandatory:"false" json:"parameters"` // The duration of the run in milliseconds. RunDurationInMilliseconds *int64 `mandatory:"false" json:"runDurationInMilliseconds"` // The total number of oCPU requested by the run. TotalOCpu *int `mandatory:"false" json:"totalOCpu"` // An Oracle Cloud Infrastructure URI of the bucket to be used as default warehouse directory // for BATCH SQL runs. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat WarehouseBucketUri *string `mandatory:"false" json:"warehouseBucketUri"` }
Run A run object.
type RunLifecycleStateEnum ¶
type RunLifecycleStateEnum string
RunLifecycleStateEnum Enum with underlying type: string
const ( RunLifecycleStateAccepted RunLifecycleStateEnum = "ACCEPTED" RunLifecycleStateInProgress RunLifecycleStateEnum = "IN_PROGRESS" RunLifecycleStateCanceling RunLifecycleStateEnum = "CANCELING" RunLifecycleStateCanceled RunLifecycleStateEnum = "CANCELED" RunLifecycleStateFailed RunLifecycleStateEnum = "FAILED" RunLifecycleStateSucceeded RunLifecycleStateEnum = "SUCCEEDED" )
Set of constants representing the allowable values for RunLifecycleStateEnum
func GetRunLifecycleStateEnumValues ¶
func GetRunLifecycleStateEnumValues() []RunLifecycleStateEnum
GetRunLifecycleStateEnumValues Enumerates the set of values for RunLifecycleStateEnum
type RunLogSummary ¶
type RunLogSummary struct { // The name of the log. // Example: spark_driver_stderr_20190917T114000Z.log.gz Name *string `mandatory:"true" json:"name"` // The runId associated with the log. RunId *string `mandatory:"true" json:"runId"` // The source of the log such as driver and executor. Source RunLogSummarySourceEnum `mandatory:"true" json:"source"` // The type of log such as stdout and stderr. Type RunLogSummaryTypeEnum `mandatory:"true" json:"type"` // The size of the object in bytes. SizeInBytes *int64 `mandatory:"false" json:"sizeInBytes"` // The date and time the object was created, as described in RFC 2616 (https://tools.ietf.org/rfc/rfc2616), section 14.29. TimeCreated *common.SDKTime `mandatory:"false" json:"timeCreated"` }
RunLogSummary A summary of a log associated with a particular run.
func (RunLogSummary) String ¶
func (m RunLogSummary) String() string
type RunLogSummarySourceEnum ¶
type RunLogSummarySourceEnum string
RunLogSummarySourceEnum Enum with underlying type: string
const ( RunLogSummarySourceApplication RunLogSummarySourceEnum = "APPLICATION" RunLogSummarySourceDriver RunLogSummarySourceEnum = "DRIVER" RunLogSummarySourceExecutor RunLogSummarySourceEnum = "EXECUTOR" )
Set of constants representing the allowable values for RunLogSummarySourceEnum
func GetRunLogSummarySourceEnumValues ¶
func GetRunLogSummarySourceEnumValues() []RunLogSummarySourceEnum
GetRunLogSummarySourceEnumValues Enumerates the set of values for RunLogSummarySourceEnum
type RunLogSummaryTypeEnum ¶
type RunLogSummaryTypeEnum string
RunLogSummaryTypeEnum Enum with underlying type: string
const ( RunLogSummaryTypeStderr RunLogSummaryTypeEnum = "STDERR" RunLogSummaryTypeStdout RunLogSummaryTypeEnum = "STDOUT" )
Set of constants representing the allowable values for RunLogSummaryTypeEnum
func GetRunLogSummaryTypeEnumValues ¶
func GetRunLogSummaryTypeEnumValues() []RunLogSummaryTypeEnum
GetRunLogSummaryTypeEnumValues Enumerates the set of values for RunLogSummaryTypeEnum
type RunSummary ¶
type RunSummary struct { // The application ID. ApplicationId *string `mandatory:"true" json:"applicationId"` // The OCID of the compartment that contains this application. CompartmentId *string `mandatory:"true" json:"compartmentId"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"true" json:"definedTags"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"true" json:"freeformTags"` // The ID of a run. Id *string `mandatory:"true" json:"id"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"true" json:"language"` // The current state of this run. LifecycleState RunLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The date and time a application was created, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeCreated *common.SDKTime `mandatory:"true" json:"timeCreated"` // The date and time a application was updated, expressed in RFC 3339 (https://tools.ietf.org/html/rfc3339) timestamp format. // Example: `2018-04-03T21:10:29.600Z` TimeUpdated *common.SDKTime `mandatory:"true" json:"timeUpdated"` // The data read by the run in bytes. DataReadInBytes *int64 `mandatory:"false" json:"dataReadInBytes"` // The data written by the run in bytes. DataWrittenInBytes *int64 `mandatory:"false" json:"dataWrittenInBytes"` // A user-friendly name. This name is not necessarily unique. DisplayName *string `mandatory:"false" json:"displayName"` // The detailed messages about the lifecycle state. LifecycleDetails *string `mandatory:"false" json:"lifecycleDetails"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `mandatory:"false" json:"opcRequestId"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"false" json:"ownerPrincipalId"` // The username of the user who created the resource. If the username of the owner does not exist, // `null` will be returned and the caller should refer to the ownerPrincipalId value instead. OwnerUserName *string `mandatory:"false" json:"ownerUserName"` // The duration of the run in milliseconds. RunDurationInMilliseconds *int64 `mandatory:"false" json:"runDurationInMilliseconds"` // The total number of oCPU requested by the run. TotalOCpu *int `mandatory:"false" json:"totalOCpu"` }
RunSummary A summary of the run.
func (RunSummary) String ¶
func (m RunSummary) String() string
type UpdateApplicationDetails ¶
type UpdateApplicationDetails struct { // The class for the application. ClassName *string `mandatory:"false" json:"className"` // An Oracle Cloud Infrastructure URI of the file containing the application to execute. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat FileUri *string `mandatory:"false" json:"fileUri"` // The Spark version utilized to run the application. SparkVersion *string `mandatory:"false" json:"sparkVersion"` // The Spark language. Language ApplicationLanguageEnum `mandatory:"false" json:"language,omitempty"` // The arguments passed to the running application as command line arguments. An argument is // either a plain text or a placeholder. Placeholders are replaced using values from the parameters // map. Each placeholder specified must be represented in the parameters map else the request // (POST or PUT) will fail with a HTTP 400 status code. Placeholders are specified as // `Service Api Spec`, where `name` is the name of the parameter. // Example: `[ "--input", "${input_file}", "--name", "John Doe" ]` // If "input_file" has a value of "mydata.xml", then the value above will be translated to // `--input mydata.xml --name "John Doe"` Arguments []string `mandatory:"false" json:"arguments"` // The Spark configuration passed to the running process. // See https://spark.apache.org/docs/latest/configuration.html#available-properties // Example: { "spark.app.name" : "My App Name", "spark.shuffle.io.maxRetries" : "4" } // Note: Not all Spark properties are permitted to be set. Attempting to set a property that is // not allowed to be overwritten will cause a 400 status to be returned. Configuration map[string]string `mandatory:"false" json:"configuration"` // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // A user-friendly description. Avoid entering confidential information. Description *string `mandatory:"false" json:"description"` // A user-friendly name. It does not have to be unique. Avoid entering confidential information. DisplayName *string `mandatory:"false" json:"displayName"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"false" json:"driverShape"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"false" json:"executorShape"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` // An Oracle Cloud Infrastructure URI of the bucket where the Spark job logs are to be uploaded. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat LogsBucketUri *string `mandatory:"false" json:"logsBucketUri"` // The number of executor VMs requested. NumExecutors *int `mandatory:"false" json:"numExecutors"` // An array of name/value pairs used to fill placeholders found in properties like // `Application.arguments`. The name must be a string of one or more word characters // (a-z, A-Z, 0-9, _). The value can be a string of 0 or more characters of any kind. // Example: [ { name: "iterations", value: "10"}, { name: "input_file", value: "mydata.xml" }, { name: "variable_x", value: "${x}"} ] Parameters []ApplicationParameter `mandatory:"false" json:"parameters"` // An Oracle Cloud Infrastructure URI of the bucket to be used as default warehouse directory // for BATCH SQL runs. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat WarehouseBucketUri *string `mandatory:"false" json:"warehouseBucketUri"` }
UpdateApplicationDetails The update application details.
func (UpdateApplicationDetails) String ¶
func (m UpdateApplicationDetails) String() string
type UpdateApplicationRequest ¶
type UpdateApplicationRequest struct { // Details for updating an application. UpdateApplicationDetails `contributesTo:"body"` // The unique ID for an application. ApplicationId *string `mandatory:"true" contributesTo:"path" name:"applicationId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // For optimistic concurrency control. In the PUT or DELETE call for a resource, // set the `if-match` parameter to the value of the etag from a previous GET or POST response for that resource. // The resource will be updated or deleted only if the etag you provide matches the resource's current etag value. IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
UpdateApplicationRequest wrapper for the UpdateApplication operation
func (UpdateApplicationRequest) HTTPRequest ¶
func (request UpdateApplicationRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (UpdateApplicationRequest) RetryPolicy ¶
func (request UpdateApplicationRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (UpdateApplicationRequest) String ¶
func (request UpdateApplicationRequest) String() string
type UpdateApplicationResponse ¶
type UpdateApplicationResponse struct { // The underlying http response RawResponse *http.Response // The Application instance Application `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
UpdateApplicationResponse wrapper for the UpdateApplication operation
func (UpdateApplicationResponse) HTTPResponse ¶
func (response UpdateApplicationResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (UpdateApplicationResponse) String ¶
func (response UpdateApplicationResponse) String() string
type UpdateRunDetails ¶
type UpdateRunDetails struct { // Defined tags for this resource. Each key is predefined and scoped to a namespace. For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Operations": {"CostCenter": "42"}}` DefinedTags map[string]map[string]interface{} `mandatory:"false" json:"definedTags"` // Free-form tags for this resource. Each tag is a simple key-value pair with no predefined name, type, or namespace. // For more information, see Resource Tags (https://docs.cloud.oracle.com/iaas/Content/General/Concepts/resourcetags.htm). // Example: `{"Department": "Finance"}` FreeformTags map[string]string `mandatory:"false" json:"freeformTags"` }
UpdateRunDetails The update run details. Only the tags of a run can be updated.
func (UpdateRunDetails) String ¶
func (m UpdateRunDetails) String() string
type UpdateRunRequest ¶
type UpdateRunRequest struct { // Details for updating a run. UpdateRunDetails `contributesTo:"body"` // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // Unique identifier for the request. If provided, the returned request ID will include this value. // Otherwise, a random request ID will be generated by the service. OpcRequestId *string `mandatory:"false" contributesTo:"header" name:"opc-request-id"` // For optimistic concurrency control. In the PUT or DELETE call for a resource, // set the `if-match` parameter to the value of the etag from a previous GET or POST response for that resource. // The resource will be updated or deleted only if the etag you provide matches the resource's current etag value. IfMatch *string `mandatory:"false" contributesTo:"header" name:"if-match"` // Metadata about the request. This information will not be transmitted to the service, but // represents information that the SDK will consume to drive retry behavior. RequestMetadata common.RequestMetadata }
UpdateRunRequest wrapper for the UpdateRun operation
func (UpdateRunRequest) HTTPRequest ¶
func (request UpdateRunRequest) HTTPRequest(method, path string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (UpdateRunRequest) RetryPolicy ¶
func (request UpdateRunRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (UpdateRunRequest) String ¶
func (request UpdateRunRequest) String() string
type UpdateRunResponse ¶
type UpdateRunResponse struct { // The underlying http response RawResponse *http.Response // The Run instance Run `presentIn:"body"` // For optimistic concurrency control. // See ETags for Optimistic Concurrency Control (https://docs.cloud.oracle.com/iaas/Content/API/Concepts/usingapi.htm#eleven). Etag *string `presentIn:"header" name:"etag"` // Unique Oracle-assigned identifier for the request. // If you need to contact Oracle about a particular request, please provide the request ID. OpcRequestId *string `presentIn:"header" name:"opc-request-id"` }
UpdateRunResponse wrapper for the UpdateRun operation
func (UpdateRunResponse) HTTPResponse ¶
func (response UpdateRunResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (UpdateRunResponse) String ¶
func (response UpdateRunResponse) String() string
Source Files ¶
- application.go
- application_language.go
- application_lifecycle_state.go
- application_parameter.go
- application_summary.go
- create_application_details.go
- create_application_request_response.go
- create_run_details.go
- create_run_request_response.go
- dataflow_client.go
- delete_application_request_response.go
- delete_run_request_response.go
- get_application_request_response.go
- get_run_log_request_response.go
- get_run_request_response.go
- list_applications_request_response.go
- list_run_logs_request_response.go
- list_runs_request_response.go
- run.go
- run_lifecycle_state.go
- run_log_summary.go
- run_summary.go
- update_application_details.go
- update_application_request_response.go
- update_run_details.go
- update_run_request_response.go