Documentation ¶
Index ¶
- Variables
- func GetEndpointMap() map[string]string
- func GetEndpointType() string
- func SetClientProperty(client *Client, propertyName string, propertyValue interface{})
- func SetEndpointDataToClient(client *Client)
- type Client
- func NewClient() (client *Client, err error)
- func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
- func NewClientWithEcsRamRole(regionId string, roleName string) (client *Client, err error)
- func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
- func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
- func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
- func NewClientWithRamRoleArnAndPolicy(regionId string, ...) (client *Client, err error)
- func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
- func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
- func (client *Client) CreateConnector(request *CreateConnectorRequest) (response *CreateConnectorResponse, err error)
- func (client *Client) CreateConnectorWithCallback(request *CreateConnectorRequest, ...) <-chan int
- func (client *Client) CreateConnectorWithChan(request *CreateConnectorRequest) (<-chan *CreateConnectorResponse, <-chan error)
- func (client *Client) CreateDeployment(request *CreateDeploymentRequest) (response *CreateDeploymentResponse, err error)
- func (client *Client) CreateDeploymentWithCallback(request *CreateDeploymentRequest, ...) <-chan int
- func (client *Client) CreateDeploymentWithChan(request *CreateDeploymentRequest) (<-chan *CreateDeploymentResponse, <-chan error)
- func (client *Client) CreateFormat(request *CreateFormatRequest) (response *CreateFormatResponse, err error)
- func (client *Client) CreateFormatWithCallback(request *CreateFormatRequest, ...) <-chan int
- func (client *Client) CreateFormatWithChan(request *CreateFormatRequest) (<-chan *CreateFormatResponse, <-chan error)
- func (client *Client) CreateMember(request *CreateMemberRequest) (response *CreateMemberResponse, err error)
- func (client *Client) CreateMemberWithCallback(request *CreateMemberRequest, ...) <-chan int
- func (client *Client) CreateMemberWithChan(request *CreateMemberRequest) (<-chan *CreateMemberResponse, <-chan error)
- func (client *Client) CreateSavepoint(request *CreateSavepointRequest) (response *CreateSavepointResponse, err error)
- func (client *Client) CreateSavepointWithCallback(request *CreateSavepointRequest, ...) <-chan int
- func (client *Client) CreateSavepointWithChan(request *CreateSavepointRequest) (<-chan *CreateSavepointResponse, <-chan error)
- func (client *Client) CreateSecretValue(request *CreateSecretValueRequest) (response *CreateSecretValueResponse, err error)
- func (client *Client) CreateSecretValueWithCallback(request *CreateSecretValueRequest, ...) <-chan int
- func (client *Client) CreateSecretValueWithChan(request *CreateSecretValueRequest) (<-chan *CreateSecretValueResponse, <-chan error)
- func (client *Client) CreateUdfArtifact(request *CreateUdfArtifactRequest) (response *CreateUdfArtifactResponse, err error)
- func (client *Client) CreateUdfArtifactWithCallback(request *CreateUdfArtifactRequest, ...) <-chan int
- func (client *Client) CreateUdfArtifactWithChan(request *CreateUdfArtifactRequest) (<-chan *CreateUdfArtifactResponse, <-chan error)
- func (client *Client) DatabaseExists(request *DatabaseExistsRequest) (response *DatabaseExistsResponse, err error)
- func (client *Client) DatabaseExistsWithCallback(request *DatabaseExistsRequest, ...) <-chan int
- func (client *Client) DatabaseExistsWithChan(request *DatabaseExistsRequest) (<-chan *DatabaseExistsResponse, <-chan error)
- func (client *Client) DeleteArtifact(request *DeleteArtifactRequest) (response *DeleteArtifactResponse, err error)
- func (client *Client) DeleteArtifactWithCallback(request *DeleteArtifactRequest, ...) <-chan int
- func (client *Client) DeleteArtifactWithChan(request *DeleteArtifactRequest) (<-chan *DeleteArtifactResponse, <-chan error)
- func (client *Client) DeleteConnector(request *DeleteConnectorRequest) (response *DeleteConnectorResponse, err error)
- func (client *Client) DeleteConnectorWithCallback(request *DeleteConnectorRequest, ...) <-chan int
- func (client *Client) DeleteConnectorWithChan(request *DeleteConnectorRequest) (<-chan *DeleteConnectorResponse, <-chan error)
- func (client *Client) DeleteDeployment(request *DeleteDeploymentRequest) (response *DeleteDeploymentResponse, err error)
- func (client *Client) DeleteDeploymentWithCallback(request *DeleteDeploymentRequest, ...) <-chan int
- func (client *Client) DeleteDeploymentWithChan(request *DeleteDeploymentRequest) (<-chan *DeleteDeploymentResponse, <-chan error)
- func (client *Client) DeleteFormat(request *DeleteFormatRequest) (response *DeleteFormatResponse, err error)
- func (client *Client) DeleteFormatWithCallback(request *DeleteFormatRequest, ...) <-chan int
- func (client *Client) DeleteFormatWithChan(request *DeleteFormatRequest) (<-chan *DeleteFormatResponse, <-chan error)
- func (client *Client) DeleteMember(request *DeleteMemberRequest) (response *DeleteMemberResponse, err error)
- func (client *Client) DeleteMemberWithCallback(request *DeleteMemberRequest, ...) <-chan int
- func (client *Client) DeleteMemberWithChan(request *DeleteMemberRequest) (<-chan *DeleteMemberResponse, <-chan error)
- func (client *Client) DeleteSecretValue(request *DeleteSecretValueRequest) (response *DeleteSecretValueResponse, err error)
- func (client *Client) DeleteSecretValueWithCallback(request *DeleteSecretValueRequest, ...) <-chan int
- func (client *Client) DeleteSecretValueWithChan(request *DeleteSecretValueRequest) (<-chan *DeleteSecretValueResponse, <-chan error)
- func (client *Client) DeleteUdfArtifact(request *DeleteUdfArtifactRequest) (response *DeleteUdfArtifactResponse, err error)
- func (client *Client) DeleteUdfArtifactWithCallback(request *DeleteUdfArtifactRequest, ...) <-chan int
- func (client *Client) DeleteUdfArtifactWithChan(request *DeleteUdfArtifactRequest) (<-chan *DeleteUdfArtifactResponse, <-chan error)
- func (client *Client) ExecuteSqlScript(request *ExecuteSqlScriptRequest) (response *ExecuteSqlScriptResponse, err error)
- func (client *Client) ExecuteSqlScriptWithCallback(request *ExecuteSqlScriptRequest, ...) <-chan int
- func (client *Client) ExecuteSqlScriptWithChan(request *ExecuteSqlScriptRequest) (<-chan *ExecuteSqlScriptResponse, <-chan error)
- func (client *Client) ExecuteSqlscriptsStatements(request *ExecuteSqlscriptsStatementsRequest) (response *ExecuteSqlscriptsStatementsResponse, err error)
- func (client *Client) ExecuteSqlscriptsStatementsWithCallback(request *ExecuteSqlscriptsStatementsRequest, ...) <-chan int
- func (client *Client) ExecuteSqlscriptsStatementsWithChan(request *ExecuteSqlscriptsStatementsRequest) (<-chan *ExecuteSqlscriptsStatementsResponse, <-chan error)
- func (client *Client) ForcefullyCreateLock(request *ForcefullyCreateLockRequest) (response *ForcefullyCreateLockResponse, err error)
- func (client *Client) ForcefullyCreateLockWithCallback(request *ForcefullyCreateLockRequest, ...) <-chan int
- func (client *Client) ForcefullyCreateLockWithChan(request *ForcefullyCreateLockRequest) (<-chan *ForcefullyCreateLockResponse, <-chan error)
- func (client *Client) FunctionExists(request *FunctionExistsRequest) (response *FunctionExistsResponse, err error)
- func (client *Client) FunctionExistsWithCallback(request *FunctionExistsRequest, ...) <-chan int
- func (client *Client) FunctionExistsWithChan(request *FunctionExistsRequest) (<-chan *FunctionExistsResponse, <-chan error)
- func (client *Client) GenerateResourcePlan(request *GenerateResourcePlanRequest) (response *GenerateResourcePlanResponse, err error)
- func (client *Client) GenerateResourcePlanWithCallback(request *GenerateResourcePlanRequest, ...) <-chan int
- func (client *Client) GenerateResourcePlanWithChan(request *GenerateResourcePlanRequest) (<-chan *GenerateResourcePlanResponse, <-chan error)
- func (client *Client) GetArtifactMetadata(request *GetArtifactMetadataRequest) (response *GetArtifactMetadataResponse, err error)
- func (client *Client) GetArtifactMetadataWithCallback(request *GetArtifactMetadataRequest, ...) <-chan int
- func (client *Client) GetArtifactMetadataWithChan(request *GetArtifactMetadataRequest) (<-chan *GetArtifactMetadataResponse, <-chan error)
- func (client *Client) GetCatalog(request *GetCatalogRequest) (response *GetCatalogResponse, err error)
- func (client *Client) GetCatalogWithCallback(request *GetCatalogRequest, ...) <-chan int
- func (client *Client) GetCatalogWithChan(request *GetCatalogRequest) (<-chan *GetCatalogResponse, <-chan error)
- func (client *Client) GetDatabase(request *GetDatabaseRequest) (response *GetDatabaseResponse, err error)
- func (client *Client) GetDatabaseWithCallback(request *GetDatabaseRequest, ...) <-chan int
- func (client *Client) GetDatabaseWithChan(request *GetDatabaseRequest) (<-chan *GetDatabaseResponse, <-chan error)
- func (client *Client) GetDefaultDatabase(request *GetDefaultDatabaseRequest) (response *GetDefaultDatabaseResponse, err error)
- func (client *Client) GetDefaultDatabaseWithCallback(request *GetDefaultDatabaseRequest, ...) <-chan int
- func (client *Client) GetDefaultDatabaseWithChan(request *GetDefaultDatabaseRequest) (<-chan *GetDefaultDatabaseResponse, <-chan error)
- func (client *Client) GetDeployment(request *GetDeploymentRequest) (response *GetDeploymentResponse, err error)
- func (client *Client) GetDeploymentDefaults(request *GetDeploymentDefaultsRequest) (response *GetDeploymentDefaultsResponse, err error)
- func (client *Client) GetDeploymentDefaultsWithCallback(request *GetDeploymentDefaultsRequest, ...) <-chan int
- func (client *Client) GetDeploymentDefaultsWithChan(request *GetDeploymentDefaultsRequest) (<-chan *GetDeploymentDefaultsResponse, <-chan error)
- func (client *Client) GetDeploymentWithCallback(request *GetDeploymentRequest, ...) <-chan int
- func (client *Client) GetDeploymentWithChan(request *GetDeploymentRequest) (<-chan *GetDeploymentResponse, <-chan error)
- func (client *Client) GetFunction(request *GetFunctionRequest) (response *GetFunctionResponse, err error)
- func (client *Client) GetFunctionWithCallback(request *GetFunctionRequest, ...) <-chan int
- func (client *Client) GetFunctionWithChan(request *GetFunctionRequest) (<-chan *GetFunctionResponse, <-chan error)
- func (client *Client) GetGlobalDeploymentDefaults(request *GetGlobalDeploymentDefaultsRequest) (response *GetGlobalDeploymentDefaultsResponse, err error)
- func (client *Client) GetGlobalDeploymentDefaultsWithCallback(request *GetGlobalDeploymentDefaultsRequest, ...) <-chan int
- func (client *Client) GetGlobalDeploymentDefaultsWithChan(request *GetGlobalDeploymentDefaultsRequest) (<-chan *GetGlobalDeploymentDefaultsResponse, <-chan error)
- func (client *Client) GetResourcePlan(request *GetResourcePlanRequest) (response *GetResourcePlanResponse, err error)
- func (client *Client) GetResourcePlanWithCallback(request *GetResourcePlanRequest, ...) <-chan int
- func (client *Client) GetResourcePlanWithChan(request *GetResourcePlanRequest) (<-chan *GetResourcePlanResponse, <-chan error)
- func (client *Client) GetTable(request *GetTableRequest) (response *GetTableResponse, err error)
- func (client *Client) GetTableWithCallback(request *GetTableRequest, callback func(response *GetTableResponse, err error)) <-chan int
- func (client *Client) GetTableWithChan(request *GetTableRequest) (<-chan *GetTableResponse, <-chan error)
- func (client *Client) GetUdfArtifact(request *GetUdfArtifactRequest) (response *GetUdfArtifactResponse, err error)
- func (client *Client) GetUdfArtifactWithCallback(request *GetUdfArtifactRequest, ...) <-chan int
- func (client *Client) GetUdfArtifactWithChan(request *GetUdfArtifactRequest) (<-chan *GetUdfArtifactResponse, <-chan error)
- func (client *Client) ListArtifacts(request *ListArtifactsRequest) (response *ListArtifactsResponse, err error)
- func (client *Client) ListArtifactsWithCallback(request *ListArtifactsRequest, ...) <-chan int
- func (client *Client) ListArtifactsWithChan(request *ListArtifactsRequest) (<-chan *ListArtifactsResponse, <-chan error)
- func (client *Client) ListCatalogs(request *ListCatalogsRequest) (response *ListCatalogsResponse, err error)
- func (client *Client) ListCatalogsWithCallback(request *ListCatalogsRequest, ...) <-chan int
- func (client *Client) ListCatalogsWithChan(request *ListCatalogsRequest) (<-chan *ListCatalogsResponse, <-chan error)
- func (client *Client) ListConnectors(request *ListConnectorsRequest) (response *ListConnectorsResponse, err error)
- func (client *Client) ListConnectorsWithCallback(request *ListConnectorsRequest, ...) <-chan int
- func (client *Client) ListConnectorsWithChan(request *ListConnectorsRequest) (<-chan *ListConnectorsResponse, <-chan error)
- func (client *Client) ListDatabases(request *ListDatabasesRequest) (response *ListDatabasesResponse, err error)
- func (client *Client) ListDatabasesWithCallback(request *ListDatabasesRequest, ...) <-chan int
- func (client *Client) ListDatabasesWithChan(request *ListDatabasesRequest) (<-chan *ListDatabasesResponse, <-chan error)
- func (client *Client) ListDeploymentTargets(request *ListDeploymentTargetsRequest) (response *ListDeploymentTargetsResponse, err error)
- func (client *Client) ListDeploymentTargetsWithCallback(request *ListDeploymentTargetsRequest, ...) <-chan int
- func (client *Client) ListDeploymentTargetsWithChan(request *ListDeploymentTargetsRequest) (<-chan *ListDeploymentTargetsResponse, <-chan error)
- func (client *Client) ListDeployments(request *ListDeploymentsRequest) (response *ListDeploymentsResponse, err error)
- func (client *Client) ListDeploymentsWithCallback(request *ListDeploymentsRequest, ...) <-chan int
- func (client *Client) ListDeploymentsWithChan(request *ListDeploymentsRequest) (<-chan *ListDeploymentsResponse, <-chan error)
- func (client *Client) ListFlinkVersions(request *ListFlinkVersionsRequest) (response *ListFlinkVersionsResponse, err error)
- func (client *Client) ListFlinkVersionsWithCallback(request *ListFlinkVersionsRequest, ...) <-chan int
- func (client *Client) ListFlinkVersionsWithChan(request *ListFlinkVersionsRequest) (<-chan *ListFlinkVersionsResponse, <-chan error)
- func (client *Client) ListFormats(request *ListFormatsRequest) (response *ListFormatsResponse, err error)
- func (client *Client) ListFormatsWithCallback(request *ListFormatsRequest, ...) <-chan int
- func (client *Client) ListFormatsWithChan(request *ListFormatsRequest) (<-chan *ListFormatsResponse, <-chan error)
- func (client *Client) ListFunctions(request *ListFunctionsRequest) (response *ListFunctionsResponse, err error)
- func (client *Client) ListFunctionsWithCallback(request *ListFunctionsRequest, ...) <-chan int
- func (client *Client) ListFunctionsWithChan(request *ListFunctionsRequest) (<-chan *ListFunctionsResponse, <-chan error)
- func (client *Client) ListJobs(request *ListJobsRequest) (response *ListJobsResponse, err error)
- func (client *Client) ListJobsWithCallback(request *ListJobsRequest, callback func(response *ListJobsResponse, err error)) <-chan int
- func (client *Client) ListJobsWithChan(request *ListJobsRequest) (<-chan *ListJobsResponse, <-chan error)
- func (client *Client) ListNamespaces(request *ListNamespacesRequest) (response *ListNamespacesResponse, err error)
- func (client *Client) ListNamespacesWithCallback(request *ListNamespacesRequest, ...) <-chan int
- func (client *Client) ListNamespacesWithChan(request *ListNamespacesRequest) (<-chan *ListNamespacesResponse, <-chan error)
- func (client *Client) ListSavepoints(request *ListSavepointsRequest) (response *ListSavepointsResponse, err error)
- func (client *Client) ListSavepointsWithCallback(request *ListSavepointsRequest, ...) <-chan int
- func (client *Client) ListSavepointsWithChan(request *ListSavepointsRequest) (<-chan *ListSavepointsResponse, <-chan error)
- func (client *Client) ListSecretValues(request *ListSecretValuesRequest) (response *ListSecretValuesResponse, err error)
- func (client *Client) ListSecretValuesWithCallback(request *ListSecretValuesRequest, ...) <-chan int
- func (client *Client) ListSecretValuesWithChan(request *ListSecretValuesRequest) (<-chan *ListSecretValuesResponse, <-chan error)
- func (client *Client) ListSessionClusters(request *ListSessionClustersRequest) (response *ListSessionClustersResponse, err error)
- func (client *Client) ListSessionClustersWithCallback(request *ListSessionClustersRequest, ...) <-chan int
- func (client *Client) ListSessionClustersWithChan(request *ListSessionClustersRequest) (<-chan *ListSessionClustersResponse, <-chan error)
- func (client *Client) ListTables(request *ListTablesRequest) (response *ListTablesResponse, err error)
- func (client *Client) ListTablesWithCallback(request *ListTablesRequest, ...) <-chan int
- func (client *Client) ListTablesWithChan(request *ListTablesRequest) (<-chan *ListTablesResponse, <-chan error)
- func (client *Client) ParseConnector(request *ParseConnectorRequest) (response *ParseConnectorResponse, err error)
- func (client *Client) ParseConnectorWithCallback(request *ParseConnectorRequest, ...) <-chan int
- func (client *Client) ParseConnectorWithChan(request *ParseConnectorRequest) (<-chan *ParseConnectorResponse, <-chan error)
- func (client *Client) ParseFormat(request *ParseFormatRequest) (response *ParseFormatResponse, err error)
- func (client *Client) ParseFormatWithCallback(request *ParseFormatRequest, ...) <-chan int
- func (client *Client) ParseFormatWithChan(request *ParseFormatRequest) (<-chan *ParseFormatResponse, <-chan error)
- func (client *Client) ReplaceDeployment(request *ReplaceDeploymentRequest) (response *ReplaceDeploymentResponse, err error)
- func (client *Client) ReplaceDeploymentWithCallback(request *ReplaceDeploymentRequest, ...) <-chan int
- func (client *Client) ReplaceDeploymentWithChan(request *ReplaceDeploymentRequest) (<-chan *ReplaceDeploymentResponse, <-chan error)
- func (client *Client) SetDeploymentResourceMode(request *SetDeploymentResourceModeRequest) (response *SetDeploymentResourceModeResponse, err error)
- func (client *Client) SetDeploymentResourceModeWithCallback(request *SetDeploymentResourceModeRequest, ...) <-chan int
- func (client *Client) SetDeploymentResourceModeWithChan(request *SetDeploymentResourceModeRequest) (<-chan *SetDeploymentResourceModeResponse, <-chan error)
- func (client *Client) TableExists(request *TableExistsRequest) (response *TableExistsResponse, err error)
- func (client *Client) TableExistsWithCallback(request *TableExistsRequest, ...) <-chan int
- func (client *Client) TableExistsWithChan(request *TableExistsRequest) (<-chan *TableExistsResponse, <-chan error)
- func (client *Client) UpdateConnector(request *UpdateConnectorRequest) (response *UpdateConnectorResponse, err error)
- func (client *Client) UpdateConnectorWithCallback(request *UpdateConnectorRequest, ...) <-chan int
- func (client *Client) UpdateConnectorWithChan(request *UpdateConnectorRequest) (<-chan *UpdateConnectorResponse, <-chan error)
- func (client *Client) UpdateDeployment(request *UpdateDeploymentRequest) (response *UpdateDeploymentResponse, err error)
- func (client *Client) UpdateDeploymentDesiredState(request *UpdateDeploymentDesiredStateRequest) (response *UpdateDeploymentDesiredStateResponse, err error)
- func (client *Client) UpdateDeploymentDesiredStateWithCallback(request *UpdateDeploymentDesiredStateRequest, ...) <-chan int
- func (client *Client) UpdateDeploymentDesiredStateWithChan(request *UpdateDeploymentDesiredStateRequest) (<-chan *UpdateDeploymentDesiredStateResponse, <-chan error)
- func (client *Client) UpdateDeploymentWithCallback(request *UpdateDeploymentRequest, ...) <-chan int
- func (client *Client) UpdateDeploymentWithChan(request *UpdateDeploymentRequest) (<-chan *UpdateDeploymentResponse, <-chan error)
- func (client *Client) UpdateFormat(request *UpdateFormatRequest) (response *UpdateFormatResponse, err error)
- func (client *Client) UpdateFormatWithCallback(request *UpdateFormatRequest, ...) <-chan int
- func (client *Client) UpdateFormatWithChan(request *UpdateFormatRequest) (<-chan *UpdateFormatResponse, <-chan error)
- func (client *Client) UpdateMember(request *UpdateMemberRequest) (response *UpdateMemberResponse, err error)
- func (client *Client) UpdateMemberWithCallback(request *UpdateMemberRequest, ...) <-chan int
- func (client *Client) UpdateMemberWithChan(request *UpdateMemberRequest) (<-chan *UpdateMemberResponse, <-chan error)
- func (client *Client) UpdateUdfArtifact(request *UpdateUdfArtifactRequest) (response *UpdateUdfArtifactResponse, err error)
- func (client *Client) UpdateUdfArtifactWithCallback(request *UpdateUdfArtifactRequest, ...) <-chan int
- func (client *Client) UpdateUdfArtifactWithChan(request *UpdateUdfArtifactRequest) (<-chan *UpdateUdfArtifactResponse, <-chan error)
- func (client *Client) ValidateSqlScript(request *ValidateSqlScriptRequest) (response *ValidateSqlScriptResponse, err error)
- func (client *Client) ValidateSqlScriptWithCallback(request *ValidateSqlScriptRequest, ...) <-chan int
- func (client *Client) ValidateSqlScriptWithChan(request *ValidateSqlScriptRequest) (<-chan *ValidateSqlScriptResponse, <-chan error)
- type CreateConnectorRequest
- type CreateConnectorResponse
- type CreateDeploymentRequest
- type CreateDeploymentResponse
- type CreateFormatRequest
- type CreateFormatResponse
- type CreateMemberRequest
- type CreateMemberResponse
- type CreateSavepointRequest
- type CreateSavepointResponse
- type CreateSecretValueRequest
- type CreateSecretValueResponse
- type CreateUdfArtifactRequest
- type CreateUdfArtifactResponse
- type DatabaseExistsRequest
- type DatabaseExistsResponse
- type DeleteArtifactRequest
- type DeleteArtifactResponse
- type DeleteConnectorRequest
- type DeleteConnectorResponse
- type DeleteDeploymentRequest
- type DeleteDeploymentResponse
- type DeleteFormatRequest
- type DeleteFormatResponse
- type DeleteMemberRequest
- type DeleteMemberResponse
- type DeleteSecretValueRequest
- type DeleteSecretValueResponse
- type DeleteUdfArtifactRequest
- type DeleteUdfArtifactResponse
- type ExecuteSqlScriptRequest
- type ExecuteSqlScriptResponse
- type ExecuteSqlscriptsStatementsRequest
- type ExecuteSqlscriptsStatementsResponse
- type ForcefullyCreateLockRequest
- type ForcefullyCreateLockResponse
- type FunctionExistsRequest
- type FunctionExistsResponse
- type GenerateResourcePlanRequest
- type GenerateResourcePlanResponse
- type GetArtifactMetadataRequest
- type GetArtifactMetadataResponse
- type GetCatalogRequest
- type GetCatalogResponse
- type GetDatabaseRequest
- type GetDatabaseResponse
- type GetDefaultDatabaseRequest
- type GetDefaultDatabaseResponse
- type GetDeploymentDefaultsRequest
- type GetDeploymentDefaultsResponse
- type GetDeploymentRequest
- type GetDeploymentResponse
- type GetFunctionRequest
- type GetFunctionResponse
- type GetGlobalDeploymentDefaultsRequest
- type GetGlobalDeploymentDefaultsResponse
- type GetResourcePlanRequest
- type GetResourcePlanResponse
- type GetTableRequest
- type GetTableResponse
- type GetUdfArtifactRequest
- type GetUdfArtifactResponse
- type ListArtifactsRequest
- type ListArtifactsResponse
- type ListCatalogsRequest
- type ListCatalogsResponse
- type ListConnectorsRequest
- type ListConnectorsResponse
- type ListDatabasesRequest
- type ListDatabasesResponse
- type ListDeploymentTargetsRequest
- type ListDeploymentTargetsResponse
- type ListDeploymentsRequest
- type ListDeploymentsResponse
- type ListFlinkVersionsRequest
- type ListFlinkVersionsResponse
- type ListFormatsRequest
- type ListFormatsResponse
- type ListFunctionsRequest
- type ListFunctionsResponse
- type ListJobsRequest
- type ListJobsResponse
- type ListNamespacesRequest
- type ListNamespacesResponse
- type ListSavepointsRequest
- type ListSavepointsResponse
- type ListSecretValuesRequest
- type ListSecretValuesResponse
- type ListSessionClustersRequest
- type ListSessionClustersResponse
- type ListTablesRequest
- type ListTablesResponse
- type ParseConnectorRequest
- type ParseConnectorResponse
- type ParseFormatRequest
- type ParseFormatResponse
- type ReplaceDeploymentRequest
- type ReplaceDeploymentResponse
- type SetDeploymentResourceModeRequest
- type SetDeploymentResourceModeResponse
- type TableExistsRequest
- type TableExistsResponse
- type UpdateConnectorRequest
- type UpdateConnectorResponse
- type UpdateDeploymentDesiredStateRequest
- type UpdateDeploymentDesiredStateResponse
- type UpdateDeploymentRequest
- type UpdateDeploymentResponse
- type UpdateFormatRequest
- type UpdateFormatResponse
- type UpdateMemberRequest
- type UpdateMemberResponse
- type UpdateUdfArtifactRequest
- type UpdateUdfArtifactResponse
- type ValidateSqlScriptRequest
- type ValidateSqlScriptResponse
Constants ¶
This section is empty.
Variables ¶
var EndpointMap map[string]string
EndpointMap Endpoint Data
var EndpointType = "regional"
EndpointType regional or central
Functions ¶
func SetClientProperty ¶
SetClientProperty Set Property by Reflect
func SetEndpointDataToClient ¶
func SetEndpointDataToClient(client *Client)
SetEndpointDataToClient Set EndpointMap and ENdpointType
Types ¶
type Client ¶
Client is the sdk client struct, each func corresponds to an OpenAPI
func NewClientWithAccessKey ¶
func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
NewClientWithAccessKey is a shortcut to create sdk client with accesskey usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithEcsRamRole ¶
NewClientWithEcsRamRole is a shortcut to create sdk client with ecs ram role usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithOptions ¶
func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
NewClientWithOptions creates a sdk client with regionId/sdkConfig/credential this is the common api to create a sdk client
func NewClientWithProvider ¶
func NewClientWithProvider(regionId string, providers ...provider.Provider) (client *Client, err error)
NewClientWithProvider creates a sdk client with providers usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArn ¶
func NewClientWithRamRoleArn(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRamRoleArnAndPolicy ¶
func NewClientWithRamRoleArnAndPolicy(regionId string, accessKeyId, accessKeySecret, roleArn, roleSessionName, policy string) (client *Client, err error)
NewClientWithRamRoleArn is a shortcut to create sdk client with ram roleArn and policy usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithRsaKeyPair ¶
func NewClientWithRsaKeyPair(regionId string, publicKeyId, privateKey string, sessionExpiration int) (client *Client, err error)
NewClientWithRsaKeyPair is a shortcut to create sdk client with rsa key pair usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func NewClientWithStsToken ¶
func NewClientWithStsToken(regionId, stsAccessKeyId, stsAccessKeySecret, stsToken string) (client *Client, err error)
NewClientWithStsToken is a shortcut to create sdk client with sts token usage: https://github.com/aliyun/alibaba-cloud-sdk-go/blob/master/docs/2-Client-EN.md
func (*Client) CreateConnector ¶
func (client *Client) CreateConnector(request *CreateConnectorRequest) (response *CreateConnectorResponse, err error)
CreateConnector invokes the ververica.CreateConnector API synchronously
func (*Client) CreateConnectorWithCallback ¶
func (client *Client) CreateConnectorWithCallback(request *CreateConnectorRequest, callback func(response *CreateConnectorResponse, err error)) <-chan int
CreateConnectorWithCallback invokes the ververica.CreateConnector API asynchronously
func (*Client) CreateConnectorWithChan ¶
func (client *Client) CreateConnectorWithChan(request *CreateConnectorRequest) (<-chan *CreateConnectorResponse, <-chan error)
CreateConnectorWithChan invokes the ververica.CreateConnector API asynchronously
func (*Client) CreateDeployment ¶
func (client *Client) CreateDeployment(request *CreateDeploymentRequest) (response *CreateDeploymentResponse, err error)
CreateDeployment invokes the ververica.CreateDeployment API synchronously
func (*Client) CreateDeploymentWithCallback ¶
func (client *Client) CreateDeploymentWithCallback(request *CreateDeploymentRequest, callback func(response *CreateDeploymentResponse, err error)) <-chan int
CreateDeploymentWithCallback invokes the ververica.CreateDeployment API asynchronously
func (*Client) CreateDeploymentWithChan ¶
func (client *Client) CreateDeploymentWithChan(request *CreateDeploymentRequest) (<-chan *CreateDeploymentResponse, <-chan error)
CreateDeploymentWithChan invokes the ververica.CreateDeployment API asynchronously
func (*Client) CreateFormat ¶
func (client *Client) CreateFormat(request *CreateFormatRequest) (response *CreateFormatResponse, err error)
CreateFormat invokes the ververica.CreateFormat API synchronously
func (*Client) CreateFormatWithCallback ¶
func (client *Client) CreateFormatWithCallback(request *CreateFormatRequest, callback func(response *CreateFormatResponse, err error)) <-chan int
CreateFormatWithCallback invokes the ververica.CreateFormat API asynchronously
func (*Client) CreateFormatWithChan ¶
func (client *Client) CreateFormatWithChan(request *CreateFormatRequest) (<-chan *CreateFormatResponse, <-chan error)
CreateFormatWithChan invokes the ververica.CreateFormat API asynchronously
func (*Client) CreateMember ¶
func (client *Client) CreateMember(request *CreateMemberRequest) (response *CreateMemberResponse, err error)
CreateMember invokes the ververica.CreateMember API synchronously
func (*Client) CreateMemberWithCallback ¶
func (client *Client) CreateMemberWithCallback(request *CreateMemberRequest, callback func(response *CreateMemberResponse, err error)) <-chan int
CreateMemberWithCallback invokes the ververica.CreateMember API asynchronously
func (*Client) CreateMemberWithChan ¶
func (client *Client) CreateMemberWithChan(request *CreateMemberRequest) (<-chan *CreateMemberResponse, <-chan error)
CreateMemberWithChan invokes the ververica.CreateMember API asynchronously
func (*Client) CreateSavepoint ¶
func (client *Client) CreateSavepoint(request *CreateSavepointRequest) (response *CreateSavepointResponse, err error)
CreateSavepoint invokes the ververica.CreateSavepoint API synchronously
func (*Client) CreateSavepointWithCallback ¶
func (client *Client) CreateSavepointWithCallback(request *CreateSavepointRequest, callback func(response *CreateSavepointResponse, err error)) <-chan int
CreateSavepointWithCallback invokes the ververica.CreateSavepoint API asynchronously
func (*Client) CreateSavepointWithChan ¶
func (client *Client) CreateSavepointWithChan(request *CreateSavepointRequest) (<-chan *CreateSavepointResponse, <-chan error)
CreateSavepointWithChan invokes the ververica.CreateSavepoint API asynchronously
func (*Client) CreateSecretValue ¶
func (client *Client) CreateSecretValue(request *CreateSecretValueRequest) (response *CreateSecretValueResponse, err error)
CreateSecretValue invokes the ververica.CreateSecretValue API synchronously
func (*Client) CreateSecretValueWithCallback ¶
func (client *Client) CreateSecretValueWithCallback(request *CreateSecretValueRequest, callback func(response *CreateSecretValueResponse, err error)) <-chan int
CreateSecretValueWithCallback invokes the ververica.CreateSecretValue API asynchronously
func (*Client) CreateSecretValueWithChan ¶
func (client *Client) CreateSecretValueWithChan(request *CreateSecretValueRequest) (<-chan *CreateSecretValueResponse, <-chan error)
CreateSecretValueWithChan invokes the ververica.CreateSecretValue API asynchronously
func (*Client) CreateUdfArtifact ¶
func (client *Client) CreateUdfArtifact(request *CreateUdfArtifactRequest) (response *CreateUdfArtifactResponse, err error)
CreateUdfArtifact invokes the ververica.CreateUdfArtifact API synchronously
func (*Client) CreateUdfArtifactWithCallback ¶
func (client *Client) CreateUdfArtifactWithCallback(request *CreateUdfArtifactRequest, callback func(response *CreateUdfArtifactResponse, err error)) <-chan int
CreateUdfArtifactWithCallback invokes the ververica.CreateUdfArtifact API asynchronously
func (*Client) CreateUdfArtifactWithChan ¶
func (client *Client) CreateUdfArtifactWithChan(request *CreateUdfArtifactRequest) (<-chan *CreateUdfArtifactResponse, <-chan error)
CreateUdfArtifactWithChan invokes the ververica.CreateUdfArtifact API asynchronously
func (*Client) DatabaseExists ¶
func (client *Client) DatabaseExists(request *DatabaseExistsRequest) (response *DatabaseExistsResponse, err error)
DatabaseExists invokes the ververica.DatabaseExists API synchronously
func (*Client) DatabaseExistsWithCallback ¶
func (client *Client) DatabaseExistsWithCallback(request *DatabaseExistsRequest, callback func(response *DatabaseExistsResponse, err error)) <-chan int
DatabaseExistsWithCallback invokes the ververica.DatabaseExists API asynchronously
func (*Client) DatabaseExistsWithChan ¶
func (client *Client) DatabaseExistsWithChan(request *DatabaseExistsRequest) (<-chan *DatabaseExistsResponse, <-chan error)
DatabaseExistsWithChan invokes the ververica.DatabaseExists API asynchronously
func (*Client) DeleteArtifact ¶
func (client *Client) DeleteArtifact(request *DeleteArtifactRequest) (response *DeleteArtifactResponse, err error)
DeleteArtifact invokes the ververica.DeleteArtifact API synchronously
func (*Client) DeleteArtifactWithCallback ¶
func (client *Client) DeleteArtifactWithCallback(request *DeleteArtifactRequest, callback func(response *DeleteArtifactResponse, err error)) <-chan int
DeleteArtifactWithCallback invokes the ververica.DeleteArtifact API asynchronously
func (*Client) DeleteArtifactWithChan ¶
func (client *Client) DeleteArtifactWithChan(request *DeleteArtifactRequest) (<-chan *DeleteArtifactResponse, <-chan error)
DeleteArtifactWithChan invokes the ververica.DeleteArtifact API asynchronously
func (*Client) DeleteConnector ¶
func (client *Client) DeleteConnector(request *DeleteConnectorRequest) (response *DeleteConnectorResponse, err error)
DeleteConnector invokes the ververica.DeleteConnector API synchronously
func (*Client) DeleteConnectorWithCallback ¶
func (client *Client) DeleteConnectorWithCallback(request *DeleteConnectorRequest, callback func(response *DeleteConnectorResponse, err error)) <-chan int
DeleteConnectorWithCallback invokes the ververica.DeleteConnector API asynchronously
func (*Client) DeleteConnectorWithChan ¶
func (client *Client) DeleteConnectorWithChan(request *DeleteConnectorRequest) (<-chan *DeleteConnectorResponse, <-chan error)
DeleteConnectorWithChan invokes the ververica.DeleteConnector API asynchronously
func (*Client) DeleteDeployment ¶
func (client *Client) DeleteDeployment(request *DeleteDeploymentRequest) (response *DeleteDeploymentResponse, err error)
DeleteDeployment invokes the ververica.DeleteDeployment API synchronously
func (*Client) DeleteDeploymentWithCallback ¶
func (client *Client) DeleteDeploymentWithCallback(request *DeleteDeploymentRequest, callback func(response *DeleteDeploymentResponse, err error)) <-chan int
DeleteDeploymentWithCallback invokes the ververica.DeleteDeployment API asynchronously
func (*Client) DeleteDeploymentWithChan ¶
func (client *Client) DeleteDeploymentWithChan(request *DeleteDeploymentRequest) (<-chan *DeleteDeploymentResponse, <-chan error)
DeleteDeploymentWithChan invokes the ververica.DeleteDeployment API asynchronously
func (*Client) DeleteFormat ¶
func (client *Client) DeleteFormat(request *DeleteFormatRequest) (response *DeleteFormatResponse, err error)
DeleteFormat invokes the ververica.DeleteFormat API synchronously
func (*Client) DeleteFormatWithCallback ¶
func (client *Client) DeleteFormatWithCallback(request *DeleteFormatRequest, callback func(response *DeleteFormatResponse, err error)) <-chan int
DeleteFormatWithCallback invokes the ververica.DeleteFormat API asynchronously
func (*Client) DeleteFormatWithChan ¶
func (client *Client) DeleteFormatWithChan(request *DeleteFormatRequest) (<-chan *DeleteFormatResponse, <-chan error)
DeleteFormatWithChan invokes the ververica.DeleteFormat API asynchronously
func (*Client) DeleteMember ¶
func (client *Client) DeleteMember(request *DeleteMemberRequest) (response *DeleteMemberResponse, err error)
DeleteMember invokes the ververica.DeleteMember API synchronously
func (*Client) DeleteMemberWithCallback ¶
func (client *Client) DeleteMemberWithCallback(request *DeleteMemberRequest, callback func(response *DeleteMemberResponse, err error)) <-chan int
DeleteMemberWithCallback invokes the ververica.DeleteMember API asynchronously
func (*Client) DeleteMemberWithChan ¶
func (client *Client) DeleteMemberWithChan(request *DeleteMemberRequest) (<-chan *DeleteMemberResponse, <-chan error)
DeleteMemberWithChan invokes the ververica.DeleteMember API asynchronously
func (*Client) DeleteSecretValue ¶
func (client *Client) DeleteSecretValue(request *DeleteSecretValueRequest) (response *DeleteSecretValueResponse, err error)
DeleteSecretValue invokes the ververica.DeleteSecretValue API synchronously
func (*Client) DeleteSecretValueWithCallback ¶
func (client *Client) DeleteSecretValueWithCallback(request *DeleteSecretValueRequest, callback func(response *DeleteSecretValueResponse, err error)) <-chan int
DeleteSecretValueWithCallback invokes the ververica.DeleteSecretValue API asynchronously
func (*Client) DeleteSecretValueWithChan ¶
func (client *Client) DeleteSecretValueWithChan(request *DeleteSecretValueRequest) (<-chan *DeleteSecretValueResponse, <-chan error)
DeleteSecretValueWithChan invokes the ververica.DeleteSecretValue API asynchronously
func (*Client) DeleteUdfArtifact ¶
func (client *Client) DeleteUdfArtifact(request *DeleteUdfArtifactRequest) (response *DeleteUdfArtifactResponse, err error)
DeleteUdfArtifact invokes the ververica.DeleteUdfArtifact API synchronously
func (*Client) DeleteUdfArtifactWithCallback ¶
func (client *Client) DeleteUdfArtifactWithCallback(request *DeleteUdfArtifactRequest, callback func(response *DeleteUdfArtifactResponse, err error)) <-chan int
DeleteUdfArtifactWithCallback invokes the ververica.DeleteUdfArtifact API asynchronously
func (*Client) DeleteUdfArtifactWithChan ¶
func (client *Client) DeleteUdfArtifactWithChan(request *DeleteUdfArtifactRequest) (<-chan *DeleteUdfArtifactResponse, <-chan error)
DeleteUdfArtifactWithChan invokes the ververica.DeleteUdfArtifact API asynchronously
func (*Client) ExecuteSqlScript ¶
func (client *Client) ExecuteSqlScript(request *ExecuteSqlScriptRequest) (response *ExecuteSqlScriptResponse, err error)
ExecuteSqlScript invokes the ververica.ExecuteSqlScript API synchronously
func (*Client) ExecuteSqlScriptWithCallback ¶
func (client *Client) ExecuteSqlScriptWithCallback(request *ExecuteSqlScriptRequest, callback func(response *ExecuteSqlScriptResponse, err error)) <-chan int
ExecuteSqlScriptWithCallback invokes the ververica.ExecuteSqlScript API asynchronously
func (*Client) ExecuteSqlScriptWithChan ¶
func (client *Client) ExecuteSqlScriptWithChan(request *ExecuteSqlScriptRequest) (<-chan *ExecuteSqlScriptResponse, <-chan error)
ExecuteSqlScriptWithChan invokes the ververica.ExecuteSqlScript API asynchronously
func (*Client) ExecuteSqlscriptsStatements ¶
func (client *Client) ExecuteSqlscriptsStatements(request *ExecuteSqlscriptsStatementsRequest) (response *ExecuteSqlscriptsStatementsResponse, err error)
ExecuteSqlscriptsStatements invokes the ververica.ExecuteSqlscriptsStatements API synchronously
func (*Client) ExecuteSqlscriptsStatementsWithCallback ¶
func (client *Client) ExecuteSqlscriptsStatementsWithCallback(request *ExecuteSqlscriptsStatementsRequest, callback func(response *ExecuteSqlscriptsStatementsResponse, err error)) <-chan int
ExecuteSqlscriptsStatementsWithCallback invokes the ververica.ExecuteSqlscriptsStatements API asynchronously
func (*Client) ExecuteSqlscriptsStatementsWithChan ¶
func (client *Client) ExecuteSqlscriptsStatementsWithChan(request *ExecuteSqlscriptsStatementsRequest) (<-chan *ExecuteSqlscriptsStatementsResponse, <-chan error)
ExecuteSqlscriptsStatementsWithChan invokes the ververica.ExecuteSqlscriptsStatements API asynchronously
func (*Client) ForcefullyCreateLock ¶
func (client *Client) ForcefullyCreateLock(request *ForcefullyCreateLockRequest) (response *ForcefullyCreateLockResponse, err error)
ForcefullyCreateLock invokes the ververica.ForcefullyCreateLock API synchronously
func (*Client) ForcefullyCreateLockWithCallback ¶
func (client *Client) ForcefullyCreateLockWithCallback(request *ForcefullyCreateLockRequest, callback func(response *ForcefullyCreateLockResponse, err error)) <-chan int
ForcefullyCreateLockWithCallback invokes the ververica.ForcefullyCreateLock API asynchronously
func (*Client) ForcefullyCreateLockWithChan ¶
func (client *Client) ForcefullyCreateLockWithChan(request *ForcefullyCreateLockRequest) (<-chan *ForcefullyCreateLockResponse, <-chan error)
ForcefullyCreateLockWithChan invokes the ververica.ForcefullyCreateLock API asynchronously
func (*Client) FunctionExists ¶
func (client *Client) FunctionExists(request *FunctionExistsRequest) (response *FunctionExistsResponse, err error)
FunctionExists invokes the ververica.FunctionExists API synchronously
func (*Client) FunctionExistsWithCallback ¶
func (client *Client) FunctionExistsWithCallback(request *FunctionExistsRequest, callback func(response *FunctionExistsResponse, err error)) <-chan int
FunctionExistsWithCallback invokes the ververica.FunctionExists API asynchronously
func (*Client) FunctionExistsWithChan ¶
func (client *Client) FunctionExistsWithChan(request *FunctionExistsRequest) (<-chan *FunctionExistsResponse, <-chan error)
FunctionExistsWithChan invokes the ververica.FunctionExists API asynchronously
func (*Client) GenerateResourcePlan ¶
func (client *Client) GenerateResourcePlan(request *GenerateResourcePlanRequest) (response *GenerateResourcePlanResponse, err error)
GenerateResourcePlan invokes the ververica.GenerateResourcePlan API synchronously
func (*Client) GenerateResourcePlanWithCallback ¶
func (client *Client) GenerateResourcePlanWithCallback(request *GenerateResourcePlanRequest, callback func(response *GenerateResourcePlanResponse, err error)) <-chan int
GenerateResourcePlanWithCallback invokes the ververica.GenerateResourcePlan API asynchronously
func (*Client) GenerateResourcePlanWithChan ¶
func (client *Client) GenerateResourcePlanWithChan(request *GenerateResourcePlanRequest) (<-chan *GenerateResourcePlanResponse, <-chan error)
GenerateResourcePlanWithChan invokes the ververica.GenerateResourcePlan API asynchronously
func (*Client) GetArtifactMetadata ¶
func (client *Client) GetArtifactMetadata(request *GetArtifactMetadataRequest) (response *GetArtifactMetadataResponse, err error)
GetArtifactMetadata invokes the ververica.GetArtifactMetadata API synchronously
func (*Client) GetArtifactMetadataWithCallback ¶
func (client *Client) GetArtifactMetadataWithCallback(request *GetArtifactMetadataRequest, callback func(response *GetArtifactMetadataResponse, err error)) <-chan int
GetArtifactMetadataWithCallback invokes the ververica.GetArtifactMetadata API asynchronously
func (*Client) GetArtifactMetadataWithChan ¶
func (client *Client) GetArtifactMetadataWithChan(request *GetArtifactMetadataRequest) (<-chan *GetArtifactMetadataResponse, <-chan error)
GetArtifactMetadataWithChan invokes the ververica.GetArtifactMetadata API asynchronously
func (*Client) GetCatalog ¶
func (client *Client) GetCatalog(request *GetCatalogRequest) (response *GetCatalogResponse, err error)
GetCatalog invokes the ververica.GetCatalog API synchronously
func (*Client) GetCatalogWithCallback ¶
func (client *Client) GetCatalogWithCallback(request *GetCatalogRequest, callback func(response *GetCatalogResponse, err error)) <-chan int
GetCatalogWithCallback invokes the ververica.GetCatalog API asynchronously
func (*Client) GetCatalogWithChan ¶
func (client *Client) GetCatalogWithChan(request *GetCatalogRequest) (<-chan *GetCatalogResponse, <-chan error)
GetCatalogWithChan invokes the ververica.GetCatalog API asynchronously
func (*Client) GetDatabase ¶
func (client *Client) GetDatabase(request *GetDatabaseRequest) (response *GetDatabaseResponse, err error)
GetDatabase invokes the ververica.GetDatabase API synchronously
func (*Client) GetDatabaseWithCallback ¶
func (client *Client) GetDatabaseWithCallback(request *GetDatabaseRequest, callback func(response *GetDatabaseResponse, err error)) <-chan int
GetDatabaseWithCallback invokes the ververica.GetDatabase API asynchronously
func (*Client) GetDatabaseWithChan ¶
func (client *Client) GetDatabaseWithChan(request *GetDatabaseRequest) (<-chan *GetDatabaseResponse, <-chan error)
GetDatabaseWithChan invokes the ververica.GetDatabase API asynchronously
func (*Client) GetDefaultDatabase ¶
func (client *Client) GetDefaultDatabase(request *GetDefaultDatabaseRequest) (response *GetDefaultDatabaseResponse, err error)
GetDefaultDatabase invokes the ververica.GetDefaultDatabase API synchronously
func (*Client) GetDefaultDatabaseWithCallback ¶
func (client *Client) GetDefaultDatabaseWithCallback(request *GetDefaultDatabaseRequest, callback func(response *GetDefaultDatabaseResponse, err error)) <-chan int
GetDefaultDatabaseWithCallback invokes the ververica.GetDefaultDatabase API asynchronously
func (*Client) GetDefaultDatabaseWithChan ¶
func (client *Client) GetDefaultDatabaseWithChan(request *GetDefaultDatabaseRequest) (<-chan *GetDefaultDatabaseResponse, <-chan error)
GetDefaultDatabaseWithChan invokes the ververica.GetDefaultDatabase API asynchronously
func (*Client) GetDeployment ¶
func (client *Client) GetDeployment(request *GetDeploymentRequest) (response *GetDeploymentResponse, err error)
GetDeployment invokes the ververica.GetDeployment API synchronously
func (*Client) GetDeploymentDefaults ¶
func (client *Client) GetDeploymentDefaults(request *GetDeploymentDefaultsRequest) (response *GetDeploymentDefaultsResponse, err error)
GetDeploymentDefaults invokes the ververica.GetDeploymentDefaults API synchronously
func (*Client) GetDeploymentDefaultsWithCallback ¶
func (client *Client) GetDeploymentDefaultsWithCallback(request *GetDeploymentDefaultsRequest, callback func(response *GetDeploymentDefaultsResponse, err error)) <-chan int
GetDeploymentDefaultsWithCallback invokes the ververica.GetDeploymentDefaults API asynchronously
func (*Client) GetDeploymentDefaultsWithChan ¶
func (client *Client) GetDeploymentDefaultsWithChan(request *GetDeploymentDefaultsRequest) (<-chan *GetDeploymentDefaultsResponse, <-chan error)
GetDeploymentDefaultsWithChan invokes the ververica.GetDeploymentDefaults API asynchronously
func (*Client) GetDeploymentWithCallback ¶
func (client *Client) GetDeploymentWithCallback(request *GetDeploymentRequest, callback func(response *GetDeploymentResponse, err error)) <-chan int
GetDeploymentWithCallback invokes the ververica.GetDeployment API asynchronously
func (*Client) GetDeploymentWithChan ¶
func (client *Client) GetDeploymentWithChan(request *GetDeploymentRequest) (<-chan *GetDeploymentResponse, <-chan error)
GetDeploymentWithChan invokes the ververica.GetDeployment API asynchronously
func (*Client) GetFunction ¶
func (client *Client) GetFunction(request *GetFunctionRequest) (response *GetFunctionResponse, err error)
GetFunction invokes the ververica.GetFunction API synchronously
func (*Client) GetFunctionWithCallback ¶
func (client *Client) GetFunctionWithCallback(request *GetFunctionRequest, callback func(response *GetFunctionResponse, err error)) <-chan int
GetFunctionWithCallback invokes the ververica.GetFunction API asynchronously
func (*Client) GetFunctionWithChan ¶
func (client *Client) GetFunctionWithChan(request *GetFunctionRequest) (<-chan *GetFunctionResponse, <-chan error)
GetFunctionWithChan invokes the ververica.GetFunction API asynchronously
func (*Client) GetGlobalDeploymentDefaults ¶
func (client *Client) GetGlobalDeploymentDefaults(request *GetGlobalDeploymentDefaultsRequest) (response *GetGlobalDeploymentDefaultsResponse, err error)
GetGlobalDeploymentDefaults invokes the ververica.GetGlobalDeploymentDefaults API synchronously
func (*Client) GetGlobalDeploymentDefaultsWithCallback ¶
func (client *Client) GetGlobalDeploymentDefaultsWithCallback(request *GetGlobalDeploymentDefaultsRequest, callback func(response *GetGlobalDeploymentDefaultsResponse, err error)) <-chan int
GetGlobalDeploymentDefaultsWithCallback invokes the ververica.GetGlobalDeploymentDefaults API asynchronously
func (*Client) GetGlobalDeploymentDefaultsWithChan ¶
func (client *Client) GetGlobalDeploymentDefaultsWithChan(request *GetGlobalDeploymentDefaultsRequest) (<-chan *GetGlobalDeploymentDefaultsResponse, <-chan error)
GetGlobalDeploymentDefaultsWithChan invokes the ververica.GetGlobalDeploymentDefaults API asynchronously
func (*Client) GetResourcePlan ¶
func (client *Client) GetResourcePlan(request *GetResourcePlanRequest) (response *GetResourcePlanResponse, err error)
GetResourcePlan invokes the ververica.GetResourcePlan API synchronously
func (*Client) GetResourcePlanWithCallback ¶
func (client *Client) GetResourcePlanWithCallback(request *GetResourcePlanRequest, callback func(response *GetResourcePlanResponse, err error)) <-chan int
GetResourcePlanWithCallback invokes the ververica.GetResourcePlan API asynchronously
func (*Client) GetResourcePlanWithChan ¶
func (client *Client) GetResourcePlanWithChan(request *GetResourcePlanRequest) (<-chan *GetResourcePlanResponse, <-chan error)
GetResourcePlanWithChan invokes the ververica.GetResourcePlan API asynchronously
func (*Client) GetTable ¶
func (client *Client) GetTable(request *GetTableRequest) (response *GetTableResponse, err error)
GetTable invokes the ververica.GetTable API synchronously
func (*Client) GetTableWithCallback ¶
func (client *Client) GetTableWithCallback(request *GetTableRequest, callback func(response *GetTableResponse, err error)) <-chan int
GetTableWithCallback invokes the ververica.GetTable API asynchronously
func (*Client) GetTableWithChan ¶
func (client *Client) GetTableWithChan(request *GetTableRequest) (<-chan *GetTableResponse, <-chan error)
GetTableWithChan invokes the ververica.GetTable API asynchronously
func (*Client) GetUdfArtifact ¶
func (client *Client) GetUdfArtifact(request *GetUdfArtifactRequest) (response *GetUdfArtifactResponse, err error)
GetUdfArtifact invokes the ververica.GetUdfArtifact API synchronously
func (*Client) GetUdfArtifactWithCallback ¶
func (client *Client) GetUdfArtifactWithCallback(request *GetUdfArtifactRequest, callback func(response *GetUdfArtifactResponse, err error)) <-chan int
GetUdfArtifactWithCallback invokes the ververica.GetUdfArtifact API asynchronously
func (*Client) GetUdfArtifactWithChan ¶
func (client *Client) GetUdfArtifactWithChan(request *GetUdfArtifactRequest) (<-chan *GetUdfArtifactResponse, <-chan error)
GetUdfArtifactWithChan invokes the ververica.GetUdfArtifact API asynchronously
func (*Client) ListArtifacts ¶
func (client *Client) ListArtifacts(request *ListArtifactsRequest) (response *ListArtifactsResponse, err error)
ListArtifacts invokes the ververica.ListArtifacts API synchronously
func (*Client) ListArtifactsWithCallback ¶
func (client *Client) ListArtifactsWithCallback(request *ListArtifactsRequest, callback func(response *ListArtifactsResponse, err error)) <-chan int
ListArtifactsWithCallback invokes the ververica.ListArtifacts API asynchronously
func (*Client) ListArtifactsWithChan ¶
func (client *Client) ListArtifactsWithChan(request *ListArtifactsRequest) (<-chan *ListArtifactsResponse, <-chan error)
ListArtifactsWithChan invokes the ververica.ListArtifacts API asynchronously
func (*Client) ListCatalogs ¶
func (client *Client) ListCatalogs(request *ListCatalogsRequest) (response *ListCatalogsResponse, err error)
ListCatalogs invokes the ververica.ListCatalogs API synchronously
func (*Client) ListCatalogsWithCallback ¶
func (client *Client) ListCatalogsWithCallback(request *ListCatalogsRequest, callback func(response *ListCatalogsResponse, err error)) <-chan int
ListCatalogsWithCallback invokes the ververica.ListCatalogs API asynchronously
func (*Client) ListCatalogsWithChan ¶
func (client *Client) ListCatalogsWithChan(request *ListCatalogsRequest) (<-chan *ListCatalogsResponse, <-chan error)
ListCatalogsWithChan invokes the ververica.ListCatalogs API asynchronously
func (*Client) ListConnectors ¶
func (client *Client) ListConnectors(request *ListConnectorsRequest) (response *ListConnectorsResponse, err error)
ListConnectors invokes the ververica.ListConnectors API synchronously
func (*Client) ListConnectorsWithCallback ¶
func (client *Client) ListConnectorsWithCallback(request *ListConnectorsRequest, callback func(response *ListConnectorsResponse, err error)) <-chan int
ListConnectorsWithCallback invokes the ververica.ListConnectors API asynchronously
func (*Client) ListConnectorsWithChan ¶
func (client *Client) ListConnectorsWithChan(request *ListConnectorsRequest) (<-chan *ListConnectorsResponse, <-chan error)
ListConnectorsWithChan invokes the ververica.ListConnectors API asynchronously
func (*Client) ListDatabases ¶
func (client *Client) ListDatabases(request *ListDatabasesRequest) (response *ListDatabasesResponse, err error)
ListDatabases invokes the ververica.ListDatabases API synchronously
func (*Client) ListDatabasesWithCallback ¶
func (client *Client) ListDatabasesWithCallback(request *ListDatabasesRequest, callback func(response *ListDatabasesResponse, err error)) <-chan int
ListDatabasesWithCallback invokes the ververica.ListDatabases API asynchronously
func (*Client) ListDatabasesWithChan ¶
func (client *Client) ListDatabasesWithChan(request *ListDatabasesRequest) (<-chan *ListDatabasesResponse, <-chan error)
ListDatabasesWithChan invokes the ververica.ListDatabases API asynchronously
func (*Client) ListDeploymentTargets ¶
func (client *Client) ListDeploymentTargets(request *ListDeploymentTargetsRequest) (response *ListDeploymentTargetsResponse, err error)
ListDeploymentTargets invokes the ververica.ListDeploymentTargets API synchronously
func (*Client) ListDeploymentTargetsWithCallback ¶
func (client *Client) ListDeploymentTargetsWithCallback(request *ListDeploymentTargetsRequest, callback func(response *ListDeploymentTargetsResponse, err error)) <-chan int
ListDeploymentTargetsWithCallback invokes the ververica.ListDeploymentTargets API asynchronously
func (*Client) ListDeploymentTargetsWithChan ¶
func (client *Client) ListDeploymentTargetsWithChan(request *ListDeploymentTargetsRequest) (<-chan *ListDeploymentTargetsResponse, <-chan error)
ListDeploymentTargetsWithChan invokes the ververica.ListDeploymentTargets API asynchronously
func (*Client) ListDeployments ¶
func (client *Client) ListDeployments(request *ListDeploymentsRequest) (response *ListDeploymentsResponse, err error)
ListDeployments invokes the ververica.ListDeployments API synchronously
func (*Client) ListDeploymentsWithCallback ¶
func (client *Client) ListDeploymentsWithCallback(request *ListDeploymentsRequest, callback func(response *ListDeploymentsResponse, err error)) <-chan int
ListDeploymentsWithCallback invokes the ververica.ListDeployments API asynchronously
func (*Client) ListDeploymentsWithChan ¶
func (client *Client) ListDeploymentsWithChan(request *ListDeploymentsRequest) (<-chan *ListDeploymentsResponse, <-chan error)
ListDeploymentsWithChan invokes the ververica.ListDeployments API asynchronously
func (*Client) ListFlinkVersions ¶
func (client *Client) ListFlinkVersions(request *ListFlinkVersionsRequest) (response *ListFlinkVersionsResponse, err error)
ListFlinkVersions invokes the ververica.ListFlinkVersions API synchronously
func (*Client) ListFlinkVersionsWithCallback ¶
func (client *Client) ListFlinkVersionsWithCallback(request *ListFlinkVersionsRequest, callback func(response *ListFlinkVersionsResponse, err error)) <-chan int
ListFlinkVersionsWithCallback invokes the ververica.ListFlinkVersions API asynchronously
func (*Client) ListFlinkVersionsWithChan ¶
func (client *Client) ListFlinkVersionsWithChan(request *ListFlinkVersionsRequest) (<-chan *ListFlinkVersionsResponse, <-chan error)
ListFlinkVersionsWithChan invokes the ververica.ListFlinkVersions API asynchronously
func (*Client) ListFormats ¶
func (client *Client) ListFormats(request *ListFormatsRequest) (response *ListFormatsResponse, err error)
ListFormats invokes the ververica.ListFormats API synchronously
func (*Client) ListFormatsWithCallback ¶
func (client *Client) ListFormatsWithCallback(request *ListFormatsRequest, callback func(response *ListFormatsResponse, err error)) <-chan int
ListFormatsWithCallback invokes the ververica.ListFormats API asynchronously
func (*Client) ListFormatsWithChan ¶
func (client *Client) ListFormatsWithChan(request *ListFormatsRequest) (<-chan *ListFormatsResponse, <-chan error)
ListFormatsWithChan invokes the ververica.ListFormats API asynchronously
func (*Client) ListFunctions ¶
func (client *Client) ListFunctions(request *ListFunctionsRequest) (response *ListFunctionsResponse, err error)
ListFunctions invokes the ververica.ListFunctions API synchronously
func (*Client) ListFunctionsWithCallback ¶
func (client *Client) ListFunctionsWithCallback(request *ListFunctionsRequest, callback func(response *ListFunctionsResponse, err error)) <-chan int
ListFunctionsWithCallback invokes the ververica.ListFunctions API asynchronously
func (*Client) ListFunctionsWithChan ¶
func (client *Client) ListFunctionsWithChan(request *ListFunctionsRequest) (<-chan *ListFunctionsResponse, <-chan error)
ListFunctionsWithChan invokes the ververica.ListFunctions API asynchronously
func (*Client) ListJobs ¶
func (client *Client) ListJobs(request *ListJobsRequest) (response *ListJobsResponse, err error)
ListJobs invokes the ververica.ListJobs API synchronously
func (*Client) ListJobsWithCallback ¶
func (client *Client) ListJobsWithCallback(request *ListJobsRequest, callback func(response *ListJobsResponse, err error)) <-chan int
ListJobsWithCallback invokes the ververica.ListJobs API asynchronously
func (*Client) ListJobsWithChan ¶
func (client *Client) ListJobsWithChan(request *ListJobsRequest) (<-chan *ListJobsResponse, <-chan error)
ListJobsWithChan invokes the ververica.ListJobs API asynchronously
func (*Client) ListNamespaces ¶
func (client *Client) ListNamespaces(request *ListNamespacesRequest) (response *ListNamespacesResponse, err error)
ListNamespaces invokes the ververica.ListNamespaces API synchronously
func (*Client) ListNamespacesWithCallback ¶
func (client *Client) ListNamespacesWithCallback(request *ListNamespacesRequest, callback func(response *ListNamespacesResponse, err error)) <-chan int
ListNamespacesWithCallback invokes the ververica.ListNamespaces API asynchronously
func (*Client) ListNamespacesWithChan ¶
func (client *Client) ListNamespacesWithChan(request *ListNamespacesRequest) (<-chan *ListNamespacesResponse, <-chan error)
ListNamespacesWithChan invokes the ververica.ListNamespaces API asynchronously
func (*Client) ListSavepoints ¶
func (client *Client) ListSavepoints(request *ListSavepointsRequest) (response *ListSavepointsResponse, err error)
ListSavepoints invokes the ververica.ListSavepoints API synchronously
func (*Client) ListSavepointsWithCallback ¶
func (client *Client) ListSavepointsWithCallback(request *ListSavepointsRequest, callback func(response *ListSavepointsResponse, err error)) <-chan int
ListSavepointsWithCallback invokes the ververica.ListSavepoints API asynchronously
func (*Client) ListSavepointsWithChan ¶
func (client *Client) ListSavepointsWithChan(request *ListSavepointsRequest) (<-chan *ListSavepointsResponse, <-chan error)
ListSavepointsWithChan invokes the ververica.ListSavepoints API asynchronously
func (*Client) ListSecretValues ¶
func (client *Client) ListSecretValues(request *ListSecretValuesRequest) (response *ListSecretValuesResponse, err error)
ListSecretValues invokes the ververica.ListSecretValues API synchronously
func (*Client) ListSecretValuesWithCallback ¶
func (client *Client) ListSecretValuesWithCallback(request *ListSecretValuesRequest, callback func(response *ListSecretValuesResponse, err error)) <-chan int
ListSecretValuesWithCallback invokes the ververica.ListSecretValues API asynchronously
func (*Client) ListSecretValuesWithChan ¶
func (client *Client) ListSecretValuesWithChan(request *ListSecretValuesRequest) (<-chan *ListSecretValuesResponse, <-chan error)
ListSecretValuesWithChan invokes the ververica.ListSecretValues API asynchronously
func (*Client) ListSessionClusters ¶
func (client *Client) ListSessionClusters(request *ListSessionClustersRequest) (response *ListSessionClustersResponse, err error)
ListSessionClusters invokes the ververica.ListSessionClusters API synchronously
func (*Client) ListSessionClustersWithCallback ¶
func (client *Client) ListSessionClustersWithCallback(request *ListSessionClustersRequest, callback func(response *ListSessionClustersResponse, err error)) <-chan int
ListSessionClustersWithCallback invokes the ververica.ListSessionClusters API asynchronously
func (*Client) ListSessionClustersWithChan ¶
func (client *Client) ListSessionClustersWithChan(request *ListSessionClustersRequest) (<-chan *ListSessionClustersResponse, <-chan error)
ListSessionClustersWithChan invokes the ververica.ListSessionClusters API asynchronously
func (*Client) ListTables ¶
func (client *Client) ListTables(request *ListTablesRequest) (response *ListTablesResponse, err error)
ListTables invokes the ververica.ListTables API synchronously
func (*Client) ListTablesWithCallback ¶
func (client *Client) ListTablesWithCallback(request *ListTablesRequest, callback func(response *ListTablesResponse, err error)) <-chan int
ListTablesWithCallback invokes the ververica.ListTables API asynchronously
func (*Client) ListTablesWithChan ¶
func (client *Client) ListTablesWithChan(request *ListTablesRequest) (<-chan *ListTablesResponse, <-chan error)
ListTablesWithChan invokes the ververica.ListTables API asynchronously
func (*Client) ParseConnector ¶
func (client *Client) ParseConnector(request *ParseConnectorRequest) (response *ParseConnectorResponse, err error)
ParseConnector invokes the ververica.ParseConnector API synchronously
func (*Client) ParseConnectorWithCallback ¶
func (client *Client) ParseConnectorWithCallback(request *ParseConnectorRequest, callback func(response *ParseConnectorResponse, err error)) <-chan int
ParseConnectorWithCallback invokes the ververica.ParseConnector API asynchronously
func (*Client) ParseConnectorWithChan ¶
func (client *Client) ParseConnectorWithChan(request *ParseConnectorRequest) (<-chan *ParseConnectorResponse, <-chan error)
ParseConnectorWithChan invokes the ververica.ParseConnector API asynchronously
func (*Client) ParseFormat ¶
func (client *Client) ParseFormat(request *ParseFormatRequest) (response *ParseFormatResponse, err error)
ParseFormat invokes the ververica.ParseFormat API synchronously
func (*Client) ParseFormatWithCallback ¶
func (client *Client) ParseFormatWithCallback(request *ParseFormatRequest, callback func(response *ParseFormatResponse, err error)) <-chan int
ParseFormatWithCallback invokes the ververica.ParseFormat API asynchronously
func (*Client) ParseFormatWithChan ¶
func (client *Client) ParseFormatWithChan(request *ParseFormatRequest) (<-chan *ParseFormatResponse, <-chan error)
ParseFormatWithChan invokes the ververica.ParseFormat API asynchronously
func (*Client) ReplaceDeployment ¶
func (client *Client) ReplaceDeployment(request *ReplaceDeploymentRequest) (response *ReplaceDeploymentResponse, err error)
ReplaceDeployment invokes the ververica.ReplaceDeployment API synchronously
func (*Client) ReplaceDeploymentWithCallback ¶
func (client *Client) ReplaceDeploymentWithCallback(request *ReplaceDeploymentRequest, callback func(response *ReplaceDeploymentResponse, err error)) <-chan int
ReplaceDeploymentWithCallback invokes the ververica.ReplaceDeployment API asynchronously
func (*Client) ReplaceDeploymentWithChan ¶
func (client *Client) ReplaceDeploymentWithChan(request *ReplaceDeploymentRequest) (<-chan *ReplaceDeploymentResponse, <-chan error)
ReplaceDeploymentWithChan invokes the ververica.ReplaceDeployment API asynchronously
func (*Client) SetDeploymentResourceMode ¶
func (client *Client) SetDeploymentResourceMode(request *SetDeploymentResourceModeRequest) (response *SetDeploymentResourceModeResponse, err error)
SetDeploymentResourceMode invokes the ververica.SetDeploymentResourceMode API synchronously
func (*Client) SetDeploymentResourceModeWithCallback ¶
func (client *Client) SetDeploymentResourceModeWithCallback(request *SetDeploymentResourceModeRequest, callback func(response *SetDeploymentResourceModeResponse, err error)) <-chan int
SetDeploymentResourceModeWithCallback invokes the ververica.SetDeploymentResourceMode API asynchronously
func (*Client) SetDeploymentResourceModeWithChan ¶
func (client *Client) SetDeploymentResourceModeWithChan(request *SetDeploymentResourceModeRequest) (<-chan *SetDeploymentResourceModeResponse, <-chan error)
SetDeploymentResourceModeWithChan invokes the ververica.SetDeploymentResourceMode API asynchronously
func (*Client) TableExists ¶
func (client *Client) TableExists(request *TableExistsRequest) (response *TableExistsResponse, err error)
TableExists invokes the ververica.TableExists API synchronously
func (*Client) TableExistsWithCallback ¶
func (client *Client) TableExistsWithCallback(request *TableExistsRequest, callback func(response *TableExistsResponse, err error)) <-chan int
TableExistsWithCallback invokes the ververica.TableExists API asynchronously
func (*Client) TableExistsWithChan ¶
func (client *Client) TableExistsWithChan(request *TableExistsRequest) (<-chan *TableExistsResponse, <-chan error)
TableExistsWithChan invokes the ververica.TableExists API asynchronously
func (*Client) UpdateConnector ¶
func (client *Client) UpdateConnector(request *UpdateConnectorRequest) (response *UpdateConnectorResponse, err error)
UpdateConnector invokes the ververica.UpdateConnector API synchronously
func (*Client) UpdateConnectorWithCallback ¶
func (client *Client) UpdateConnectorWithCallback(request *UpdateConnectorRequest, callback func(response *UpdateConnectorResponse, err error)) <-chan int
UpdateConnectorWithCallback invokes the ververica.UpdateConnector API asynchronously
func (*Client) UpdateConnectorWithChan ¶
func (client *Client) UpdateConnectorWithChan(request *UpdateConnectorRequest) (<-chan *UpdateConnectorResponse, <-chan error)
UpdateConnectorWithChan invokes the ververica.UpdateConnector API asynchronously
func (*Client) UpdateDeployment ¶
func (client *Client) UpdateDeployment(request *UpdateDeploymentRequest) (response *UpdateDeploymentResponse, err error)
UpdateDeployment invokes the ververica.UpdateDeployment API synchronously
func (*Client) UpdateDeploymentDesiredState ¶
func (client *Client) UpdateDeploymentDesiredState(request *UpdateDeploymentDesiredStateRequest) (response *UpdateDeploymentDesiredStateResponse, err error)
UpdateDeploymentDesiredState invokes the ververica.UpdateDeploymentDesiredState API synchronously
func (*Client) UpdateDeploymentDesiredStateWithCallback ¶
func (client *Client) UpdateDeploymentDesiredStateWithCallback(request *UpdateDeploymentDesiredStateRequest, callback func(response *UpdateDeploymentDesiredStateResponse, err error)) <-chan int
UpdateDeploymentDesiredStateWithCallback invokes the ververica.UpdateDeploymentDesiredState API asynchronously
func (*Client) UpdateDeploymentDesiredStateWithChan ¶
func (client *Client) UpdateDeploymentDesiredStateWithChan(request *UpdateDeploymentDesiredStateRequest) (<-chan *UpdateDeploymentDesiredStateResponse, <-chan error)
UpdateDeploymentDesiredStateWithChan invokes the ververica.UpdateDeploymentDesiredState API asynchronously
func (*Client) UpdateDeploymentWithCallback ¶
func (client *Client) UpdateDeploymentWithCallback(request *UpdateDeploymentRequest, callback func(response *UpdateDeploymentResponse, err error)) <-chan int
UpdateDeploymentWithCallback invokes the ververica.UpdateDeployment API asynchronously
func (*Client) UpdateDeploymentWithChan ¶
func (client *Client) UpdateDeploymentWithChan(request *UpdateDeploymentRequest) (<-chan *UpdateDeploymentResponse, <-chan error)
UpdateDeploymentWithChan invokes the ververica.UpdateDeployment API asynchronously
func (*Client) UpdateFormat ¶
func (client *Client) UpdateFormat(request *UpdateFormatRequest) (response *UpdateFormatResponse, err error)
UpdateFormat invokes the ververica.UpdateFormat API synchronously
func (*Client) UpdateFormatWithCallback ¶
func (client *Client) UpdateFormatWithCallback(request *UpdateFormatRequest, callback func(response *UpdateFormatResponse, err error)) <-chan int
UpdateFormatWithCallback invokes the ververica.UpdateFormat API asynchronously
func (*Client) UpdateFormatWithChan ¶
func (client *Client) UpdateFormatWithChan(request *UpdateFormatRequest) (<-chan *UpdateFormatResponse, <-chan error)
UpdateFormatWithChan invokes the ververica.UpdateFormat API asynchronously
func (*Client) UpdateMember ¶
func (client *Client) UpdateMember(request *UpdateMemberRequest) (response *UpdateMemberResponse, err error)
UpdateMember invokes the ververica.UpdateMember API synchronously
func (*Client) UpdateMemberWithCallback ¶
func (client *Client) UpdateMemberWithCallback(request *UpdateMemberRequest, callback func(response *UpdateMemberResponse, err error)) <-chan int
UpdateMemberWithCallback invokes the ververica.UpdateMember API asynchronously
func (*Client) UpdateMemberWithChan ¶
func (client *Client) UpdateMemberWithChan(request *UpdateMemberRequest) (<-chan *UpdateMemberResponse, <-chan error)
UpdateMemberWithChan invokes the ververica.UpdateMember API asynchronously
func (*Client) UpdateUdfArtifact ¶
func (client *Client) UpdateUdfArtifact(request *UpdateUdfArtifactRequest) (response *UpdateUdfArtifactResponse, err error)
UpdateUdfArtifact invokes the ververica.UpdateUdfArtifact API synchronously
func (*Client) UpdateUdfArtifactWithCallback ¶
func (client *Client) UpdateUdfArtifactWithCallback(request *UpdateUdfArtifactRequest, callback func(response *UpdateUdfArtifactResponse, err error)) <-chan int
UpdateUdfArtifactWithCallback invokes the ververica.UpdateUdfArtifact API asynchronously
func (*Client) UpdateUdfArtifactWithChan ¶
func (client *Client) UpdateUdfArtifactWithChan(request *UpdateUdfArtifactRequest) (<-chan *UpdateUdfArtifactResponse, <-chan error)
UpdateUdfArtifactWithChan invokes the ververica.UpdateUdfArtifact API asynchronously
func (*Client) ValidateSqlScript ¶
func (client *Client) ValidateSqlScript(request *ValidateSqlScriptRequest) (response *ValidateSqlScriptResponse, err error)
ValidateSqlScript invokes the ververica.ValidateSqlScript API synchronously
func (*Client) ValidateSqlScriptWithCallback ¶
func (client *Client) ValidateSqlScriptWithCallback(request *ValidateSqlScriptRequest, callback func(response *ValidateSqlScriptResponse, err error)) <-chan int
ValidateSqlScriptWithCallback invokes the ververica.ValidateSqlScript API asynchronously
func (*Client) ValidateSqlScriptWithChan ¶
func (client *Client) ValidateSqlScriptWithChan(request *ValidateSqlScriptRequest) (<-chan *ValidateSqlScriptResponse, <-chan error)
ValidateSqlScriptWithChan invokes the ververica.ValidateSqlScript API asynchronously
type CreateConnectorRequest ¶
type CreateConnectorRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateConnectorRequest is the request struct for api CreateConnector
func CreateCreateConnectorRequest ¶
func CreateCreateConnectorRequest() (request *CreateConnectorRequest)
CreateCreateConnectorRequest creates a request to invoke CreateConnector API
type CreateConnectorResponse ¶
type CreateConnectorResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
CreateConnectorResponse is the response struct for api CreateConnector
func CreateCreateConnectorResponse ¶
func CreateCreateConnectorResponse() (response *CreateConnectorResponse)
CreateCreateConnectorResponse creates a response to parse from CreateConnector response
type CreateDeploymentRequest ¶
type CreateDeploymentRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateDeploymentRequest is the request struct for api CreateDeployment
func CreateCreateDeploymentRequest ¶
func CreateCreateDeploymentRequest() (request *CreateDeploymentRequest)
CreateCreateDeploymentRequest creates a request to invoke CreateDeployment API
type CreateDeploymentResponse ¶
type CreateDeploymentResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
CreateDeploymentResponse is the response struct for api CreateDeployment
func CreateCreateDeploymentResponse ¶
func CreateCreateDeploymentResponse() (response *CreateDeploymentResponse)
CreateCreateDeploymentResponse creates a response to parse from CreateDeployment response
type CreateFormatRequest ¶
type CreateFormatRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateFormatRequest is the request struct for api CreateFormat
func CreateCreateFormatRequest ¶
func CreateCreateFormatRequest() (request *CreateFormatRequest)
CreateCreateFormatRequest creates a request to invoke CreateFormat API
type CreateFormatResponse ¶
type CreateFormatResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
CreateFormatResponse is the response struct for api CreateFormat
func CreateCreateFormatResponse ¶
func CreateCreateFormatResponse() (response *CreateFormatResponse)
CreateCreateFormatResponse creates a response to parse from CreateFormat response
type CreateMemberRequest ¶
type CreateMemberRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateMemberRequest is the request struct for api CreateMember
func CreateCreateMemberRequest ¶
func CreateCreateMemberRequest() (request *CreateMemberRequest)
CreateCreateMemberRequest creates a request to invoke CreateMember API
type CreateMemberResponse ¶
type CreateMemberResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
CreateMemberResponse is the response struct for api CreateMember
func CreateCreateMemberResponse ¶
func CreateCreateMemberResponse() (response *CreateMemberResponse)
CreateCreateMemberResponse creates a response to parse from CreateMember response
type CreateSavepointRequest ¶
type CreateSavepointRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateSavepointRequest is the request struct for api CreateSavepoint
func CreateCreateSavepointRequest ¶
func CreateCreateSavepointRequest() (request *CreateSavepointRequest)
CreateCreateSavepointRequest creates a request to invoke CreateSavepoint API
type CreateSavepointResponse ¶
type CreateSavepointResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
CreateSavepointResponse is the response struct for api CreateSavepoint
func CreateCreateSavepointResponse ¶
func CreateCreateSavepointResponse() (response *CreateSavepointResponse)
CreateCreateSavepointResponse creates a response to parse from CreateSavepoint response
type CreateSecretValueRequest ¶
type CreateSecretValueRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateSecretValueRequest is the request struct for api CreateSecretValue
func CreateCreateSecretValueRequest ¶
func CreateCreateSecretValueRequest() (request *CreateSecretValueRequest)
CreateCreateSecretValueRequest creates a request to invoke CreateSecretValue API
type CreateSecretValueResponse ¶
type CreateSecretValueResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
CreateSecretValueResponse is the response struct for api CreateSecretValue
func CreateCreateSecretValueResponse ¶
func CreateCreateSecretValueResponse() (response *CreateSecretValueResponse)
CreateCreateSecretValueResponse creates a response to parse from CreateSecretValue response
type CreateUdfArtifactRequest ¶
type CreateUdfArtifactRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
CreateUdfArtifactRequest is the request struct for api CreateUdfArtifact
func CreateCreateUdfArtifactRequest ¶
func CreateCreateUdfArtifactRequest() (request *CreateUdfArtifactRequest)
CreateCreateUdfArtifactRequest creates a request to invoke CreateUdfArtifact API
type CreateUdfArtifactResponse ¶
type CreateUdfArtifactResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
CreateUdfArtifactResponse is the response struct for api CreateUdfArtifact
func CreateCreateUdfArtifactResponse ¶
func CreateCreateUdfArtifactResponse() (response *CreateUdfArtifactResponse)
CreateCreateUdfArtifactResponse creates a response to parse from CreateUdfArtifact response
type DatabaseExistsRequest ¶
type DatabaseExistsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
DatabaseExistsRequest is the request struct for api DatabaseExists
func CreateDatabaseExistsRequest ¶
func CreateDatabaseExistsRequest() (request *DatabaseExistsRequest)
CreateDatabaseExistsRequest creates a request to invoke DatabaseExists API
type DatabaseExistsResponse ¶
type DatabaseExistsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
DatabaseExistsResponse is the response struct for api DatabaseExists
func CreateDatabaseExistsResponse ¶
func CreateDatabaseExistsResponse() (response *DatabaseExistsResponse)
CreateDatabaseExistsResponse creates a response to parse from DatabaseExists response
type DeleteArtifactRequest ¶
type DeleteArtifactRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Filename string `position:"Query" name:"filename"` Namespace string `position:"Path" name:"namespace"` }
DeleteArtifactRequest is the request struct for api DeleteArtifact
func CreateDeleteArtifactRequest ¶
func CreateDeleteArtifactRequest() (request *DeleteArtifactRequest)
CreateDeleteArtifactRequest creates a request to invoke DeleteArtifact API
type DeleteArtifactResponse ¶
type DeleteArtifactResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteArtifactResponse is the response struct for api DeleteArtifact
func CreateDeleteArtifactResponse ¶
func CreateDeleteArtifactResponse() (response *DeleteArtifactResponse)
CreateDeleteArtifactResponse creates a response to parse from DeleteArtifact response
type DeleteConnectorRequest ¶
type DeleteConnectorRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Name string `position:"Path" name:"name"` Namespace string `position:"Path" name:"namespace"` }
DeleteConnectorRequest is the request struct for api DeleteConnector
func CreateDeleteConnectorRequest ¶
func CreateDeleteConnectorRequest() (request *DeleteConnectorRequest)
CreateDeleteConnectorRequest creates a request to invoke DeleteConnector API
type DeleteConnectorResponse ¶
type DeleteConnectorResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteConnectorResponse is the response struct for api DeleteConnector
func CreateDeleteConnectorResponse ¶
func CreateDeleteConnectorResponse() (response *DeleteConnectorResponse)
CreateDeleteConnectorResponse creates a response to parse from DeleteConnector response
type DeleteDeploymentRequest ¶
type DeleteDeploymentRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
DeleteDeploymentRequest is the request struct for api DeleteDeployment
func CreateDeleteDeploymentRequest ¶
func CreateDeleteDeploymentRequest() (request *DeleteDeploymentRequest)
CreateDeleteDeploymentRequest creates a request to invoke DeleteDeployment API
type DeleteDeploymentResponse ¶
type DeleteDeploymentResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteDeploymentResponse is the response struct for api DeleteDeployment
func CreateDeleteDeploymentResponse ¶
func CreateDeleteDeploymentResponse() (response *DeleteDeploymentResponse)
CreateDeleteDeploymentResponse creates a response to parse from DeleteDeployment response
type DeleteFormatRequest ¶
type DeleteFormatRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Name string `position:"Path" name:"name"` Namespace string `position:"Path" name:"namespace"` }
DeleteFormatRequest is the request struct for api DeleteFormat
func CreateDeleteFormatRequest ¶
func CreateDeleteFormatRequest() (request *DeleteFormatRequest)
CreateDeleteFormatRequest creates a request to invoke DeleteFormat API
type DeleteFormatResponse ¶
type DeleteFormatResponse struct { *responses.BaseResponse RequestId string `json:"requestId" xml:"requestId"` }
DeleteFormatResponse is the response struct for api DeleteFormat
func CreateDeleteFormatResponse ¶
func CreateDeleteFormatResponse() (response *DeleteFormatResponse)
CreateDeleteFormatResponse creates a response to parse from DeleteFormat response
type DeleteMemberRequest ¶
type DeleteMemberRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` Member string `position:"Path" name:"member"` }
DeleteMemberRequest is the request struct for api DeleteMember
func CreateDeleteMemberRequest ¶
func CreateDeleteMemberRequest() (request *DeleteMemberRequest)
CreateDeleteMemberRequest creates a request to invoke DeleteMember API
type DeleteMemberResponse ¶
type DeleteMemberResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteMemberResponse is the response struct for api DeleteMember
func CreateDeleteMemberResponse ¶
func CreateDeleteMemberResponse() (response *DeleteMemberResponse)
CreateDeleteMemberResponse creates a response to parse from DeleteMember response
type DeleteSecretValueRequest ¶
type DeleteSecretValueRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` Name string `position:"Path" name:"name"` }
DeleteSecretValueRequest is the request struct for api DeleteSecretValue
func CreateDeleteSecretValueRequest ¶
func CreateDeleteSecretValueRequest() (request *DeleteSecretValueRequest)
CreateDeleteSecretValueRequest creates a request to invoke DeleteSecretValue API
type DeleteSecretValueResponse ¶
type DeleteSecretValueResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteSecretValueResponse is the response struct for api DeleteSecretValue
func CreateDeleteSecretValueResponse ¶
func CreateDeleteSecretValueResponse() (response *DeleteSecretValueResponse)
CreateDeleteSecretValueResponse creates a response to parse from DeleteSecretValue response
type DeleteUdfArtifactRequest ¶
type DeleteUdfArtifactRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` UdfArtifactName string `position:"Path" name:"udfArtifactName"` }
DeleteUdfArtifactRequest is the request struct for api DeleteUdfArtifact
func CreateDeleteUdfArtifactRequest ¶
func CreateDeleteUdfArtifactRequest() (request *DeleteUdfArtifactRequest)
CreateDeleteUdfArtifactRequest creates a request to invoke DeleteUdfArtifact API
type DeleteUdfArtifactResponse ¶
type DeleteUdfArtifactResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
DeleteUdfArtifactResponse is the response struct for api DeleteUdfArtifact
func CreateDeleteUdfArtifactResponse ¶
func CreateDeleteUdfArtifactResponse() (response *DeleteUdfArtifactResponse)
CreateDeleteUdfArtifactResponse creates a response to parse from DeleteUdfArtifact response
type ExecuteSqlScriptRequest ¶
type ExecuteSqlScriptRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
ExecuteSqlScriptRequest is the request struct for api ExecuteSqlScript
func CreateExecuteSqlScriptRequest ¶
func CreateExecuteSqlScriptRequest() (request *ExecuteSqlScriptRequest)
CreateExecuteSqlScriptRequest creates a request to invoke ExecuteSqlScript API
type ExecuteSqlScriptResponse ¶
type ExecuteSqlScriptResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ExecuteSqlScriptResponse is the response struct for api ExecuteSqlScript
func CreateExecuteSqlScriptResponse ¶
func CreateExecuteSqlScriptResponse() (response *ExecuteSqlScriptResponse)
CreateExecuteSqlScriptResponse creates a response to parse from ExecuteSqlScript response
type ExecuteSqlscriptsStatementsRequest ¶
type ExecuteSqlscriptsStatementsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
ExecuteSqlscriptsStatementsRequest is the request struct for api ExecuteSqlscriptsStatements
func CreateExecuteSqlscriptsStatementsRequest ¶
func CreateExecuteSqlscriptsStatementsRequest() (request *ExecuteSqlscriptsStatementsRequest)
CreateExecuteSqlscriptsStatementsRequest creates a request to invoke ExecuteSqlscriptsStatements API
type ExecuteSqlscriptsStatementsResponse ¶
type ExecuteSqlscriptsStatementsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ExecuteSqlscriptsStatementsResponse is the response struct for api ExecuteSqlscriptsStatements
func CreateExecuteSqlscriptsStatementsResponse ¶
func CreateExecuteSqlscriptsStatementsResponse() (response *ExecuteSqlscriptsStatementsResponse)
CreateExecuteSqlscriptsStatementsResponse creates a response to parse from ExecuteSqlscriptsStatements response
type ForcefullyCreateLockRequest ¶
type ForcefullyCreateLockRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ResourceId string `position:"Query" name:"resourceId"` Namespace string `position:"Path" name:"namespace"` ResourceType string `position:"Query" name:"resourceType"` }
ForcefullyCreateLockRequest is the request struct for api ForcefullyCreateLock
func CreateForcefullyCreateLockRequest ¶
func CreateForcefullyCreateLockRequest() (request *ForcefullyCreateLockRequest)
CreateForcefullyCreateLockRequest creates a request to invoke ForcefullyCreateLock API
type ForcefullyCreateLockResponse ¶
type ForcefullyCreateLockResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ForcefullyCreateLockResponse is the response struct for api ForcefullyCreateLock
func CreateForcefullyCreateLockResponse ¶
func CreateForcefullyCreateLockResponse() (response *ForcefullyCreateLockResponse)
CreateForcefullyCreateLockResponse creates a response to parse from ForcefullyCreateLock response
type FunctionExistsRequest ¶
type FunctionExistsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Function string `position:"Query" name:"function"` Namespace string `position:"Path" name:"namespace"` }
FunctionExistsRequest is the request struct for api FunctionExists
func CreateFunctionExistsRequest ¶
func CreateFunctionExistsRequest() (request *FunctionExistsRequest)
CreateFunctionExistsRequest creates a request to invoke FunctionExists API
type FunctionExistsResponse ¶
type FunctionExistsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
FunctionExistsResponse is the response struct for api FunctionExists
func CreateFunctionExistsResponse ¶
func CreateFunctionExistsResponse() (response *FunctionExistsResponse)
CreateFunctionExistsResponse creates a response to parse from FunctionExists response
type GenerateResourcePlanRequest ¶
type GenerateResourcePlanRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
GenerateResourcePlanRequest is the request struct for api GenerateResourcePlan
func CreateGenerateResourcePlanRequest ¶
func CreateGenerateResourcePlanRequest() (request *GenerateResourcePlanRequest)
CreateGenerateResourcePlanRequest creates a request to invoke GenerateResourcePlan API
type GenerateResourcePlanResponse ¶
type GenerateResourcePlanResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GenerateResourcePlanResponse is the response struct for api GenerateResourcePlan
func CreateGenerateResourcePlanResponse ¶
func CreateGenerateResourcePlanResponse() (response *GenerateResourcePlanResponse)
CreateGenerateResourcePlanResponse creates a response to parse from GenerateResourcePlan response
type GetArtifactMetadataRequest ¶
type GetArtifactMetadataRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Filename string `position:"Query" name:"filename"` Namespace string `position:"Path" name:"namespace"` }
GetArtifactMetadataRequest is the request struct for api GetArtifactMetadata
func CreateGetArtifactMetadataRequest ¶
func CreateGetArtifactMetadataRequest() (request *GetArtifactMetadataRequest)
CreateGetArtifactMetadataRequest creates a request to invoke GetArtifactMetadata API
type GetArtifactMetadataResponse ¶
type GetArtifactMetadataResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
GetArtifactMetadataResponse is the response struct for api GetArtifactMetadata
func CreateGetArtifactMetadataResponse ¶
func CreateGetArtifactMetadataResponse() (response *GetArtifactMetadataResponse)
CreateGetArtifactMetadataResponse creates a response to parse from GetArtifactMetadata response
type GetCatalogRequest ¶
type GetCatalogRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
GetCatalogRequest is the request struct for api GetCatalog
func CreateGetCatalogRequest ¶
func CreateGetCatalogRequest() (request *GetCatalogRequest)
CreateGetCatalogRequest creates a request to invoke GetCatalog API
type GetCatalogResponse ¶
type GetCatalogResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetCatalogResponse is the response struct for api GetCatalog
func CreateGetCatalogResponse ¶
func CreateGetCatalogResponse() (response *GetCatalogResponse)
CreateGetCatalogResponse creates a response to parse from GetCatalog response
type GetDatabaseRequest ¶
type GetDatabaseRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
GetDatabaseRequest is the request struct for api GetDatabase
func CreateGetDatabaseRequest ¶
func CreateGetDatabaseRequest() (request *GetDatabaseRequest)
CreateGetDatabaseRequest creates a request to invoke GetDatabase API
type GetDatabaseResponse ¶
type GetDatabaseResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetDatabaseResponse is the response struct for api GetDatabase
func CreateGetDatabaseResponse ¶
func CreateGetDatabaseResponse() (response *GetDatabaseResponse)
CreateGetDatabaseResponse creates a response to parse from GetDatabase response
type GetDefaultDatabaseRequest ¶
type GetDefaultDatabaseRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
GetDefaultDatabaseRequest is the request struct for api GetDefaultDatabase
func CreateGetDefaultDatabaseRequest ¶
func CreateGetDefaultDatabaseRequest() (request *GetDefaultDatabaseRequest)
CreateGetDefaultDatabaseRequest creates a request to invoke GetDefaultDatabase API
type GetDefaultDatabaseResponse ¶
type GetDefaultDatabaseResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetDefaultDatabaseResponse is the response struct for api GetDefaultDatabase
func CreateGetDefaultDatabaseResponse ¶
func CreateGetDefaultDatabaseResponse() (response *GetDefaultDatabaseResponse)
CreateGetDefaultDatabaseResponse creates a response to parse from GetDefaultDatabase response
type GetDeploymentDefaultsRequest ¶
type GetDeploymentDefaultsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
GetDeploymentDefaultsRequest is the request struct for api GetDeploymentDefaults
func CreateGetDeploymentDefaultsRequest ¶
func CreateGetDeploymentDefaultsRequest() (request *GetDeploymentDefaultsRequest)
CreateGetDeploymentDefaultsRequest creates a request to invoke GetDeploymentDefaults API
type GetDeploymentDefaultsResponse ¶
type GetDeploymentDefaultsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
GetDeploymentDefaultsResponse is the response struct for api GetDeploymentDefaults
func CreateGetDeploymentDefaultsResponse ¶
func CreateGetDeploymentDefaultsResponse() (response *GetDeploymentDefaultsResponse)
CreateGetDeploymentDefaultsResponse creates a response to parse from GetDeploymentDefaults response
type GetDeploymentRequest ¶
type GetDeploymentRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
GetDeploymentRequest is the request struct for api GetDeployment
func CreateGetDeploymentRequest ¶
func CreateGetDeploymentRequest() (request *GetDeploymentRequest)
CreateGetDeploymentRequest creates a request to invoke GetDeployment API
type GetDeploymentResponse ¶
type GetDeploymentResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetDeploymentResponse is the response struct for api GetDeployment
func CreateGetDeploymentResponse ¶
func CreateGetDeploymentResponse() (response *GetDeploymentResponse)
CreateGetDeploymentResponse creates a response to parse from GetDeployment response
type GetFunctionRequest ¶
type GetFunctionRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Function string `position:"Query" name:"function"` Namespace string `position:"Path" name:"namespace"` }
GetFunctionRequest is the request struct for api GetFunction
func CreateGetFunctionRequest ¶
func CreateGetFunctionRequest() (request *GetFunctionRequest)
CreateGetFunctionRequest creates a request to invoke GetFunction API
type GetFunctionResponse ¶
type GetFunctionResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetFunctionResponse is the response struct for api GetFunction
func CreateGetFunctionResponse ¶
func CreateGetFunctionResponse() (response *GetFunctionResponse)
CreateGetFunctionResponse creates a response to parse from GetFunction response
type GetGlobalDeploymentDefaultsRequest ¶
type GetGlobalDeploymentDefaultsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Header" name:"namespace"` }
GetGlobalDeploymentDefaultsRequest is the request struct for api GetGlobalDeploymentDefaults
func CreateGetGlobalDeploymentDefaultsRequest ¶
func CreateGetGlobalDeploymentDefaultsRequest() (request *GetGlobalDeploymentDefaultsRequest)
CreateGetGlobalDeploymentDefaultsRequest creates a request to invoke GetGlobalDeploymentDefaults API
type GetGlobalDeploymentDefaultsResponse ¶
type GetGlobalDeploymentDefaultsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
GetGlobalDeploymentDefaultsResponse is the response struct for api GetGlobalDeploymentDefaults
func CreateGetGlobalDeploymentDefaultsResponse ¶
func CreateGetGlobalDeploymentDefaultsResponse() (response *GetGlobalDeploymentDefaultsResponse)
CreateGetGlobalDeploymentDefaultsResponse creates a response to parse from GetGlobalDeploymentDefaults response
type GetResourcePlanRequest ¶
type GetResourcePlanRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
GetResourcePlanRequest is the request struct for api GetResourcePlan
func CreateGetResourcePlanRequest ¶
func CreateGetResourcePlanRequest() (request *GetResourcePlanRequest)
CreateGetResourcePlanRequest creates a request to invoke GetResourcePlan API
type GetResourcePlanResponse ¶
type GetResourcePlanResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetResourcePlanResponse is the response struct for api GetResourcePlan
func CreateGetResourcePlanResponse ¶
func CreateGetResourcePlanResponse() (response *GetResourcePlanResponse)
CreateGetResourcePlanResponse creates a response to parse from GetResourcePlan response
type GetTableRequest ¶
type GetTableRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` Table string `position:"Query" name:"table"` }
GetTableRequest is the request struct for api GetTable
func CreateGetTableRequest ¶
func CreateGetTableRequest() (request *GetTableRequest)
CreateGetTableRequest creates a request to invoke GetTable API
type GetTableResponse ¶
type GetTableResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetTableResponse is the response struct for api GetTable
func CreateGetTableResponse ¶
func CreateGetTableResponse() (response *GetTableResponse)
CreateGetTableResponse creates a response to parse from GetTable response
type GetUdfArtifactRequest ¶
type GetUdfArtifactRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` RequireFunctionNames requests.Boolean `position:"Query" name:"requireFunctionNames"` Namespace string `position:"Path" name:"namespace"` UdfArtifactName string `position:"Path" name:"udfArtifactName"` }
GetUdfArtifactRequest is the request struct for api GetUdfArtifact
func CreateGetUdfArtifactRequest ¶
func CreateGetUdfArtifactRequest() (request *GetUdfArtifactRequest)
CreateGetUdfArtifactRequest creates a request to invoke GetUdfArtifact API
type GetUdfArtifactResponse ¶
type GetUdfArtifactResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
GetUdfArtifactResponse is the response struct for api GetUdfArtifact
func CreateGetUdfArtifactResponse ¶
func CreateGetUdfArtifactResponse() (response *GetUdfArtifactResponse)
CreateGetUdfArtifactResponse creates a response to parse from GetUdfArtifact response
type ListArtifactsRequest ¶
type ListArtifactsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListArtifactsRequest is the request struct for api ListArtifacts
func CreateListArtifactsRequest ¶
func CreateListArtifactsRequest() (request *ListArtifactsRequest)
CreateListArtifactsRequest creates a request to invoke ListArtifacts API
type ListArtifactsResponse ¶
type ListArtifactsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ListArtifactsResponse is the response struct for api ListArtifacts
func CreateListArtifactsResponse ¶
func CreateListArtifactsResponse() (response *ListArtifactsResponse)
CreateListArtifactsResponse creates a response to parse from ListArtifacts response
type ListCatalogsRequest ¶
type ListCatalogsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListCatalogsRequest is the request struct for api ListCatalogs
func CreateListCatalogsRequest ¶
func CreateListCatalogsRequest() (request *ListCatalogsRequest)
CreateListCatalogsRequest creates a request to invoke ListCatalogs API
type ListCatalogsResponse ¶
type ListCatalogsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListCatalogsResponse is the response struct for api ListCatalogs
func CreateListCatalogsResponse ¶
func CreateListCatalogsResponse() (response *ListCatalogsResponse)
CreateListCatalogsResponse creates a response to parse from ListCatalogs response
type ListConnectorsRequest ¶
type ListConnectorsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListConnectorsRequest is the request struct for api ListConnectors
func CreateListConnectorsRequest ¶
func CreateListConnectorsRequest() (request *ListConnectorsRequest)
CreateListConnectorsRequest creates a request to invoke ListConnectors API
type ListConnectorsResponse ¶
type ListConnectorsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListConnectorsResponse is the response struct for api ListConnectors
func CreateListConnectorsResponse ¶
func CreateListConnectorsResponse() (response *ListConnectorsResponse)
CreateListConnectorsResponse creates a response to parse from ListConnectors response
type ListDatabasesRequest ¶
type ListDatabasesRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
ListDatabasesRequest is the request struct for api ListDatabases
func CreateListDatabasesRequest ¶
func CreateListDatabasesRequest() (request *ListDatabasesRequest)
CreateListDatabasesRequest creates a request to invoke ListDatabases API
type ListDatabasesResponse ¶
type ListDatabasesResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListDatabasesResponse is the response struct for api ListDatabases
func CreateListDatabasesResponse ¶
func CreateListDatabasesResponse() (response *ListDatabasesResponse)
CreateListDatabasesResponse creates a response to parse from ListDatabases response
type ListDeploymentTargetsRequest ¶
type ListDeploymentTargetsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListDeploymentTargetsRequest is the request struct for api ListDeploymentTargets
func CreateListDeploymentTargetsRequest ¶
func CreateListDeploymentTargetsRequest() (request *ListDeploymentTargetsRequest)
CreateListDeploymentTargetsRequest creates a request to invoke ListDeploymentTargets API
type ListDeploymentTargetsResponse ¶
type ListDeploymentTargetsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ListDeploymentTargetsResponse is the response struct for api ListDeploymentTargets
func CreateListDeploymentTargetsResponse ¶
func CreateListDeploymentTargetsResponse() (response *ListDeploymentTargetsResponse)
CreateListDeploymentTargetsResponse creates a response to parse from ListDeploymentTargets response
type ListDeploymentsRequest ¶
type ListDeploymentsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Creator string `position:"Query" name:"creator"` Modifier string `position:"Query" name:"modifier"` Priority string `position:"Query" name:"priority"` BatchMode requests.Boolean `position:"Query" name:"batchMode"` SortName string `position:"Query" name:"sortName"` DeploymentId string `position:"Query" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` PageSize string `position:"Query" name:"pageSize"` Name string `position:"Query" name:"name"` PageIndex string `position:"Query" name:"pageIndex"` SortOrder string `position:"Query" name:"sortOrder"` State string `position:"Query" name:"state"` Status string `position:"Query" name:"status"` }
ListDeploymentsRequest is the request struct for api ListDeployments
func CreateListDeploymentsRequest ¶
func CreateListDeploymentsRequest() (request *ListDeploymentsRequest)
CreateListDeploymentsRequest creates a request to invoke ListDeployments API
type ListDeploymentsResponse ¶
type ListDeploymentsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListDeploymentsResponse is the response struct for api ListDeployments
func CreateListDeploymentsResponse ¶
func CreateListDeploymentsResponse() (response *ListDeploymentsResponse)
CreateListDeploymentsResponse creates a response to parse from ListDeployments response
type ListFlinkVersionsRequest ¶
type ListFlinkVersionsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` }
ListFlinkVersionsRequest is the request struct for api ListFlinkVersions
func CreateListFlinkVersionsRequest ¶
func CreateListFlinkVersionsRequest() (request *ListFlinkVersionsRequest)
CreateListFlinkVersionsRequest creates a request to invoke ListFlinkVersions API
type ListFlinkVersionsResponse ¶
type ListFlinkVersionsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListFlinkVersionsResponse is the response struct for api ListFlinkVersions
func CreateListFlinkVersionsResponse ¶
func CreateListFlinkVersionsResponse() (response *ListFlinkVersionsResponse)
CreateListFlinkVersionsResponse creates a response to parse from ListFlinkVersions response
type ListFormatsRequest ¶
type ListFormatsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListFormatsRequest is the request struct for api ListFormats
func CreateListFormatsRequest ¶
func CreateListFormatsRequest() (request *ListFormatsRequest)
CreateListFormatsRequest creates a request to invoke ListFormats API
type ListFormatsResponse ¶
type ListFormatsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListFormatsResponse is the response struct for api ListFormats
func CreateListFormatsResponse ¶
func CreateListFormatsResponse() (response *ListFormatsResponse)
CreateListFormatsResponse creates a response to parse from ListFormats response
type ListFunctionsRequest ¶
type ListFunctionsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
ListFunctionsRequest is the request struct for api ListFunctions
func CreateListFunctionsRequest ¶
func CreateListFunctionsRequest() (request *ListFunctionsRequest)
CreateListFunctionsRequest creates a request to invoke ListFunctions API
type ListFunctionsResponse ¶
type ListFunctionsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListFunctionsResponse is the response struct for api ListFunctions
func CreateListFunctionsResponse ¶
func CreateListFunctionsResponse() (response *ListFunctionsResponse)
CreateListFunctionsResponse creates a response to parse from ListFunctions response
type ListJobsRequest ¶
type ListJobsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Query" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
ListJobsRequest is the request struct for api ListJobs
func CreateListJobsRequest ¶
func CreateListJobsRequest() (request *ListJobsRequest)
CreateListJobsRequest creates a request to invoke ListJobs API
type ListJobsResponse ¶
type ListJobsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListJobsResponse is the response struct for api ListJobs
func CreateListJobsResponse ¶
func CreateListJobsResponse() (response *ListJobsResponse)
CreateListJobsResponse creates a response to parse from ListJobs response
type ListNamespacesRequest ¶
type ListNamespacesRequest struct {
*requests.RoaRequest
}
ListNamespacesRequest is the request struct for api ListNamespaces
func CreateListNamespacesRequest ¶
func CreateListNamespacesRequest() (request *ListNamespacesRequest)
CreateListNamespacesRequest creates a request to invoke ListNamespaces API
type ListNamespacesResponse ¶
type ListNamespacesResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ListNamespacesResponse is the response struct for api ListNamespaces
func CreateListNamespacesResponse ¶
func CreateListNamespacesResponse() (response *ListNamespacesResponse)
CreateListNamespacesResponse creates a response to parse from ListNamespaces response
type ListSavepointsRequest ¶
type ListSavepointsRequest struct { *requests.RoaRequest JobId string `position:"Query" name:"jobId"` Workspace string `position:"Path" name:"workspace"` DeploymentId string `position:"Query" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
ListSavepointsRequest is the request struct for api ListSavepoints
func CreateListSavepointsRequest ¶
func CreateListSavepointsRequest() (request *ListSavepointsRequest)
CreateListSavepointsRequest creates a request to invoke ListSavepoints API
type ListSavepointsResponse ¶
type ListSavepointsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListSavepointsResponse is the response struct for api ListSavepoints
func CreateListSavepointsResponse ¶
func CreateListSavepointsResponse() (response *ListSavepointsResponse)
CreateListSavepointsResponse creates a response to parse from ListSavepoints response
type ListSecretValuesRequest ¶
type ListSecretValuesRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListSecretValuesRequest is the request struct for api ListSecretValues
func CreateListSecretValuesRequest ¶
func CreateListSecretValuesRequest() (request *ListSecretValuesRequest)
CreateListSecretValuesRequest creates a request to invoke ListSecretValues API
type ListSecretValuesResponse ¶
type ListSecretValuesResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ListSecretValuesResponse is the response struct for api ListSecretValues
func CreateListSecretValuesResponse ¶
func CreateListSecretValuesResponse() (response *ListSecretValuesResponse)
CreateListSecretValuesResponse creates a response to parse from ListSecretValues response
type ListSessionClustersRequest ¶
type ListSessionClustersRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Namespace string `position:"Path" name:"namespace"` }
ListSessionClustersRequest is the request struct for api ListSessionClusters
func CreateListSessionClustersRequest ¶
func CreateListSessionClustersRequest() (request *ListSessionClustersRequest)
CreateListSessionClustersRequest creates a request to invoke ListSessionClusters API
type ListSessionClustersResponse ¶
type ListSessionClustersResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListSessionClustersResponse is the response struct for api ListSessionClusters
func CreateListSessionClustersResponse ¶
func CreateListSessionClustersResponse() (response *ListSessionClustersResponse)
CreateListSessionClustersResponse creates a response to parse from ListSessionClusters response
type ListTablesRequest ¶
type ListTablesRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` }
ListTablesRequest is the request struct for api ListTables
func CreateListTablesRequest ¶
func CreateListTablesRequest() (request *ListTablesRequest)
CreateListTablesRequest creates a request to invoke ListTables API
type ListTablesResponse ¶
type ListTablesResponse struct { *responses.BaseResponse Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ListTablesResponse is the response struct for api ListTables
func CreateListTablesResponse ¶
func CreateListTablesResponse() (response *ListTablesResponse)
CreateListTablesResponse creates a response to parse from ListTables response
type ParseConnectorRequest ¶
type ParseConnectorRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
ParseConnectorRequest is the request struct for api ParseConnector
func CreateParseConnectorRequest ¶
func CreateParseConnectorRequest() (request *ParseConnectorRequest)
CreateParseConnectorRequest creates a request to invoke ParseConnector API
type ParseConnectorResponse ¶
type ParseConnectorResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ParseConnectorResponse is the response struct for api ParseConnector
func CreateParseConnectorResponse ¶
func CreateParseConnectorResponse() (response *ParseConnectorResponse)
CreateParseConnectorResponse creates a response to parse from ParseConnector response
type ParseFormatRequest ¶
type ParseFormatRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
ParseFormatRequest is the request struct for api ParseFormat
func CreateParseFormatRequest ¶
func CreateParseFormatRequest() (request *ParseFormatRequest)
CreateParseFormatRequest creates a request to invoke ParseFormat API
type ParseFormatResponse ¶
type ParseFormatResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
ParseFormatResponse is the response struct for api ParseFormat
func CreateParseFormatResponse ¶
func CreateParseFormatResponse() (response *ParseFormatResponse)
CreateParseFormatResponse creates a response to parse from ParseFormat response
type ReplaceDeploymentRequest ¶
type ReplaceDeploymentRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
ReplaceDeploymentRequest is the request struct for api ReplaceDeployment
func CreateReplaceDeploymentRequest ¶
func CreateReplaceDeploymentRequest() (request *ReplaceDeploymentRequest)
CreateReplaceDeploymentRequest creates a request to invoke ReplaceDeployment API
type ReplaceDeploymentResponse ¶
type ReplaceDeploymentResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data int `json:"data" xml:"data"` }
ReplaceDeploymentResponse is the response struct for api ReplaceDeployment
func CreateReplaceDeploymentResponse ¶
func CreateReplaceDeploymentResponse() (response *ReplaceDeploymentResponse)
CreateReplaceDeploymentResponse creates a response to parse from ReplaceDeployment response
type SetDeploymentResourceModeRequest ¶
type SetDeploymentResourceModeRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
SetDeploymentResourceModeRequest is the request struct for api SetDeploymentResourceMode
func CreateSetDeploymentResourceModeRequest ¶
func CreateSetDeploymentResourceModeRequest() (request *SetDeploymentResourceModeRequest)
CreateSetDeploymentResourceModeRequest creates a request to invoke SetDeploymentResourceMode API
type SetDeploymentResourceModeResponse ¶
type SetDeploymentResourceModeResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
SetDeploymentResourceModeResponse is the response struct for api SetDeploymentResourceMode
func CreateSetDeploymentResourceModeResponse ¶
func CreateSetDeploymentResourceModeResponse() (response *SetDeploymentResourceModeResponse)
CreateSetDeploymentResourceModeResponse creates a response to parse from SetDeploymentResourceMode response
type TableExistsRequest ¶
type TableExistsRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` Database string `position:"Query" name:"database"` Cat string `position:"Path" name:"cat"` Namespace string `position:"Path" name:"namespace"` Table string `position:"Query" name:"table"` }
TableExistsRequest is the request struct for api TableExists
func CreateTableExistsRequest ¶
func CreateTableExistsRequest() (request *TableExistsRequest)
CreateTableExistsRequest creates a request to invoke TableExists API
type TableExistsResponse ¶
type TableExistsResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
TableExistsResponse is the response struct for api TableExists
func CreateTableExistsResponse ¶
func CreateTableExistsResponse() (response *TableExistsResponse)
CreateTableExistsResponse creates a response to parse from TableExists response
type UpdateConnectorRequest ¶
type UpdateConnectorRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Name string `position:"Path" name:"name"` Namespace string `position:"Path" name:"namespace"` }
UpdateConnectorRequest is the request struct for api UpdateConnector
func CreateUpdateConnectorRequest ¶
func CreateUpdateConnectorRequest() (request *UpdateConnectorRequest)
CreateUpdateConnectorRequest creates a request to invoke UpdateConnector API
type UpdateConnectorResponse ¶
type UpdateConnectorResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
UpdateConnectorResponse is the response struct for api UpdateConnector
func CreateUpdateConnectorResponse ¶
func CreateUpdateConnectorResponse() (response *UpdateConnectorResponse)
CreateUpdateConnectorResponse creates a response to parse from UpdateConnector response
type UpdateDeploymentDesiredStateRequest ¶
type UpdateDeploymentDesiredStateRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
UpdateDeploymentDesiredStateRequest is the request struct for api UpdateDeploymentDesiredState
func CreateUpdateDeploymentDesiredStateRequest ¶
func CreateUpdateDeploymentDesiredStateRequest() (request *UpdateDeploymentDesiredStateRequest)
CreateUpdateDeploymentDesiredStateRequest creates a request to invoke UpdateDeploymentDesiredState API
type UpdateDeploymentDesiredStateResponse ¶
type UpdateDeploymentDesiredStateResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
UpdateDeploymentDesiredStateResponse is the response struct for api UpdateDeploymentDesiredState
func CreateUpdateDeploymentDesiredStateResponse ¶
func CreateUpdateDeploymentDesiredStateResponse() (response *UpdateDeploymentDesiredStateResponse)
CreateUpdateDeploymentDesiredStateResponse creates a response to parse from UpdateDeploymentDesiredState response
type UpdateDeploymentRequest ¶
type UpdateDeploymentRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` DeploymentId string `position:"Path" name:"deploymentId"` Namespace string `position:"Path" name:"namespace"` }
UpdateDeploymentRequest is the request struct for api UpdateDeployment
func CreateUpdateDeploymentRequest ¶
func CreateUpdateDeploymentRequest() (request *UpdateDeploymentRequest)
CreateUpdateDeploymentRequest creates a request to invoke UpdateDeployment API
type UpdateDeploymentResponse ¶
type UpdateDeploymentResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data int `json:"data" xml:"data"` }
UpdateDeploymentResponse is the response struct for api UpdateDeployment
func CreateUpdateDeploymentResponse ¶
func CreateUpdateDeploymentResponse() (response *UpdateDeploymentResponse)
CreateUpdateDeploymentResponse creates a response to parse from UpdateDeployment response
type UpdateFormatRequest ¶
type UpdateFormatRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Name string `position:"Path" name:"name"` Namespace string `position:"Path" name:"namespace"` }
UpdateFormatRequest is the request struct for api UpdateFormat
func CreateUpdateFormatRequest ¶
func CreateUpdateFormatRequest() (request *UpdateFormatRequest)
CreateUpdateFormatRequest creates a request to invoke UpdateFormat API
type UpdateFormatResponse ¶
type UpdateFormatResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
UpdateFormatResponse is the response struct for api UpdateFormat
func CreateUpdateFormatResponse ¶
func CreateUpdateFormatResponse() (response *UpdateFormatResponse)
CreateUpdateFormatResponse creates a response to parse from UpdateFormat response
type UpdateMemberRequest ¶
type UpdateMemberRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
UpdateMemberRequest is the request struct for api UpdateMember
func CreateUpdateMemberRequest ¶
func CreateUpdateMemberRequest() (request *UpdateMemberRequest)
CreateUpdateMemberRequest creates a request to invoke UpdateMember API
type UpdateMemberResponse ¶
type UpdateMemberResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
UpdateMemberResponse is the response struct for api UpdateMember
func CreateUpdateMemberResponse ¶
func CreateUpdateMemberResponse() (response *UpdateMemberResponse)
CreateUpdateMemberResponse creates a response to parse from UpdateMember response
type UpdateUdfArtifactRequest ¶
type UpdateUdfArtifactRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` UdfArtifactName string `position:"Path" name:"udfArtifactName"` }
UpdateUdfArtifactRequest is the request struct for api UpdateUdfArtifact
func CreateUpdateUdfArtifactRequest ¶
func CreateUpdateUdfArtifactRequest() (request *UpdateUdfArtifactRequest)
CreateUpdateUdfArtifactRequest creates a request to invoke UpdateUdfArtifact API
type UpdateUdfArtifactResponse ¶
type UpdateUdfArtifactResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` Data string `json:"data" xml:"data"` RequestId string `json:"requestId" xml:"requestId"` }
UpdateUdfArtifactResponse is the response struct for api UpdateUdfArtifact
func CreateUpdateUdfArtifactResponse ¶
func CreateUpdateUdfArtifactResponse() (response *UpdateUdfArtifactResponse)
CreateUpdateUdfArtifactResponse creates a response to parse from UpdateUdfArtifact response
type ValidateSqlScriptRequest ¶
type ValidateSqlScriptRequest struct { *requests.RoaRequest Workspace string `position:"Path" name:"workspace"` ParamsJson string `position:"Body" name:"paramsJson"` Namespace string `position:"Path" name:"namespace"` }
ValidateSqlScriptRequest is the request struct for api ValidateSqlScript
func CreateValidateSqlScriptRequest ¶
func CreateValidateSqlScriptRequest() (request *ValidateSqlScriptRequest)
CreateValidateSqlScriptRequest creates a request to invoke ValidateSqlScript API
type ValidateSqlScriptResponse ¶
type ValidateSqlScriptResponse struct { *responses.BaseResponse Success bool `json:"success" xml:"success"` RequestId string `json:"requestId" xml:"requestId"` Data string `json:"data" xml:"data"` }
ValidateSqlScriptResponse is the response struct for api ValidateSqlScript
func CreateValidateSqlScriptResponse ¶
func CreateValidateSqlScriptResponse() (response *ValidateSqlScriptResponse)
CreateValidateSqlScriptResponse creates a response to parse from ValidateSqlScript response
Source Files ¶
- client.go
- create_connector.go
- create_deployment.go
- create_format.go
- create_member.go
- create_savepoint.go
- create_secret_value.go
- create_udf_artifact.go
- database_exists.go
- delete_artifact.go
- delete_connector.go
- delete_deployment.go
- delete_format.go
- delete_member.go
- delete_secret_value.go
- delete_udf_artifact.go
- endpoint.go
- execute_sql_script.go
- execute_sqlscripts_statements.go
- forcefully_create_lock.go
- function_exists.go
- generate_resource_plan.go
- get_artifact_metadata.go
- get_catalog.go
- get_database.go
- get_default_database.go
- get_deployment.go
- get_deployment_defaults.go
- get_function.go
- get_global_deployment_defaults.go
- get_resource_plan.go
- get_table.go
- get_udf_artifact.go
- list_artifacts.go
- list_catalogs.go
- list_connectors.go
- list_databases.go
- list_deployment_targets.go
- list_deployments.go
- list_flink_versions.go
- list_formats.go
- list_functions.go
- list_jobs.go
- list_namespaces.go
- list_savepoints.go
- list_secret_values.go
- list_session_clusters.go
- list_tables.go
- parse_connector.go
- parse_format.go
- replace_deployment.go
- set_deployment_resource_mode.go
- table_exists.go
- update_connector.go
- update_deployment.go
- update_deployment_desired_state.go
- update_format.go
- update_member.go
- update_udf_artifact.go
- validate_sql_script.go