Documentation
¶
Index ¶
- func GetApplicationLanguageEnumStringValues() []string
- func GetApplicationLifecycleStateEnumStringValues() []string
- func GetApplicationTypeEnumStringValues() []string
- func GetListApplicationsSortByEnumStringValues() []string
- func GetListApplicationsSortOrderEnumStringValues() []string
- func GetListPrivateEndpointsLifecycleStateEnumStringValues() []string
- func GetListPrivateEndpointsSortByEnumStringValues() []string
- func GetListPrivateEndpointsSortOrderEnumStringValues() []string
- func GetListRunsLifecycleStateEnumStringValues() []string
- func GetListRunsSortByEnumStringValues() []string
- func GetListRunsSortOrderEnumStringValues() []string
- func GetPrivateEndpointLifecycleStateEnumStringValues() []string
- func GetRunLifecycleStateEnumStringValues() []string
- func GetRunLogSummarySourceEnumStringValues() []string
- func GetRunLogSummaryTypeEnumStringValues() []string
- func GetWorkRequestOperationEnumStringValues() []string
- func GetWorkRequestResourceActionTypeEnumStringValues() []string
- func GetWorkRequestStatusEnumStringValues() []string
- type Application
- type ApplicationLanguageEnum
- type ApplicationLifecycleStateEnum
- type ApplicationParameter
- type ApplicationSummary
- type ApplicationTypeEnum
- type ChangeApplicationCompartmentDetails
- type ChangeApplicationCompartmentRequest
- func (request ChangeApplicationCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ChangeApplicationCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ChangeApplicationCompartmentRequest) RetryPolicy() *common.RetryPolicy
- func (request ChangeApplicationCompartmentRequest) String() string
- func (request ChangeApplicationCompartmentRequest) ValidateEnumValue() (bool, error)
- type ChangeApplicationCompartmentResponse
- type ChangePrivateEndpointCompartmentDetails
- type ChangePrivateEndpointCompartmentRequest
- func (request ChangePrivateEndpointCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ChangePrivateEndpointCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ChangePrivateEndpointCompartmentRequest) RetryPolicy() *common.RetryPolicy
- func (request ChangePrivateEndpointCompartmentRequest) String() string
- func (request ChangePrivateEndpointCompartmentRequest) ValidateEnumValue() (bool, error)
- type ChangePrivateEndpointCompartmentResponse
- type ChangeRunCompartmentDetails
- type ChangeRunCompartmentRequest
- func (request ChangeRunCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ChangeRunCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ChangeRunCompartmentRequest) RetryPolicy() *common.RetryPolicy
- func (request ChangeRunCompartmentRequest) String() string
- func (request ChangeRunCompartmentRequest) ValidateEnumValue() (bool, error)
- type ChangeRunCompartmentResponse
- type CreateApplicationDetails
- type CreateApplicationRequest
- func (request CreateApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request CreateApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request CreateApplicationRequest) RetryPolicy() *common.RetryPolicy
- func (request CreateApplicationRequest) String() string
- func (request CreateApplicationRequest) ValidateEnumValue() (bool, error)
- type CreateApplicationResponse
- type CreatePrivateEndpointDetails
- type CreatePrivateEndpointRequest
- func (request CreatePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request CreatePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request CreatePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
- func (request CreatePrivateEndpointRequest) String() string
- func (request CreatePrivateEndpointRequest) ValidateEnumValue() (bool, error)
- type CreatePrivateEndpointResponse
- type CreateRunDetails
- type CreateRunRequest
- func (request CreateRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request CreateRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request CreateRunRequest) RetryPolicy() *common.RetryPolicy
- func (request CreateRunRequest) String() string
- func (request CreateRunRequest) ValidateEnumValue() (bool, error)
- type CreateRunResponse
- type DataFlowClient
- func (client DataFlowClient) ChangeApplicationCompartment(ctx context.Context, request ChangeApplicationCompartmentRequest) (response ChangeApplicationCompartmentResponse, err error)
- func (client DataFlowClient) ChangePrivateEndpointCompartment(ctx context.Context, request ChangePrivateEndpointCompartmentRequest) (response ChangePrivateEndpointCompartmentResponse, err error)
- func (client DataFlowClient) ChangeRunCompartment(ctx context.Context, request ChangeRunCompartmentRequest) (response ChangeRunCompartmentResponse, err error)
- func (client *DataFlowClient) ConfigurationProvider() *common.ConfigurationProvider
- func (client DataFlowClient) CreateApplication(ctx context.Context, request CreateApplicationRequest) (response CreateApplicationResponse, err error)
- func (client DataFlowClient) CreatePrivateEndpoint(ctx context.Context, request CreatePrivateEndpointRequest) (response CreatePrivateEndpointResponse, 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) DeletePrivateEndpoint(ctx context.Context, request DeletePrivateEndpointRequest) (response DeletePrivateEndpointResponse, 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) GetPrivateEndpoint(ctx context.Context, request GetPrivateEndpointRequest) (response GetPrivateEndpointResponse, 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) GetWorkRequest(ctx context.Context, request GetWorkRequestRequest) (response GetWorkRequestResponse, err error)
- func (client DataFlowClient) ListApplications(ctx context.Context, request ListApplicationsRequest) (response ListApplicationsResponse, err error)
- func (client DataFlowClient) ListPrivateEndpoints(ctx context.Context, request ListPrivateEndpointsRequest) (response ListPrivateEndpointsResponse, 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) ListWorkRequestErrors(ctx context.Context, request ListWorkRequestErrorsRequest) (response ListWorkRequestErrorsResponse, err error)
- func (client DataFlowClient) ListWorkRequestLogs(ctx context.Context, request ListWorkRequestLogsRequest) (response ListWorkRequestLogsResponse, err error)
- func (client DataFlowClient) ListWorkRequests(ctx context.Context, request ListWorkRequestsRequest) (response ListWorkRequestsResponse, err error)
- func (client *DataFlowClient) SetRegion(region string)
- func (client DataFlowClient) UpdateApplication(ctx context.Context, request UpdateApplicationRequest) (response UpdateApplicationResponse, err error)
- func (client DataFlowClient) UpdatePrivateEndpoint(ctx context.Context, request UpdatePrivateEndpointRequest) (response UpdatePrivateEndpointResponse, err error)
- func (client DataFlowClient) UpdateRun(ctx context.Context, request UpdateRunRequest) (response UpdateRunResponse, err error)
- type DeleteApplicationRequest
- func (request DeleteApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request DeleteApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request DeleteApplicationRequest) RetryPolicy() *common.RetryPolicy
- func (request DeleteApplicationRequest) String() string
- func (request DeleteApplicationRequest) ValidateEnumValue() (bool, error)
- type DeleteApplicationResponse
- type DeletePrivateEndpointRequest
- func (request DeletePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request DeletePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request DeletePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
- func (request DeletePrivateEndpointRequest) String() string
- func (request DeletePrivateEndpointRequest) ValidateEnumValue() (bool, error)
- type DeletePrivateEndpointResponse
- type DeleteRunRequest
- func (request DeleteRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request DeleteRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request DeleteRunRequest) RetryPolicy() *common.RetryPolicy
- func (request DeleteRunRequest) String() string
- func (request DeleteRunRequest) ValidateEnumValue() (bool, error)
- type DeleteRunResponse
- type GetApplicationRequest
- func (request GetApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request GetApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request GetApplicationRequest) RetryPolicy() *common.RetryPolicy
- func (request GetApplicationRequest) String() string
- func (request GetApplicationRequest) ValidateEnumValue() (bool, error)
- type GetApplicationResponse
- type GetPrivateEndpointRequest
- func (request GetPrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request GetPrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request GetPrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
- func (request GetPrivateEndpointRequest) String() string
- func (request GetPrivateEndpointRequest) ValidateEnumValue() (bool, error)
- type GetPrivateEndpointResponse
- type GetRunLogRequest
- func (request GetRunLogRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request GetRunLogRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request GetRunLogRequest) RetryPolicy() *common.RetryPolicy
- func (request GetRunLogRequest) String() string
- func (request GetRunLogRequest) ValidateEnumValue() (bool, error)
- type GetRunLogResponse
- type GetRunRequest
- func (request GetRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request GetRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request GetRunRequest) RetryPolicy() *common.RetryPolicy
- func (request GetRunRequest) String() string
- func (request GetRunRequest) ValidateEnumValue() (bool, error)
- type GetRunResponse
- type GetWorkRequestRequest
- func (request GetWorkRequestRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request GetWorkRequestRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request GetWorkRequestRequest) RetryPolicy() *common.RetryPolicy
- func (request GetWorkRequestRequest) String() string
- func (request GetWorkRequestRequest) ValidateEnumValue() (bool, error)
- type GetWorkRequestResponse
- type ListApplicationsRequest
- func (request ListApplicationsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListApplicationsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListApplicationsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListApplicationsRequest) String() string
- func (request ListApplicationsRequest) ValidateEnumValue() (bool, error)
- type ListApplicationsResponse
- type ListApplicationsSortByEnum
- type ListApplicationsSortOrderEnum
- type ListPrivateEndpointsLifecycleStateEnum
- type ListPrivateEndpointsRequest
- func (request ListPrivateEndpointsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListPrivateEndpointsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListPrivateEndpointsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListPrivateEndpointsRequest) String() string
- func (request ListPrivateEndpointsRequest) ValidateEnumValue() (bool, error)
- type ListPrivateEndpointsResponse
- type ListPrivateEndpointsSortByEnum
- type ListPrivateEndpointsSortOrderEnum
- type ListRunLogsRequest
- func (request ListRunLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListRunLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListRunLogsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListRunLogsRequest) String() string
- func (request ListRunLogsRequest) ValidateEnumValue() (bool, error)
- type ListRunLogsResponse
- type ListRunsLifecycleStateEnum
- type ListRunsRequest
- func (request ListRunsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListRunsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListRunsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListRunsRequest) String() string
- func (request ListRunsRequest) ValidateEnumValue() (bool, error)
- type ListRunsResponse
- type ListRunsSortByEnum
- type ListRunsSortOrderEnum
- type ListWorkRequestErrorsRequest
- func (request ListWorkRequestErrorsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListWorkRequestErrorsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListWorkRequestErrorsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListWorkRequestErrorsRequest) String() string
- func (request ListWorkRequestErrorsRequest) ValidateEnumValue() (bool, error)
- type ListWorkRequestErrorsResponse
- type ListWorkRequestLogsRequest
- func (request ListWorkRequestLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListWorkRequestLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListWorkRequestLogsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListWorkRequestLogsRequest) String() string
- func (request ListWorkRequestLogsRequest) ValidateEnumValue() (bool, error)
- type ListWorkRequestLogsResponse
- type ListWorkRequestsRequest
- func (request ListWorkRequestsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request ListWorkRequestsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request ListWorkRequestsRequest) RetryPolicy() *common.RetryPolicy
- func (request ListWorkRequestsRequest) String() string
- func (request ListWorkRequestsRequest) ValidateEnumValue() (bool, error)
- type ListWorkRequestsResponse
- type PrivateEndpoint
- type PrivateEndpointCollection
- type PrivateEndpointLifecycleStateEnum
- type PrivateEndpointSummary
- type Run
- type RunLifecycleStateEnum
- type RunLogSummary
- type RunLogSummarySourceEnum
- type RunLogSummaryTypeEnum
- type RunSummary
- type ShapeConfig
- type UpdateApplicationDetails
- type UpdateApplicationRequest
- func (request UpdateApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request UpdateApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request UpdateApplicationRequest) RetryPolicy() *common.RetryPolicy
- func (request UpdateApplicationRequest) String() string
- func (request UpdateApplicationRequest) ValidateEnumValue() (bool, error)
- type UpdateApplicationResponse
- type UpdatePrivateEndpointDetails
- type UpdatePrivateEndpointRequest
- func (request UpdatePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request UpdatePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request UpdatePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
- func (request UpdatePrivateEndpointRequest) String() string
- func (request UpdatePrivateEndpointRequest) ValidateEnumValue() (bool, error)
- type UpdatePrivateEndpointResponse
- type UpdateRunDetails
- type UpdateRunRequest
- func (request UpdateRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
- func (request UpdateRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, ...) (http.Request, error)
- func (request UpdateRunRequest) RetryPolicy() *common.RetryPolicy
- func (request UpdateRunRequest) String() string
- func (request UpdateRunRequest) ValidateEnumValue() (bool, error)
- type UpdateRunResponse
- type WorkRequest
- type WorkRequestCollection
- type WorkRequestError
- type WorkRequestErrorCollection
- type WorkRequestLog
- type WorkRequestLogCollection
- type WorkRequestOperationEnum
- type WorkRequestResource
- type WorkRequestResourceActionTypeEnum
- type WorkRequestStatusEnum
- type WorkRequestSummary
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetApplicationLanguageEnumStringValues ¶
func GetApplicationLanguageEnumStringValues() []string
GetApplicationLanguageEnumStringValues Enumerates the set of values in String for ApplicationLanguageEnum
func GetApplicationLifecycleStateEnumStringValues ¶
func GetApplicationLifecycleStateEnumStringValues() []string
GetApplicationLifecycleStateEnumStringValues Enumerates the set of values in String for ApplicationLifecycleStateEnum
func GetApplicationTypeEnumStringValues ¶
func GetApplicationTypeEnumStringValues() []string
GetApplicationTypeEnumStringValues Enumerates the set of values in String for ApplicationTypeEnum
func GetListApplicationsSortByEnumStringValues ¶
func GetListApplicationsSortByEnumStringValues() []string
GetListApplicationsSortByEnumStringValues Enumerates the set of values in String for ListApplicationsSortByEnum
func GetListApplicationsSortOrderEnumStringValues ¶
func GetListApplicationsSortOrderEnumStringValues() []string
GetListApplicationsSortOrderEnumStringValues Enumerates the set of values in String for ListApplicationsSortOrderEnum
func GetListPrivateEndpointsLifecycleStateEnumStringValues ¶
func GetListPrivateEndpointsLifecycleStateEnumStringValues() []string
GetListPrivateEndpointsLifecycleStateEnumStringValues Enumerates the set of values in String for ListPrivateEndpointsLifecycleStateEnum
func GetListPrivateEndpointsSortByEnumStringValues ¶
func GetListPrivateEndpointsSortByEnumStringValues() []string
GetListPrivateEndpointsSortByEnumStringValues Enumerates the set of values in String for ListPrivateEndpointsSortByEnum
func GetListPrivateEndpointsSortOrderEnumStringValues ¶
func GetListPrivateEndpointsSortOrderEnumStringValues() []string
GetListPrivateEndpointsSortOrderEnumStringValues Enumerates the set of values in String for ListPrivateEndpointsSortOrderEnum
func GetListRunsLifecycleStateEnumStringValues ¶
func GetListRunsLifecycleStateEnumStringValues() []string
GetListRunsLifecycleStateEnumStringValues Enumerates the set of values in String for ListRunsLifecycleStateEnum
func GetListRunsSortByEnumStringValues ¶
func GetListRunsSortByEnumStringValues() []string
GetListRunsSortByEnumStringValues Enumerates the set of values in String for ListRunsSortByEnum
func GetListRunsSortOrderEnumStringValues ¶
func GetListRunsSortOrderEnumStringValues() []string
GetListRunsSortOrderEnumStringValues Enumerates the set of values in String for ListRunsSortOrderEnum
func GetPrivateEndpointLifecycleStateEnumStringValues ¶
func GetPrivateEndpointLifecycleStateEnumStringValues() []string
GetPrivateEndpointLifecycleStateEnumStringValues Enumerates the set of values in String for PrivateEndpointLifecycleStateEnum
func GetRunLifecycleStateEnumStringValues ¶
func GetRunLifecycleStateEnumStringValues() []string
GetRunLifecycleStateEnumStringValues Enumerates the set of values in String for RunLifecycleStateEnum
func GetRunLogSummarySourceEnumStringValues ¶
func GetRunLogSummarySourceEnumStringValues() []string
GetRunLogSummarySourceEnumStringValues Enumerates the set of values in String for RunLogSummarySourceEnum
func GetRunLogSummaryTypeEnumStringValues ¶
func GetRunLogSummaryTypeEnumStringValues() []string
GetRunLogSummaryTypeEnumStringValues Enumerates the set of values in String for RunLogSummaryTypeEnum
func GetWorkRequestOperationEnumStringValues ¶
func GetWorkRequestOperationEnumStringValues() []string
GetWorkRequestOperationEnumStringValues Enumerates the set of values in String for WorkRequestOperationEnum
func GetWorkRequestResourceActionTypeEnumStringValues ¶
func GetWorkRequestResourceActionTypeEnumStringValues() []string
GetWorkRequestResourceActionTypeEnumStringValues Enumerates the set of values in String for WorkRequestResourceActionTypeEnum
func GetWorkRequestStatusEnumStringValues ¶
func GetWorkRequestStatusEnumStringValues() []string
GetWorkRequestStatusEnumStringValues Enumerates the set of values in String for WorkRequestStatusEnum
Types ¶
type Application ¶
type Application struct { // The OCID of a compartment. 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"` // An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution a Python, Java, or Scala application. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. ArchiveUri *string `mandatory:"false" json:"archiveUri"` // 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"` DriverShapeConfig *ShapeConfig `mandatory:"false" json:"driverShapeConfig"` // The input used for spark-submit command. For more details see https://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit. // Supported options include “--class“, “--file“, “--jars“, “--conf“, “--py-files“, and main application file with arguments. // Example: “--jars oci://path/to/a.jar,oci://path/to/b.jar --files oci://path/to/a.json,oci://path/to/b.csv --py-files oci://path/to/a.py,oci://path/to/b.py --conf spark.sql.crossJoin.enabled=true --class org.apache.spark.examples.SparkPi oci://path/to/main.jar 10“ // Note: If execute is specified together with applicationId, className, configuration, fileUri, language, arguments, parameters during application create/update, or run create/submit, // Data Flow service will use derived information from execute input only. Execute *string `mandatory:"false" json:"execute"` ExecutorShapeConfig *ShapeConfig `mandatory:"false" json:"executorShapeConfig"` // 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 OCID of OCI Hive Metastore. MetastoreId *string `mandatory:"false" json:"metastoreId"` // 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 OCID of a private endpoint. PrivateEndpointId *string `mandatory:"false" json:"privateEndpointId"` // The Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` // 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
func (Application) ValidateEnumValue ¶
func (m Application) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
func GetMappingApplicationLanguageEnum ¶
func GetMappingApplicationLanguageEnum(val string) (ApplicationLanguageEnum, bool)
GetMappingApplicationLanguageEnum performs case Insensitive comparison on enum value and return the desired enum
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
func GetMappingApplicationLifecycleStateEnum ¶
func GetMappingApplicationLifecycleStateEnum(val string) (ApplicationLifecycleStateEnum, bool)
GetMappingApplicationLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum
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
func (ApplicationParameter) ValidateEnumValue ¶
func (m ApplicationParameter) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ApplicationSummary ¶
type ApplicationSummary struct { // The OCID of a compartment. 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 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 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 Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` }
ApplicationSummary A Data Flow application object used in bulk listings.
func (ApplicationSummary) String ¶
func (m ApplicationSummary) String() string
func (ApplicationSummary) ValidateEnumValue ¶
func (m ApplicationSummary) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ApplicationTypeEnum ¶
type ApplicationTypeEnum string
ApplicationTypeEnum Enum with underlying type: string
const ( ApplicationTypeBatch ApplicationTypeEnum = "BATCH" ApplicationTypeStreaming ApplicationTypeEnum = "STREAMING" )
Set of constants representing the allowable values for ApplicationTypeEnum
func GetApplicationTypeEnumValues ¶
func GetApplicationTypeEnumValues() []ApplicationTypeEnum
GetApplicationTypeEnumValues Enumerates the set of values for ApplicationTypeEnum
func GetMappingApplicationTypeEnum ¶
func GetMappingApplicationTypeEnum(val string) (ApplicationTypeEnum, bool)
GetMappingApplicationTypeEnum performs case Insensitive comparison on enum value and return the desired enum
type ChangeApplicationCompartmentDetails ¶
type ChangeApplicationCompartmentDetails struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` }
ChangeApplicationCompartmentDetails The change application compartment details.
func (ChangeApplicationCompartmentDetails) String ¶
func (m ChangeApplicationCompartmentDetails) String() string
func (ChangeApplicationCompartmentDetails) ValidateEnumValue ¶
func (m ChangeApplicationCompartmentDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangeApplicationCompartmentRequest ¶
type ChangeApplicationCompartmentRequest struct { // The unique ID for an application. ApplicationId *string `mandatory:"true" contributesTo:"path" name:"applicationId"` // Details for changing an application's compartment. ChangeApplicationCompartmentDetails `contributesTo:"body"` // 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"` // 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"` // 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 }
ChangeApplicationCompartmentRequest wrapper for the ChangeApplicationCompartment operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangeApplicationCompartment.go.html to see an example of how to use ChangeApplicationCompartmentRequest.
func (ChangeApplicationCompartmentRequest) BinaryRequestBody ¶
func (request ChangeApplicationCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ChangeApplicationCompartmentRequest) HTTPRequest ¶
func (request ChangeApplicationCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ChangeApplicationCompartmentRequest) RetryPolicy ¶
func (request ChangeApplicationCompartmentRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ChangeApplicationCompartmentRequest) String ¶
func (request ChangeApplicationCompartmentRequest) String() string
func (ChangeApplicationCompartmentRequest) ValidateEnumValue ¶
func (request ChangeApplicationCompartmentRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangeApplicationCompartmentResponse ¶
type ChangeApplicationCompartmentResponse 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"` }
ChangeApplicationCompartmentResponse wrapper for the ChangeApplicationCompartment operation
func (ChangeApplicationCompartmentResponse) HTTPResponse ¶
func (response ChangeApplicationCompartmentResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ChangeApplicationCompartmentResponse) String ¶
func (response ChangeApplicationCompartmentResponse) String() string
type ChangePrivateEndpointCompartmentDetails ¶
type ChangePrivateEndpointCompartmentDetails struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` }
ChangePrivateEndpointCompartmentDetails The details required to change a private endpoint compartment.
func (ChangePrivateEndpointCompartmentDetails) String ¶
func (m ChangePrivateEndpointCompartmentDetails) String() string
func (ChangePrivateEndpointCompartmentDetails) ValidateEnumValue ¶
func (m ChangePrivateEndpointCompartmentDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangePrivateEndpointCompartmentRequest ¶
type ChangePrivateEndpointCompartmentRequest struct { // The unique ID for a private endpoint. PrivateEndpointId *string `mandatory:"true" contributesTo:"path" name:"privateEndpointId"` // Details for changing a private endpoint's compartment. ChangePrivateEndpointCompartmentDetails `contributesTo:"body"` // 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 }
ChangePrivateEndpointCompartmentRequest wrapper for the ChangePrivateEndpointCompartment operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangePrivateEndpointCompartment.go.html to see an example of how to use ChangePrivateEndpointCompartmentRequest.
func (ChangePrivateEndpointCompartmentRequest) BinaryRequestBody ¶
func (request ChangePrivateEndpointCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ChangePrivateEndpointCompartmentRequest) HTTPRequest ¶
func (request ChangePrivateEndpointCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ChangePrivateEndpointCompartmentRequest) RetryPolicy ¶
func (request ChangePrivateEndpointCompartmentRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ChangePrivateEndpointCompartmentRequest) String ¶
func (request ChangePrivateEndpointCompartmentRequest) String() string
func (ChangePrivateEndpointCompartmentRequest) ValidateEnumValue ¶
func (request ChangePrivateEndpointCompartmentRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangePrivateEndpointCompartmentResponse ¶
type ChangePrivateEndpointCompartmentResponse 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"` // Unique Oracle assigned identifier for a work request. OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"` }
ChangePrivateEndpointCompartmentResponse wrapper for the ChangePrivateEndpointCompartment operation
func (ChangePrivateEndpointCompartmentResponse) HTTPResponse ¶
func (response ChangePrivateEndpointCompartmentResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ChangePrivateEndpointCompartmentResponse) String ¶
func (response ChangePrivateEndpointCompartmentResponse) String() string
type ChangeRunCompartmentDetails ¶
type ChangeRunCompartmentDetails struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` }
ChangeRunCompartmentDetails The change run compartment details.
func (ChangeRunCompartmentDetails) String ¶
func (m ChangeRunCompartmentDetails) String() string
func (ChangeRunCompartmentDetails) ValidateEnumValue ¶
func (m ChangeRunCompartmentDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangeRunCompartmentRequest ¶
type ChangeRunCompartmentRequest struct { // The unique ID for the run RunId *string `mandatory:"true" contributesTo:"path" name:"runId"` // Details for changing a run's compartment. ChangeRunCompartmentDetails `contributesTo:"body"` // 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"` // 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"` // 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 }
ChangeRunCompartmentRequest wrapper for the ChangeRunCompartment operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangeRunCompartment.go.html to see an example of how to use ChangeRunCompartmentRequest.
func (ChangeRunCompartmentRequest) BinaryRequestBody ¶
func (request ChangeRunCompartmentRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ChangeRunCompartmentRequest) HTTPRequest ¶
func (request ChangeRunCompartmentRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ChangeRunCompartmentRequest) RetryPolicy ¶
func (request ChangeRunCompartmentRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ChangeRunCompartmentRequest) String ¶
func (request ChangeRunCompartmentRequest) String() string
func (ChangeRunCompartmentRequest) ValidateEnumValue ¶
func (request ChangeRunCompartmentRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ChangeRunCompartmentResponse ¶
type ChangeRunCompartmentResponse 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"` }
ChangeRunCompartmentResponse wrapper for the ChangeRunCompartment operation
func (ChangeRunCompartmentResponse) HTTPResponse ¶
func (response ChangeRunCompartmentResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ChangeRunCompartmentResponse) String ¶
func (response ChangeRunCompartmentResponse) String() string
type CreateApplicationDetails ¶
type CreateApplicationDetails struct { // The OCID of a compartment. 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"` // An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution a Python, Java, or Scala application. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. ArchiveUri *string `mandatory:"false" json:"archiveUri"` // 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"` DriverShapeConfig *ShapeConfig `mandatory:"false" json:"driverShapeConfig"` // The input used for spark-submit command. For more details see https://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit. // Supported options include “--class“, “--file“, “--jars“, “--conf“, “--py-files“, and main application file with arguments. // Example: “--jars oci://path/to/a.jar,oci://path/to/b.jar --files oci://path/to/a.json,oci://path/to/b.csv --py-files oci://path/to/a.py,oci://path/to/b.py --conf spark.sql.crossJoin.enabled=true --class org.apache.spark.examples.SparkPi oci://path/to/main.jar 10“ // Note: If execute is specified together with applicationId, className, configuration, fileUri, language, arguments, parameters during application create/update, or run create/submit, // Data Flow service will use derived information from execute input only. Execute *string `mandatory:"false" json:"execute"` ExecutorShapeConfig *ShapeConfig `mandatory:"false" json:"executorShapeConfig"` // 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 OCID of OCI Hive Metastore. MetastoreId *string `mandatory:"false" json:"metastoreId"` // 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 OCID of a private endpoint. PrivateEndpointId *string `mandatory:"false" json:"privateEndpointId"` // The Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` // 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
func (CreateApplicationDetails) ValidateEnumValue ¶
func (m CreateApplicationDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreateApplication.go.html to see an example of how to use CreateApplicationRequest.
func (CreateApplicationRequest) BinaryRequestBody ¶
func (request CreateApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (CreateApplicationRequest) HTTPRequest ¶
func (request CreateApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (CreateApplicationRequest) ValidateEnumValue ¶
func (request CreateApplicationRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 CreatePrivateEndpointDetails ¶
type CreatePrivateEndpointDetails struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` // An array of DNS zone names. // Example: `[ "app.examplecorp.com", "app.examplecorp2.com" ]` DnsZones []string `mandatory:"true" json:"dnsZones"` // The OCID of a subnet. SubnetId *string `mandatory:"true" json:"subnetId"` // 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"` // 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 maximum number of hosts to be accessed through the private endpoint. This value is used // to calculate the relevant CIDR block and should be a multiple of 256. If the value is not a // multiple of 256, it is rounded up to the next multiple of 256. For example, 300 is rounded up // to 512. MaxHostCount *int `mandatory:"false" json:"maxHostCount"` // An array of network security group OCIDs. NsgIds []string `mandatory:"false" json:"nsgIds"` }
CreatePrivateEndpointDetails The details required to create a private endpoint.
func (CreatePrivateEndpointDetails) String ¶
func (m CreatePrivateEndpointDetails) String() string
func (CreatePrivateEndpointDetails) ValidateEnumValue ¶
func (m CreatePrivateEndpointDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type CreatePrivateEndpointRequest ¶
type CreatePrivateEndpointRequest struct { // The parameters required to create a private endpoint. CreatePrivateEndpointDetails `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 }
CreatePrivateEndpointRequest wrapper for the CreatePrivateEndpoint operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreatePrivateEndpoint.go.html to see an example of how to use CreatePrivateEndpointRequest.
func (CreatePrivateEndpointRequest) BinaryRequestBody ¶
func (request CreatePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (CreatePrivateEndpointRequest) HTTPRequest ¶
func (request CreatePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (CreatePrivateEndpointRequest) RetryPolicy ¶
func (request CreatePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (CreatePrivateEndpointRequest) String ¶
func (request CreatePrivateEndpointRequest) String() string
func (CreatePrivateEndpointRequest) ValidateEnumValue ¶
func (request CreatePrivateEndpointRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type CreatePrivateEndpointResponse ¶
type CreatePrivateEndpointResponse struct { // The underlying http response RawResponse *http.Response // The PrivateEndpoint instance PrivateEndpoint `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"` // Unique Oracle assigned identifier for a work request. OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"` // Provides information about the location of a newly created resource. Location *string `presentIn:"header" name:"location"` }
CreatePrivateEndpointResponse wrapper for the CreatePrivateEndpoint operation
func (CreatePrivateEndpointResponse) HTTPResponse ¶
func (response CreatePrivateEndpointResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (CreatePrivateEndpointResponse) String ¶
func (response CreatePrivateEndpointResponse) String() string
type CreateRunDetails ¶
type CreateRunDetails struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` // The OCID of the associated application. If this value is set, then no value for the execute parameter is required. If this value is not set, then a value for the execute parameter is required, and a new application is created and associated with the new run. ApplicationId *string `mandatory:"false" json:"applicationId"` // An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution a Python, Java, or Scala application. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. ArchiveUri *string `mandatory:"false" json:"archiveUri"` // 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 name that does not have to be unique. Avoid entering confidential information. If this value is not specified, it will be derived from the associated application's displayName or set by API using fileUri's application file name. DisplayName *string `mandatory:"false" json:"displayName"` // The VM shape for the driver. Sets the driver cores and memory. DriverShape *string `mandatory:"false" json:"driverShape"` DriverShapeConfig *ShapeConfig `mandatory:"false" json:"driverShapeConfig"` // The input used for spark-submit command. For more details see https://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit. // Supported options include “--class“, “--file“, “--jars“, “--conf“, “--py-files“, and main application file with arguments. // Example: “--jars oci://path/to/a.jar,oci://path/to/b.jar --files oci://path/to/a.json,oci://path/to/b.csv --py-files oci://path/to/a.py,oci://path/to/b.py --conf spark.sql.crossJoin.enabled=true --class org.apache.spark.examples.SparkPi oci://path/to/main.jar 10“ // Note: If execute is specified together with applicationId, className, configuration, fileUri, language, arguments, parameters during application create/update, or run create/submit, // Data Flow service will use derived information from execute input only. Execute *string `mandatory:"false" json:"execute"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"false" json:"executorShape"` ExecutorShapeConfig *ShapeConfig `mandatory:"false" json:"executorShapeConfig"` // 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 OCID of OCI Hive Metastore. MetastoreId *string `mandatory:"false" json:"metastoreId"` // 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"` // The Spark version utilized to run the application. This value may be set if applicationId is not since the Spark version will be taken from the associated application. SparkVersion *string `mandatory:"false" json:"sparkVersion"` // The Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` // 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:
- applicationId
- archiveUri
- arguments
- configuration
- definedTags
- displayName
- driverShape
- execute
- executorShape
- freeformTags
- logsBucketUri
- metastoreId
- numExecutors
- parameters
- sparkVersion
- warehouseBucketUri
It is expected that either the applicationId or the execute parameter is specified; but not both. If both or none are set, a Bad Request (HTTP 400) status will be sent as the response. If an appicationId is not specified, then a value for the execute parameter is expected. Using data parsed from the value, a new application will be created and assicated with the new run. See information on the execute parameter for details on the format of this parameter. The optional parameter spark version can only be specified when using the execute parameter. If it is not specified when using the execute parameter, the latest version will be used as default. If the execute parameter is not used, the spark version will be taken from the associated application. If displayName is not specified, it will be derived from the displayName of associated application or set by API using fileUri's application file name. 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
func (CreateRunDetails) ValidateEnumValue ¶
func (m CreateRunDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreateRun.go.html to see an example of how to use CreateRunRequest.
func (CreateRunRequest) BinaryRequestBody ¶
func (request CreateRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (CreateRunRequest) HTTPRequest ¶
func (request CreateRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (CreateRunRequest) ValidateEnumValue ¶
func (request CreateRunRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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) ChangeApplicationCompartment ¶
func (client DataFlowClient) ChangeApplicationCompartment(ctx context.Context, request ChangeApplicationCompartmentRequest) (response ChangeApplicationCompartmentResponse, err error)
ChangeApplicationCompartment Moves an application into a different compartment. When provided, If-Match is checked against ETag values of the resource. Associated resources, like runs, will not be automatically moved.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangeApplicationCompartment.go.html to see an example of how to use ChangeApplicationCompartment API.
func (DataFlowClient) ChangePrivateEndpointCompartment ¶
func (client DataFlowClient) ChangePrivateEndpointCompartment(ctx context.Context, request ChangePrivateEndpointCompartmentRequest) (response ChangePrivateEndpointCompartmentResponse, err error)
ChangePrivateEndpointCompartment Moves a private endpoint into a different compartment. When provided, If-Match is checked against ETag values of the resource.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangePrivateEndpointCompartment.go.html to see an example of how to use ChangePrivateEndpointCompartment API.
func (DataFlowClient) ChangeRunCompartment ¶
func (client DataFlowClient) ChangeRunCompartment(ctx context.Context, request ChangeRunCompartmentRequest) (response ChangeRunCompartmentResponse, err error)
ChangeRunCompartment Moves a run into a different compartment. When provided, If-Match is checked against ETag values of the resource. Associated resources, like historical metrics, will not be automatically moved. The run must be in a terminal state (CANCELED, FAILED, SUCCEEDED) in order for it to be moved to a different compartment
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ChangeRunCompartment.go.html to see an example of how to use ChangeRunCompartment API.
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.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreateApplication.go.html to see an example of how to use CreateApplication API.
func (DataFlowClient) CreatePrivateEndpoint ¶
func (client DataFlowClient) CreatePrivateEndpoint(ctx context.Context, request CreatePrivateEndpointRequest) (response CreatePrivateEndpointResponse, err error)
CreatePrivateEndpoint Creates a private endpoint to be used by applications.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreatePrivateEndpoint.go.html to see an example of how to use CreatePrivateEndpoint API.
func (DataFlowClient) CreateRun ¶
func (client DataFlowClient) CreateRun(ctx context.Context, request CreateRunRequest) (response CreateRunResponse, err error)
CreateRun Creates a run for an application.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/CreateRun.go.html to see an example of how to use CreateRun API.
func (DataFlowClient) DeleteApplication ¶
func (client DataFlowClient) DeleteApplication(ctx context.Context, request DeleteApplicationRequest) (response DeleteApplicationResponse, err error)
DeleteApplication Deletes an application using an `applicationId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeleteApplication.go.html to see an example of how to use DeleteApplication API.
func (DataFlowClient) DeletePrivateEndpoint ¶
func (client DataFlowClient) DeletePrivateEndpoint(ctx context.Context, request DeletePrivateEndpointRequest) (response DeletePrivateEndpointResponse, err error)
DeletePrivateEndpoint Deletes a private endpoint using a `privateEndpointId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeletePrivateEndpoint.go.html to see an example of how to use DeletePrivateEndpoint API.
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.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeleteRun.go.html to see an example of how to use DeleteRun API.
func (DataFlowClient) GetApplication ¶
func (client DataFlowClient) GetApplication(ctx context.Context, request GetApplicationRequest) (response GetApplicationResponse, err error)
GetApplication Retrieves an application using an `applicationId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetApplication.go.html to see an example of how to use GetApplication API.
func (DataFlowClient) GetPrivateEndpoint ¶
func (client DataFlowClient) GetPrivateEndpoint(ctx context.Context, request GetPrivateEndpointRequest) (response GetPrivateEndpointResponse, err error)
GetPrivateEndpoint Retrieves an private endpoint using a `privateEndpointId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetPrivateEndpoint.go.html to see an example of how to use GetPrivateEndpoint API.
func (DataFlowClient) GetRun ¶
func (client DataFlowClient) GetRun(ctx context.Context, request GetRunRequest) (response GetRunResponse, err error)
GetRun Retrieves the run for the specified `runId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetRun.go.html to see an example of how to use GetRun API.
func (DataFlowClient) GetRunLog ¶
func (client DataFlowClient) GetRunLog(ctx context.Context, request GetRunLogRequest) (response GetRunLogResponse, err error)
GetRunLog Retrieves the content of an run log.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetRunLog.go.html to see an example of how to use GetRunLog API.
func (DataFlowClient) GetWorkRequest ¶
func (client DataFlowClient) GetWorkRequest(ctx context.Context, request GetWorkRequestRequest) (response GetWorkRequestResponse, err error)
GetWorkRequest Gets the status of the work request with the given OCID.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetWorkRequest.go.html to see an example of how to use GetWorkRequest API.
func (DataFlowClient) ListApplications ¶
func (client DataFlowClient) ListApplications(ctx context.Context, request ListApplicationsRequest) (response ListApplicationsResponse, err error)
ListApplications Lists all applications in the specified compartment. Only one parameter other than compartmentId may also be included in a query. The query must include compartmentId. If the query does not include compartmentId, or includes compartmentId but two or more other parameters an error is returned.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListApplications.go.html to see an example of how to use ListApplications API.
func (DataFlowClient) ListPrivateEndpoints ¶
func (client DataFlowClient) ListPrivateEndpoints(ctx context.Context, request ListPrivateEndpointsRequest) (response ListPrivateEndpointsResponse, err error)
ListPrivateEndpoints Lists all private endpoints in the specified compartment.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListPrivateEndpoints.go.html to see an example of how to use ListPrivateEndpoints API.
func (DataFlowClient) ListRunLogs ¶
func (client DataFlowClient) ListRunLogs(ctx context.Context, request ListRunLogsRequest) (response ListRunLogsResponse, err error)
ListRunLogs Retrieves summaries of the run's logs.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListRunLogs.go.html to see an example of how to use ListRunLogs API.
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. Only one parameter other than compartmentId may also be included in a query. The query must include compartmentId. If the query does not include compartmentId, or includes compartmentId but two or more other parameters an error is returned.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListRuns.go.html to see an example of how to use ListRuns API.
func (DataFlowClient) ListWorkRequestErrors ¶
func (client DataFlowClient) ListWorkRequestErrors(ctx context.Context, request ListWorkRequestErrorsRequest) (response ListWorkRequestErrorsResponse, err error)
ListWorkRequestErrors Return a (paginated) list of errors for a given work request.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequestErrors.go.html to see an example of how to use ListWorkRequestErrors API.
func (DataFlowClient) ListWorkRequestLogs ¶
func (client DataFlowClient) ListWorkRequestLogs(ctx context.Context, request ListWorkRequestLogsRequest) (response ListWorkRequestLogsResponse, err error)
ListWorkRequestLogs Return a paginated list of logs for a given work request.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequestLogs.go.html to see an example of how to use ListWorkRequestLogs API.
func (DataFlowClient) ListWorkRequests ¶
func (client DataFlowClient) ListWorkRequests(ctx context.Context, request ListWorkRequestsRequest) (response ListWorkRequestsResponse, err error)
ListWorkRequests Lists the work requests in a compartment.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequests.go.html to see an example of how to use ListWorkRequests API.
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`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdateApplication.go.html to see an example of how to use UpdateApplication API.
func (DataFlowClient) UpdatePrivateEndpoint ¶
func (client DataFlowClient) UpdatePrivateEndpoint(ctx context.Context, request UpdatePrivateEndpointRequest) (response UpdatePrivateEndpointResponse, err error)
UpdatePrivateEndpoint Updates a private endpoint using a `privateEndpointId`. If changes to a private endpoint match a previously defined private endpoint, then a 409 status code will be returned. This indicates that a conflict has been detected.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdatePrivateEndpoint.go.html to see an example of how to use UpdatePrivateEndpoint API.
func (DataFlowClient) UpdateRun ¶
func (client DataFlowClient) UpdateRun(ctx context.Context, request UpdateRunRequest) (response UpdateRunResponse, err error)
UpdateRun Updates a run using a `runId`.
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdateRun.go.html to see an example of how to use UpdateRun API.
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeleteApplication.go.html to see an example of how to use DeleteApplicationRequest.
func (DeleteApplicationRequest) BinaryRequestBody ¶
func (request DeleteApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (DeleteApplicationRequest) HTTPRequest ¶
func (request DeleteApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (DeleteApplicationRequest) ValidateEnumValue ¶
func (request DeleteApplicationRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 DeletePrivateEndpointRequest ¶
type DeletePrivateEndpointRequest struct { // The unique ID for a private endpoint. PrivateEndpointId *string `mandatory:"true" contributesTo:"path" name:"privateEndpointId"` // 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 }
DeletePrivateEndpointRequest wrapper for the DeletePrivateEndpoint operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeletePrivateEndpoint.go.html to see an example of how to use DeletePrivateEndpointRequest.
func (DeletePrivateEndpointRequest) BinaryRequestBody ¶
func (request DeletePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (DeletePrivateEndpointRequest) HTTPRequest ¶
func (request DeletePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (DeletePrivateEndpointRequest) RetryPolicy ¶
func (request DeletePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (DeletePrivateEndpointRequest) String ¶
func (request DeletePrivateEndpointRequest) String() string
func (DeletePrivateEndpointRequest) ValidateEnumValue ¶
func (request DeletePrivateEndpointRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type DeletePrivateEndpointResponse ¶
type DeletePrivateEndpointResponse 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"` // Unique Oracle assigned identifier for a work request. OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"` }
DeletePrivateEndpointResponse wrapper for the DeletePrivateEndpoint operation
func (DeletePrivateEndpointResponse) HTTPResponse ¶
func (response DeletePrivateEndpointResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (DeletePrivateEndpointResponse) String ¶
func (response DeletePrivateEndpointResponse) 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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/DeleteRun.go.html to see an example of how to use DeleteRunRequest.
func (DeleteRunRequest) BinaryRequestBody ¶
func (request DeleteRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (DeleteRunRequest) HTTPRequest ¶
func (request DeleteRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (DeleteRunRequest) ValidateEnumValue ¶
func (request DeleteRunRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetApplication.go.html to see an example of how to use GetApplicationRequest.
func (GetApplicationRequest) BinaryRequestBody ¶
func (request GetApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (GetApplicationRequest) HTTPRequest ¶
func (request GetApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (GetApplicationRequest) ValidateEnumValue ¶
func (request GetApplicationRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 GetPrivateEndpointRequest ¶
type GetPrivateEndpointRequest struct { // The unique ID for a private endpoint. PrivateEndpointId *string `mandatory:"true" contributesTo:"path" name:"privateEndpointId"` // 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 }
GetPrivateEndpointRequest wrapper for the GetPrivateEndpoint operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetPrivateEndpoint.go.html to see an example of how to use GetPrivateEndpointRequest.
func (GetPrivateEndpointRequest) BinaryRequestBody ¶
func (request GetPrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (GetPrivateEndpointRequest) HTTPRequest ¶
func (request GetPrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (GetPrivateEndpointRequest) RetryPolicy ¶
func (request GetPrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (GetPrivateEndpointRequest) String ¶
func (request GetPrivateEndpointRequest) String() string
func (GetPrivateEndpointRequest) ValidateEnumValue ¶
func (request GetPrivateEndpointRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type GetPrivateEndpointResponse ¶
type GetPrivateEndpointResponse struct { // The underlying http response RawResponse *http.Response // The PrivateEndpoint instance PrivateEndpoint `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"` }
GetPrivateEndpointResponse wrapper for the GetPrivateEndpoint operation
func (GetPrivateEndpointResponse) HTTPResponse ¶
func (response GetPrivateEndpointResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (GetPrivateEndpointResponse) String ¶
func (response GetPrivateEndpointResponse) 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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetRunLog.go.html to see an example of how to use GetRunLogRequest.
func (GetRunLogRequest) BinaryRequestBody ¶
func (request GetRunLogRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (GetRunLogRequest) HTTPRequest ¶
func (request GetRunLogRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (GetRunLogRequest) ValidateEnumValue ¶
func (request GetRunLogRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetRun.go.html to see an example of how to use GetRunRequest.
func (GetRunRequest) BinaryRequestBody ¶
func (request GetRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (GetRunRequest) HTTPRequest ¶
func (request GetRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (GetRunRequest) ValidateEnumValue ¶
func (request GetRunRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 GetWorkRequestRequest ¶
type GetWorkRequestRequest struct { // The unique ID for a work request. WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"` // 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 }
GetWorkRequestRequest wrapper for the GetWorkRequest operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/GetWorkRequest.go.html to see an example of how to use GetWorkRequestRequest.
func (GetWorkRequestRequest) BinaryRequestBody ¶
func (request GetWorkRequestRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (GetWorkRequestRequest) HTTPRequest ¶
func (request GetWorkRequestRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (GetWorkRequestRequest) RetryPolicy ¶
func (request GetWorkRequestRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (GetWorkRequestRequest) String ¶
func (request GetWorkRequestRequest) String() string
func (GetWorkRequestRequest) ValidateEnumValue ¶
func (request GetWorkRequestRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type GetWorkRequestResponse ¶
type GetWorkRequestResponse struct { // The underlying http response RawResponse *http.Response // The WorkRequest instance WorkRequest `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"` }
GetWorkRequestResponse wrapper for the GetWorkRequest operation
func (GetWorkRequestResponse) HTTPResponse ¶
func (response GetWorkRequestResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (GetWorkRequestResponse) String ¶
func (response GetWorkRequestResponse) 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"` // The Spark version utilized to run the application. SparkVersion *string `mandatory:"false" contributesTo:"query" name:"sparkVersion"` // 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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListApplications.go.html to see an example of how to use ListApplicationsRequest.
func (ListApplicationsRequest) BinaryRequestBody ¶
func (request ListApplicationsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListApplicationsRequest) HTTPRequest ¶
func (request ListApplicationsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (ListApplicationsRequest) ValidateEnumValue ¶
func (request ListApplicationsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
func GetMappingListApplicationsSortByEnum ¶
func GetMappingListApplicationsSortByEnum(val string) (ListApplicationsSortByEnum, bool)
GetMappingListApplicationsSortByEnum performs case Insensitive comparison on enum value and return the desired enum
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
func GetMappingListApplicationsSortOrderEnum ¶
func GetMappingListApplicationsSortOrderEnum(val string) (ListApplicationsSortOrderEnum, bool)
GetMappingListApplicationsSortOrderEnum performs case Insensitive comparison on enum value and return the desired enum
type ListPrivateEndpointsLifecycleStateEnum ¶
type ListPrivateEndpointsLifecycleStateEnum string
ListPrivateEndpointsLifecycleStateEnum Enum with underlying type: string
const ( ListPrivateEndpointsLifecycleStateCreating ListPrivateEndpointsLifecycleStateEnum = "CREATING" ListPrivateEndpointsLifecycleStateActive ListPrivateEndpointsLifecycleStateEnum = "ACTIVE" ListPrivateEndpointsLifecycleStateInactive ListPrivateEndpointsLifecycleStateEnum = "INACTIVE" ListPrivateEndpointsLifecycleStateUpdating ListPrivateEndpointsLifecycleStateEnum = "UPDATING" ListPrivateEndpointsLifecycleStateDeleting ListPrivateEndpointsLifecycleStateEnum = "DELETING" ListPrivateEndpointsLifecycleStateDeleted ListPrivateEndpointsLifecycleStateEnum = "DELETED" ListPrivateEndpointsLifecycleStateFailed ListPrivateEndpointsLifecycleStateEnum = "FAILED" )
Set of constants representing the allowable values for ListPrivateEndpointsLifecycleStateEnum
func GetListPrivateEndpointsLifecycleStateEnumValues ¶
func GetListPrivateEndpointsLifecycleStateEnumValues() []ListPrivateEndpointsLifecycleStateEnum
GetListPrivateEndpointsLifecycleStateEnumValues Enumerates the set of values for ListPrivateEndpointsLifecycleStateEnum
func GetMappingListPrivateEndpointsLifecycleStateEnum ¶
func GetMappingListPrivateEndpointsLifecycleStateEnum(val string) (ListPrivateEndpointsLifecycleStateEnum, bool)
GetMappingListPrivateEndpointsLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum
type ListPrivateEndpointsRequest ¶
type ListPrivateEndpointsRequest 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 LifecycleState of the private endpoint. LifecycleState ListPrivateEndpointsLifecycleStateEnum `mandatory:"false" contributesTo:"query" name:"lifecycleState" omitEmpty:"true"` // The field used to sort the results. Multiple fields are not supported. SortBy ListPrivateEndpointsSortByEnum `mandatory:"false" contributesTo:"query" name:"sortBy" omitEmpty:"true"` // The ordering of results in ascending or descending order. SortOrder ListPrivateEndpointsSortOrderEnum `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 }
ListPrivateEndpointsRequest wrapper for the ListPrivateEndpoints operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListPrivateEndpoints.go.html to see an example of how to use ListPrivateEndpointsRequest.
func (ListPrivateEndpointsRequest) BinaryRequestBody ¶
func (request ListPrivateEndpointsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListPrivateEndpointsRequest) HTTPRequest ¶
func (request ListPrivateEndpointsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListPrivateEndpointsRequest) RetryPolicy ¶
func (request ListPrivateEndpointsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListPrivateEndpointsRequest) String ¶
func (request ListPrivateEndpointsRequest) String() string
func (ListPrivateEndpointsRequest) ValidateEnumValue ¶
func (request ListPrivateEndpointsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ListPrivateEndpointsResponse ¶
type ListPrivateEndpointsResponse struct { // The underlying http response RawResponse *http.Response // A list of PrivateEndpointCollection instances PrivateEndpointCollection `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"` }
ListPrivateEndpointsResponse wrapper for the ListPrivateEndpoints operation
func (ListPrivateEndpointsResponse) HTTPResponse ¶
func (response ListPrivateEndpointsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListPrivateEndpointsResponse) String ¶
func (response ListPrivateEndpointsResponse) String() string
type ListPrivateEndpointsSortByEnum ¶
type ListPrivateEndpointsSortByEnum string
ListPrivateEndpointsSortByEnum Enum with underlying type: string
const (
ListPrivateEndpointsSortByTimecreated ListPrivateEndpointsSortByEnum = "timeCreated"
)
Set of constants representing the allowable values for ListPrivateEndpointsSortByEnum
func GetListPrivateEndpointsSortByEnumValues ¶
func GetListPrivateEndpointsSortByEnumValues() []ListPrivateEndpointsSortByEnum
GetListPrivateEndpointsSortByEnumValues Enumerates the set of values for ListPrivateEndpointsSortByEnum
func GetMappingListPrivateEndpointsSortByEnum ¶
func GetMappingListPrivateEndpointsSortByEnum(val string) (ListPrivateEndpointsSortByEnum, bool)
GetMappingListPrivateEndpointsSortByEnum performs case Insensitive comparison on enum value and return the desired enum
type ListPrivateEndpointsSortOrderEnum ¶
type ListPrivateEndpointsSortOrderEnum string
ListPrivateEndpointsSortOrderEnum Enum with underlying type: string
const ( ListPrivateEndpointsSortOrderAsc ListPrivateEndpointsSortOrderEnum = "ASC" ListPrivateEndpointsSortOrderDesc ListPrivateEndpointsSortOrderEnum = "DESC" )
Set of constants representing the allowable values for ListPrivateEndpointsSortOrderEnum
func GetListPrivateEndpointsSortOrderEnumValues ¶
func GetListPrivateEndpointsSortOrderEnumValues() []ListPrivateEndpointsSortOrderEnum
GetListPrivateEndpointsSortOrderEnumValues Enumerates the set of values for ListPrivateEndpointsSortOrderEnum
func GetMappingListPrivateEndpointsSortOrderEnum ¶
func GetMappingListPrivateEndpointsSortOrderEnum(val string) (ListPrivateEndpointsSortOrderEnum, bool)
GetMappingListPrivateEndpointsSortOrderEnum performs case Insensitive comparison on enum value and return the desired enum
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListRunLogs.go.html to see an example of how to use ListRunLogsRequest.
func (ListRunLogsRequest) BinaryRequestBody ¶
func (request ListRunLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListRunLogsRequest) HTTPRequest ¶
func (request ListRunLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (ListRunLogsRequest) ValidateEnumValue ¶
func (request ListRunLogsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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" ListRunsLifecycleStateStopping ListRunsLifecycleStateEnum = "STOPPING" ListRunsLifecycleStateStopped ListRunsLifecycleStateEnum = "STOPPED" )
Set of constants representing the allowable values for ListRunsLifecycleStateEnum
func GetListRunsLifecycleStateEnumValues ¶
func GetListRunsLifecycleStateEnumValues() []ListRunsLifecycleStateEnum
GetListRunsLifecycleStateEnumValues Enumerates the set of values for ListRunsLifecycleStateEnum
func GetMappingListRunsLifecycleStateEnum ¶
func GetMappingListRunsLifecycleStateEnum(val string) (ListRunsLifecycleStateEnum, bool)
GetMappingListRunsLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListRuns.go.html to see an example of how to use ListRunsRequest.
func (ListRunsRequest) BinaryRequestBody ¶
func (request ListRunsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListRunsRequest) HTTPRequest ¶
func (request ListRunsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (ListRunsRequest) ValidateEnumValue ¶
func (request ListRunsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
func GetMappingListRunsSortByEnum ¶
func GetMappingListRunsSortByEnum(val string) (ListRunsSortByEnum, bool)
GetMappingListRunsSortByEnum performs case Insensitive comparison on enum value and return the desired enum
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
func GetMappingListRunsSortOrderEnum ¶
func GetMappingListRunsSortOrderEnum(val string) (ListRunsSortOrderEnum, bool)
GetMappingListRunsSortOrderEnum performs case Insensitive comparison on enum value and return the desired enum
type ListWorkRequestErrorsRequest ¶
type ListWorkRequestErrorsRequest struct { // The unique ID for a work request. WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"` // The maximum number of results to return in a paginated `List` call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // 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 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 }
ListWorkRequestErrorsRequest wrapper for the ListWorkRequestErrors operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequestErrors.go.html to see an example of how to use ListWorkRequestErrorsRequest.
func (ListWorkRequestErrorsRequest) BinaryRequestBody ¶
func (request ListWorkRequestErrorsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListWorkRequestErrorsRequest) HTTPRequest ¶
func (request ListWorkRequestErrorsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListWorkRequestErrorsRequest) RetryPolicy ¶
func (request ListWorkRequestErrorsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListWorkRequestErrorsRequest) String ¶
func (request ListWorkRequestErrorsRequest) String() string
func (ListWorkRequestErrorsRequest) ValidateEnumValue ¶
func (request ListWorkRequestErrorsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ListWorkRequestErrorsResponse ¶
type ListWorkRequestErrorsResponse struct { // The underlying http response RawResponse *http.Response // A list of WorkRequestErrorCollection instances WorkRequestErrorCollection `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"` }
ListWorkRequestErrorsResponse wrapper for the ListWorkRequestErrors operation
func (ListWorkRequestErrorsResponse) HTTPResponse ¶
func (response ListWorkRequestErrorsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListWorkRequestErrorsResponse) String ¶
func (response ListWorkRequestErrorsResponse) String() string
type ListWorkRequestLogsRequest ¶
type ListWorkRequestLogsRequest struct { // The unique ID for a work request. WorkRequestId *string `mandatory:"true" contributesTo:"path" name:"workRequestId"` // The maximum number of results to return in a paginated `List` call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // 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 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 }
ListWorkRequestLogsRequest wrapper for the ListWorkRequestLogs operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequestLogs.go.html to see an example of how to use ListWorkRequestLogsRequest.
func (ListWorkRequestLogsRequest) BinaryRequestBody ¶
func (request ListWorkRequestLogsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListWorkRequestLogsRequest) HTTPRequest ¶
func (request ListWorkRequestLogsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListWorkRequestLogsRequest) RetryPolicy ¶
func (request ListWorkRequestLogsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListWorkRequestLogsRequest) String ¶
func (request ListWorkRequestLogsRequest) String() string
func (ListWorkRequestLogsRequest) ValidateEnumValue ¶
func (request ListWorkRequestLogsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ListWorkRequestLogsResponse ¶
type ListWorkRequestLogsResponse struct { // The underlying http response RawResponse *http.Response // A list of WorkRequestLogCollection instances WorkRequestLogCollection `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"` }
ListWorkRequestLogsResponse wrapper for the ListWorkRequestLogs operation
func (ListWorkRequestLogsResponse) HTTPResponse ¶
func (response ListWorkRequestLogsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListWorkRequestLogsResponse) String ¶
func (response ListWorkRequestLogsResponse) String() string
type ListWorkRequestsRequest ¶
type ListWorkRequestsRequest struct { // The OCID of the compartment. CompartmentId *string `mandatory:"true" contributesTo:"query" name:"compartmentId"` // The maximum number of results to return in a paginated `List` call. Limit *int `mandatory:"false" contributesTo:"query" name:"limit"` // 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 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 }
ListWorkRequestsRequest wrapper for the ListWorkRequests operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/ListWorkRequests.go.html to see an example of how to use ListWorkRequestsRequest.
func (ListWorkRequestsRequest) BinaryRequestBody ¶
func (request ListWorkRequestsRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (ListWorkRequestsRequest) HTTPRequest ¶
func (request ListWorkRequestsRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (ListWorkRequestsRequest) RetryPolicy ¶
func (request ListWorkRequestsRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (ListWorkRequestsRequest) String ¶
func (request ListWorkRequestsRequest) String() string
func (ListWorkRequestsRequest) ValidateEnumValue ¶
func (request ListWorkRequestsRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ListWorkRequestsResponse ¶
type ListWorkRequestsResponse struct { // The underlying http response RawResponse *http.Response // A list of WorkRequestCollection instances WorkRequestCollection `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"` }
ListWorkRequestsResponse wrapper for the ListWorkRequests operation
func (ListWorkRequestsResponse) HTTPResponse ¶
func (response ListWorkRequestsResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (ListWorkRequestsResponse) String ¶
func (response ListWorkRequestsResponse) String() string
type PrivateEndpoint ¶
type PrivateEndpoint struct { // The OCID of a compartment. 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. It does not have to be unique. Avoid entering confidential information. DisplayName *string `mandatory:"true" json:"displayName"` // An array of DNS zone names. // Example: `[ "app.examplecorp.com", "app.examplecorp2.com" ]` DnsZones []string `mandatory:"true" json:"dnsZones"` // 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 OCID of a private endpoint. Id *string `mandatory:"true" json:"id"` // The current state of this private endpoint. LifecycleState PrivateEndpointLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"true" json:"ownerPrincipalId"` // The OCID of a subnet. SubnetId *string `mandatory:"true" json:"subnetId"` // 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"` // A user-friendly description. Avoid entering confidential information. Description *string `mandatory:"false" json:"description"` // The detailed messages about the lifecycle state. LifecycleDetails *string `mandatory:"false" json:"lifecycleDetails"` // The maximum number of hosts to be accessed through the private endpoint. This value is used // to calculate the relevant CIDR block and should be a multiple of 256. If the value is not a // multiple of 256, it is rounded up to the next multiple of 256. For example, 300 is rounded up // to 512. MaxHostCount *int `mandatory:"false" json:"maxHostCount"` // An array of network security group OCIDs. NsgIds []string `mandatory:"false" json:"nsgIds"` // 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"` }
PrivateEndpoint A Data Flow private endpoint object.
func (PrivateEndpoint) String ¶
func (m PrivateEndpoint) String() string
func (PrivateEndpoint) ValidateEnumValue ¶
func (m PrivateEndpoint) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type PrivateEndpointCollection ¶
type PrivateEndpointCollection struct { // A list of private endpoints. Items []PrivateEndpointSummary `mandatory:"true" json:"items"` }
PrivateEndpointCollection The results of a query for a list of private endpoints. It contains PrivateEndpointSummary items.
func (PrivateEndpointCollection) String ¶
func (m PrivateEndpointCollection) String() string
func (PrivateEndpointCollection) ValidateEnumValue ¶
func (m PrivateEndpointCollection) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type PrivateEndpointLifecycleStateEnum ¶
type PrivateEndpointLifecycleStateEnum string
PrivateEndpointLifecycleStateEnum Enum with underlying type: string
const ( PrivateEndpointLifecycleStateCreating PrivateEndpointLifecycleStateEnum = "CREATING" PrivateEndpointLifecycleStateActive PrivateEndpointLifecycleStateEnum = "ACTIVE" PrivateEndpointLifecycleStateInactive PrivateEndpointLifecycleStateEnum = "INACTIVE" PrivateEndpointLifecycleStateUpdating PrivateEndpointLifecycleStateEnum = "UPDATING" PrivateEndpointLifecycleStateDeleting PrivateEndpointLifecycleStateEnum = "DELETING" PrivateEndpointLifecycleStateDeleted PrivateEndpointLifecycleStateEnum = "DELETED" PrivateEndpointLifecycleStateFailed PrivateEndpointLifecycleStateEnum = "FAILED" )
Set of constants representing the allowable values for PrivateEndpointLifecycleStateEnum
func GetMappingPrivateEndpointLifecycleStateEnum ¶
func GetMappingPrivateEndpointLifecycleStateEnum(val string) (PrivateEndpointLifecycleStateEnum, bool)
GetMappingPrivateEndpointLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum
func GetPrivateEndpointLifecycleStateEnumValues ¶
func GetPrivateEndpointLifecycleStateEnumValues() []PrivateEndpointLifecycleStateEnum
GetPrivateEndpointLifecycleStateEnumValues Enumerates the set of values for PrivateEndpointLifecycleStateEnum
type PrivateEndpointSummary ¶
type PrivateEndpointSummary struct { // The OCID of a compartment. 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. It does not have to be unique. Avoid entering confidential information. DisplayName *string `mandatory:"true" json:"displayName"` // An array of DNS zone names. // Example: `[ "app.examplecorp.com", "app.examplecorp2.com" ]` DnsZones []string `mandatory:"true" json:"dnsZones"` // 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 OCID of a private endpoint. Id *string `mandatory:"true" json:"id"` // The current state of this private endpoint. LifecycleState PrivateEndpointLifecycleStateEnum `mandatory:"true" json:"lifecycleState"` // The OCID of the user who created the resource. OwnerPrincipalId *string `mandatory:"true" json:"ownerPrincipalId"` // The OCID of a subnet. SubnetId *string `mandatory:"true" json:"subnetId"` // 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 maximum number of hosts to be accessed through the private endpoint. This value is used // to calculate the relevant CIDR block and should be a multiple of 256. If the value is not a // multiple of 256, it is rounded up to the next multiple of 256. For example, 300 is rounded up // to 512. MaxHostCount *int `mandatory:"false" json:"maxHostCount"` // An array of network security group OCIDs. NsgIds []string `mandatory:"false" json:"nsgIds"` // 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"` }
PrivateEndpointSummary A Data Flow private endpoint object used in bulk listings.
func (PrivateEndpointSummary) String ¶
func (m PrivateEndpointSummary) String() string
func (PrivateEndpointSummary) ValidateEnumValue ¶
func (m PrivateEndpointSummary) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type Run ¶
type Run struct { // The application ID. ApplicationId *string `mandatory:"true" json:"applicationId"` // The OCID of a compartment. 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"` // An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution a Python, Java, or Scala application. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. ArchiveUri *string `mandatory:"false" json:"archiveUri"` // 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"` DriverShapeConfig *ShapeConfig `mandatory:"false" json:"driverShapeConfig"` // The input used for spark-submit command. For more details see https://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit. // Supported options include “--class“, “--file“, “--jars“, “--conf“, “--py-files“, and main application file with arguments. // Example: “--jars oci://path/to/a.jar,oci://path/to/b.jar --files oci://path/to/a.json,oci://path/to/b.csv --py-files oci://path/to/a.py,oci://path/to/b.py --conf spark.sql.crossJoin.enabled=true --class org.apache.spark.examples.SparkPi oci://path/to/main.jar 10“ // Note: If execute is specified together with applicationId, className, configuration, fileUri, language, arguments, parameters during application create/update, or run create/submit, // Data Flow service will use derived information from execute input only. Execute *string `mandatory:"false" json:"execute"` ExecutorShapeConfig *ShapeConfig `mandatory:"false" json:"executorShapeConfig"` // 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"` // The OCID of OCI Hive Metastore. MetastoreId *string `mandatory:"false" json:"metastoreId"` // 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"` // An array of DNS zone names. // Example: `[ "app.examplecorp.com", "app.examplecorp2.com" ]` PrivateEndpointDnsZones []string `mandatory:"false" json:"privateEndpointDnsZones"` // The maximum number of hosts to be accessed through the private endpoint. This value is used // to calculate the relevant CIDR block and should be a multiple of 256. If the value is not a // multiple of 256, it is rounded up to the next multiple of 256. For example, 300 is rounded up // to 512. PrivateEndpointMaxHostCount *int `mandatory:"false" json:"privateEndpointMaxHostCount"` // An array of network security group OCIDs. PrivateEndpointNsgIds []string `mandatory:"false" json:"privateEndpointNsgIds"` // The OCID of a private endpoint. PrivateEndpointId *string `mandatory:"false" json:"privateEndpointId"` // The OCID of a subnet. PrivateEndpointSubnetId *string `mandatory:"false" json:"privateEndpointSubnetId"` // 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"` // The Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` // 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.
func (Run) ValidateEnumValue ¶
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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" RunLifecycleStateStopping RunLifecycleStateEnum = "STOPPING" RunLifecycleStateStopped RunLifecycleStateEnum = "STOPPED" )
Set of constants representing the allowable values for RunLifecycleStateEnum
func GetMappingRunLifecycleStateEnum ¶
func GetMappingRunLifecycleStateEnum(val string) (RunLifecycleStateEnum, bool)
GetMappingRunLifecycleStateEnum performs case Insensitive comparison on enum value and return the desired enum
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
func (RunLogSummary) ValidateEnumValue ¶
func (m RunLogSummary) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 GetMappingRunLogSummarySourceEnum ¶
func GetMappingRunLogSummarySourceEnum(val string) (RunLogSummarySourceEnum, bool)
GetMappingRunLogSummarySourceEnum performs case Insensitive comparison on enum value and return the desired enum
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 GetMappingRunLogSummaryTypeEnum ¶
func GetMappingRunLogSummaryTypeEnum(val string) (RunLogSummaryTypeEnum, bool)
GetMappingRunLogSummaryTypeEnum performs case Insensitive comparison on enum value and return the desired enum
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 a compartment. 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"` // The Spark application processing type. Type ApplicationTypeEnum `mandatory:"false" json:"type,omitempty"` }
RunSummary A summary of the run.
func (RunSummary) String ¶
func (m RunSummary) String() string
func (RunSummary) ValidateEnumValue ¶
func (m RunSummary) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type ShapeConfig ¶ added in v65.8.0
type ShapeConfig struct { // The total number of OCPUs used for the driver or executors. // See here (https://docs.cloud.oracle.com/en-us/iaas/api/#/en/iaas/20160918/Shape/) for details. Ocpus *float32 `mandatory:"false" json:"ocpus"` // The amount of memory used for the driver or executors. MemoryInGBs *float32 `mandatory:"false" json:"memoryInGBs"` }
ShapeConfig This is used to configure the shape of the driver or executor if a flexible shape is used.
func (ShapeConfig) String ¶ added in v65.8.0
func (m ShapeConfig) String() string
func (ShapeConfig) ValidateEnumValue ¶ added in v65.8.0
func (m ShapeConfig) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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"` // An Oracle Cloud Infrastructure URI of an archive.zip file containing custom dependencies that may be used to support the execution a Python, Java, or Scala application. // See https://docs.cloud.oracle.com/iaas/Content/API/SDKDocs/hdfsconnector.htm#uriformat. ArchiveUri *string `mandatory:"false" json:"archiveUri"` // 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"` DriverShapeConfig *ShapeConfig `mandatory:"false" json:"driverShapeConfig"` // The input used for spark-submit command. For more details see https://spark.apache.org/docs/latest/submitting-applications.html#launching-applications-with-spark-submit. // Supported options include “--class“, “--file“, “--jars“, “--conf“, “--py-files“, and main application file with arguments. // Example: “--jars oci://path/to/a.jar,oci://path/to/b.jar --files oci://path/to/a.json,oci://path/to/b.csv --py-files oci://path/to/a.py,oci://path/to/b.py --conf spark.sql.crossJoin.enabled=true --class org.apache.spark.examples.SparkPi oci://path/to/main.jar 10“ // Note: If execute is specified together with applicationId, className, configuration, fileUri, language, arguments, parameters during application create/update, or run create/submit, // Data Flow service will use derived information from execute input only. Execute *string `mandatory:"false" json:"execute"` // The VM shape for the executors. Sets the executor cores and memory. ExecutorShape *string `mandatory:"false" json:"executorShape"` ExecutorShapeConfig *ShapeConfig `mandatory:"false" json:"executorShapeConfig"` // 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 OCID of OCI Hive Metastore. MetastoreId *string `mandatory:"false" json:"metastoreId"` // 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"` // The OCID of a private endpoint. PrivateEndpointId *string `mandatory:"false" json:"privateEndpointId"` // 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
func (UpdateApplicationDetails) ValidateEnumValue ¶
func (m UpdateApplicationDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdateApplication.go.html to see an example of how to use UpdateApplicationRequest.
func (UpdateApplicationRequest) BinaryRequestBody ¶
func (request UpdateApplicationRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (UpdateApplicationRequest) HTTPRequest ¶
func (request UpdateApplicationRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (UpdateApplicationRequest) ValidateEnumValue ¶
func (request UpdateApplicationRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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 UpdatePrivateEndpointDetails ¶
type UpdatePrivateEndpointDetails 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"` // 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"` // An array of DNS zone names. // Example: `[ "app.examplecorp.com", "app.examplecorp2.com" ]` DnsZones []string `mandatory:"false" json:"dnsZones"` // 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 maximum number of hosts to be accessed through the private endpoint. This value is used // to calculate the relevant CIDR block and should be a multiple of 256. If the value is not a // multiple of 256, it is rounded up to the next multiple of 256. For example, 300 is rounded up // to 512. MaxHostCount *int `mandatory:"false" json:"maxHostCount"` // An array of network security group OCIDs. NsgIds []string `mandatory:"false" json:"nsgIds"` }
UpdatePrivateEndpointDetails The details required to update a private endpoint.
func (UpdatePrivateEndpointDetails) String ¶
func (m UpdatePrivateEndpointDetails) String() string
func (UpdatePrivateEndpointDetails) ValidateEnumValue ¶
func (m UpdatePrivateEndpointDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type UpdatePrivateEndpointRequest ¶
type UpdatePrivateEndpointRequest struct { // Details for updating a private endpoint. UpdatePrivateEndpointDetails `contributesTo:"body"` // The unique ID for a private endpoint. PrivateEndpointId *string `mandatory:"true" contributesTo:"path" name:"privateEndpointId"` // 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 }
UpdatePrivateEndpointRequest wrapper for the UpdatePrivateEndpoint operation
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdatePrivateEndpoint.go.html to see an example of how to use UpdatePrivateEndpointRequest.
func (UpdatePrivateEndpointRequest) BinaryRequestBody ¶
func (request UpdatePrivateEndpointRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (UpdatePrivateEndpointRequest) HTTPRequest ¶
func (request UpdatePrivateEndpointRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]string) (http.Request, error)
HTTPRequest implements the OCIRequest interface
func (UpdatePrivateEndpointRequest) RetryPolicy ¶
func (request UpdatePrivateEndpointRequest) RetryPolicy() *common.RetryPolicy
RetryPolicy implements the OCIRetryableRequest interface. This retrieves the specified retry policy.
func (UpdatePrivateEndpointRequest) String ¶
func (request UpdatePrivateEndpointRequest) String() string
func (UpdatePrivateEndpointRequest) ValidateEnumValue ¶
func (request UpdatePrivateEndpointRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type UpdatePrivateEndpointResponse ¶
type UpdatePrivateEndpointResponse 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"` // Unique Oracle assigned identifier for a work request. OpcWorkRequestId *string `presentIn:"header" name:"opc-work-request-id"` }
UpdatePrivateEndpointResponse wrapper for the UpdatePrivateEndpoint operation
func (UpdatePrivateEndpointResponse) HTTPResponse ¶
func (response UpdatePrivateEndpointResponse) HTTPResponse() *http.Response
HTTPResponse implements the OCIResponse interface
func (UpdatePrivateEndpointResponse) String ¶
func (response UpdatePrivateEndpointResponse) 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
func (UpdateRunDetails) ValidateEnumValue ¶
func (m UpdateRunDetails) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
See also ¶
Click https://docs.cloud.oracle.com/en-us/iaas/tools/go-sdk-examples/latest/dataflow/UpdateRun.go.html to see an example of how to use UpdateRunRequest.
func (UpdateRunRequest) BinaryRequestBody ¶
func (request UpdateRunRequest) BinaryRequestBody() (*common.OCIReadSeekCloser, bool)
BinaryRequestBody implements the OCIRequest interface
func (UpdateRunRequest) HTTPRequest ¶
func (request UpdateRunRequest) HTTPRequest(method, path string, binaryRequestBody *common.OCIReadSeekCloser, extraHeaders map[string]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
func (UpdateRunRequest) ValidateEnumValue ¶
func (request UpdateRunRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
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
type WorkRequest ¶
type WorkRequest struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` // The OCID of a work request. Id *string `mandatory:"true" json:"id"` // The operation related to this work request. Operation WorkRequestOperationEnum `mandatory:"true" json:"operation"` // Percentage of the request completed. PercentComplete *float32 `mandatory:"true" json:"percentComplete"` // The resources affected by this work request. Resources []WorkRequestResource `mandatory:"true" json:"resources"` // The status of the work request. Status WorkRequestStatusEnum `mandatory:"true" json:"status"` // The date and time the request was created, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29. TimeAccepted *common.SDKTime `mandatory:"false" json:"timeAccepted"` // The date and time the request was started, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29. TimeStarted *common.SDKTime `mandatory:"false" json:"timeStarted"` // The date and time the object was finished, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339). TimeFinished *common.SDKTime `mandatory:"false" json:"timeFinished"` }
WorkRequest A Data Flow work request object.
func (WorkRequest) String ¶
func (m WorkRequest) String() string
func (WorkRequest) ValidateEnumValue ¶
func (m WorkRequest) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestCollection ¶
type WorkRequestCollection struct { // A list of work requests Items []WorkRequestSummary `mandatory:"true" json:"items"` }
WorkRequestCollection Results of a query for a list of work requests. Contains WorkRequestSummary items.
func (WorkRequestCollection) String ¶
func (m WorkRequestCollection) String() string
func (WorkRequestCollection) ValidateEnumValue ¶
func (m WorkRequestCollection) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestError ¶
type WorkRequestError struct { // A Machine-usable code for the error that occured. Code *string `mandatory:"true" json:"code"` // A human readable description of the issue encountered. Message *string `mandatory:"true" json:"message"` // The time the error occured. An RFC3339 formatted datetime string. Timestamp *common.SDKTime `mandatory:"true" json:"timestamp"` // The id of a work request error. Id *int64 `mandatory:"false" json:"id"` // The OCID of a work request. WorkRequestid *string `mandatory:"false" json:"workRequestid"` }
WorkRequestError A Data Flow work request error object.
func (WorkRequestError) String ¶
func (m WorkRequestError) String() string
func (WorkRequestError) ValidateEnumValue ¶
func (m WorkRequestError) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestErrorCollection ¶
type WorkRequestErrorCollection struct { // A list of work request errors. Items []WorkRequestError `mandatory:"true" json:"items"` }
WorkRequestErrorCollection Results of a query for a list of work request errors. Contains WorkRequestError items.
func (WorkRequestErrorCollection) String ¶
func (m WorkRequestErrorCollection) String() string
func (WorkRequestErrorCollection) ValidateEnumValue ¶
func (m WorkRequestErrorCollection) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestLog ¶
type WorkRequestLog struct { // A human readable log message. Message *string `mandatory:"true" json:"message"` // The time the log message was written. An RFC3339 formatted datetime string. Timestamp *common.SDKTime `mandatory:"true" json:"timestamp"` // The id of a work request log. Id *int64 `mandatory:"false" json:"id"` // The OCID of a work request. WorkRequestid *string `mandatory:"false" json:"workRequestid"` }
WorkRequestLog A Data Flow work request log object.
func (WorkRequestLog) String ¶
func (m WorkRequestLog) String() string
func (WorkRequestLog) ValidateEnumValue ¶
func (m WorkRequestLog) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestLogCollection ¶
type WorkRequestLogCollection struct { // A list of work request logs. Items []WorkRequestLog `mandatory:"true" json:"items"` }
WorkRequestLogCollection Results of a query for a list of work request logs. Contains WorkRequestLog items.
func (WorkRequestLogCollection) String ¶
func (m WorkRequestLogCollection) String() string
func (WorkRequestLogCollection) ValidateEnumValue ¶
func (m WorkRequestLogCollection) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestOperationEnum ¶
type WorkRequestOperationEnum string
WorkRequestOperationEnum Enum with underlying type: string
const ( WorkRequestOperationCreatePrivateEndpoint WorkRequestOperationEnum = "CREATE_PRIVATE_ENDPOINT" WorkRequestOperationUpdatePrivateEndpoint WorkRequestOperationEnum = "UPDATE_PRIVATE_ENDPOINT" WorkRequestOperationDeletePrivateEndpoint WorkRequestOperationEnum = "DELETE_PRIVATE_ENDPOINT" WorkRequestOperationMovePrivateEndpoint WorkRequestOperationEnum = "MOVE_PRIVATE_ENDPOINT" )
Set of constants representing the allowable values for WorkRequestOperationEnum
func GetMappingWorkRequestOperationEnum ¶
func GetMappingWorkRequestOperationEnum(val string) (WorkRequestOperationEnum, bool)
GetMappingWorkRequestOperationEnum performs case Insensitive comparison on enum value and return the desired enum
func GetWorkRequestOperationEnumValues ¶
func GetWorkRequestOperationEnumValues() []WorkRequestOperationEnum
GetWorkRequestOperationEnumValues Enumerates the set of values for WorkRequestOperationEnum
type WorkRequestResource ¶
type WorkRequestResource struct { // The way in which this resource is affected by the work tracked in the work request. ActionType WorkRequestResourceActionTypeEnum `mandatory:"true" json:"actionType"` // The id of the releated resource. See resourceType to identity the specific type of resource. ResourceId *string `mandatory:"true" json:"resourceId"` // The type of resource. See resourceId for the id of the specific resource. ResourceType *string `mandatory:"true" json:"resourceType"` // The id of a work request resource object. Id *int64 `mandatory:"false" json:"id"` // The URI path that the user can use to get access to the resource metadata ResourceUri *string `mandatory:"false" json:"resourceUri"` // The OCID of a work request. WorkRequestid *string `mandatory:"false" json:"workRequestid"` }
WorkRequestResource A resource related to a Data Flow work request.
func (WorkRequestResource) String ¶
func (m WorkRequestResource) String() string
func (WorkRequestResource) ValidateEnumValue ¶
func (m WorkRequestResource) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
type WorkRequestResourceActionTypeEnum ¶
type WorkRequestResourceActionTypeEnum string
WorkRequestResourceActionTypeEnum Enum with underlying type: string
const ( WorkRequestResourceActionTypeCreated WorkRequestResourceActionTypeEnum = "CREATED" WorkRequestResourceActionTypeUpdated WorkRequestResourceActionTypeEnum = "UPDATED" WorkRequestResourceActionTypeDeleted WorkRequestResourceActionTypeEnum = "DELETED" WorkRequestResourceActionTypeInprogress WorkRequestResourceActionTypeEnum = "INPROGRESS" WorkRequestResourceActionTypeRelated WorkRequestResourceActionTypeEnum = "RELATED" )
Set of constants representing the allowable values for WorkRequestResourceActionTypeEnum
func GetMappingWorkRequestResourceActionTypeEnum ¶
func GetMappingWorkRequestResourceActionTypeEnum(val string) (WorkRequestResourceActionTypeEnum, bool)
GetMappingWorkRequestResourceActionTypeEnum performs case Insensitive comparison on enum value and return the desired enum
func GetWorkRequestResourceActionTypeEnumValues ¶
func GetWorkRequestResourceActionTypeEnumValues() []WorkRequestResourceActionTypeEnum
GetWorkRequestResourceActionTypeEnumValues Enumerates the set of values for WorkRequestResourceActionTypeEnum
type WorkRequestStatusEnum ¶
type WorkRequestStatusEnum string
WorkRequestStatusEnum Enum with underlying type: string
const ( WorkRequestStatusAccepted WorkRequestStatusEnum = "ACCEPTED" WorkRequestStatusCancelled WorkRequestStatusEnum = "CANCELLED" WorkRequestStatusCancelling WorkRequestStatusEnum = "CANCELLING" WorkRequestStatusFailed WorkRequestStatusEnum = "FAILED" WorkRequestStatusInprogress WorkRequestStatusEnum = "INPROGRESS" WorkRequestStatusSucceeded WorkRequestStatusEnum = "SUCCEEDED" )
Set of constants representing the allowable values for WorkRequestStatusEnum
func GetMappingWorkRequestStatusEnum ¶
func GetMappingWorkRequestStatusEnum(val string) (WorkRequestStatusEnum, bool)
GetMappingWorkRequestStatusEnum performs case Insensitive comparison on enum value and return the desired enum
func GetWorkRequestStatusEnumValues ¶
func GetWorkRequestStatusEnumValues() []WorkRequestStatusEnum
GetWorkRequestStatusEnumValues Enumerates the set of values for WorkRequestStatusEnum
type WorkRequestSummary ¶
type WorkRequestSummary struct { // The OCID of a compartment. CompartmentId *string `mandatory:"true" json:"compartmentId"` // The OCID of a work request. Id *string `mandatory:"true" json:"id"` // The operation related to this work request. Operation WorkRequestOperationEnum `mandatory:"true" json:"operation"` // Percentage of the request completed. PercentComplete *float32 `mandatory:"true" json:"percentComplete"` // The status of the work request. Status WorkRequestStatusEnum `mandatory:"true" json:"status"` // The resources affected by this work request. Resources []WorkRequestResource `mandatory:"false" json:"resources"` // The date and time the request was created, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29. TimeAccepted *common.SDKTime `mandatory:"false" json:"timeAccepted"` // The date and time the request was started, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339), section 14.29. TimeStarted *common.SDKTime `mandatory:"false" json:"timeStarted"` // The date and time the object was finished, as described in // RFC 3339 (https://tools.ietf.org/rfc/rfc3339). TimeFinished *common.SDKTime `mandatory:"false" json:"timeFinished"` }
WorkRequestSummary A Data Flow work request summary object.
func (WorkRequestSummary) String ¶
func (m WorkRequestSummary) String() string
func (WorkRequestSummary) ValidateEnumValue ¶
func (m WorkRequestSummary) ValidateEnumValue() (bool, error)
ValidateEnumValue returns an error when providing an unsupported enum value This function is being called during constructing API request process Not recommended for calling this function directly
Source Files
¶
- application.go
- application_language.go
- application_lifecycle_state.go
- application_parameter.go
- application_summary.go
- application_type.go
- change_application_compartment_details.go
- change_application_compartment_request_response.go
- change_private_endpoint_compartment_details.go
- change_private_endpoint_compartment_request_response.go
- change_run_compartment_details.go
- change_run_compartment_request_response.go
- create_application_details.go
- create_application_request_response.go
- create_private_endpoint_details.go
- create_private_endpoint_request_response.go
- create_run_details.go
- create_run_request_response.go
- dataflow_client.go
- delete_application_request_response.go
- delete_private_endpoint_request_response.go
- delete_run_request_response.go
- get_application_request_response.go
- get_private_endpoint_request_response.go
- get_run_log_request_response.go
- get_run_request_response.go
- get_work_request_request_response.go
- list_applications_request_response.go
- list_private_endpoints_request_response.go
- list_run_logs_request_response.go
- list_runs_request_response.go
- list_work_request_errors_request_response.go
- list_work_request_logs_request_response.go
- list_work_requests_request_response.go
- private_endpoint.go
- private_endpoint_collection.go
- private_endpoint_lifecycle_state.go
- private_endpoint_summary.go
- run.go
- run_lifecycle_state.go
- run_log_summary.go
- run_summary.go
- shape_config.go
- update_application_details.go
- update_application_request_response.go
- update_private_endpoint_details.go
- update_private_endpoint_request_response.go
- update_run_details.go
- update_run_request_response.go
- work_request.go
- work_request_collection.go
- work_request_error.go
- work_request_error_collection.go
- work_request_log.go
- work_request_log_collection.go
- work_request_operation.go
- work_request_resource.go
- work_request_status.go
- work_request_summary.go