glue

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activities

type Activities struct {
	// contains filtered or unexported fields
}

func NewActivities

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities

func NewActivitiesWithSessionFactory

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities

func (*Activities) BatchCreatePartition

func (*Activities) BatchDeleteConnection

func (*Activities) BatchDeletePartition

func (*Activities) BatchDeleteTable

func (*Activities) BatchDeleteTableVersion

func (*Activities) BatchGetCrawlers

func (*Activities) BatchGetDevEndpoints

func (*Activities) BatchGetJobs

func (a *Activities) BatchGetJobs(ctx context.Context, input *glue.BatchGetJobsInput) (*glue.BatchGetJobsOutput, error)

func (*Activities) BatchGetPartition

func (*Activities) BatchGetTriggers

func (*Activities) BatchGetWorkflows

func (*Activities) BatchStopJobRun

func (a *Activities) BatchStopJobRun(ctx context.Context, input *glue.BatchStopJobRunInput) (*glue.BatchStopJobRunOutput, error)

func (*Activities) BatchUpdatePartition

func (*Activities) CancelMLTaskRun

func (a *Activities) CancelMLTaskRun(ctx context.Context, input *glue.CancelMLTaskRunInput) (*glue.CancelMLTaskRunOutput, error)

func (*Activities) CreateClassifier

func (*Activities) CreateConnection

func (*Activities) CreateCrawler

func (a *Activities) CreateCrawler(ctx context.Context, input *glue.CreateCrawlerInput) (*glue.CreateCrawlerOutput, error)

func (*Activities) CreateDatabase

func (a *Activities) CreateDatabase(ctx context.Context, input *glue.CreateDatabaseInput) (*glue.CreateDatabaseOutput, error)

func (*Activities) CreateDevEndpoint

func (*Activities) CreateJob

func (a *Activities) CreateJob(ctx context.Context, input *glue.CreateJobInput) (*glue.CreateJobOutput, error)

func (*Activities) CreateMLTransform

func (*Activities) CreatePartition

func (a *Activities) CreatePartition(ctx context.Context, input *glue.CreatePartitionInput) (*glue.CreatePartitionOutput, error)

func (*Activities) CreatePartitionIndex

func (*Activities) CreateRegistry

func (a *Activities) CreateRegistry(ctx context.Context, input *glue.CreateRegistryInput) (*glue.CreateRegistryOutput, error)

func (*Activities) CreateSchema

func (a *Activities) CreateSchema(ctx context.Context, input *glue.CreateSchemaInput) (*glue.CreateSchemaOutput, error)

func (*Activities) CreateScript

func (a *Activities) CreateScript(ctx context.Context, input *glue.CreateScriptInput) (*glue.CreateScriptOutput, error)

func (*Activities) CreateTable

func (a *Activities) CreateTable(ctx context.Context, input *glue.CreateTableInput) (*glue.CreateTableOutput, error)

func (*Activities) CreateTrigger

func (a *Activities) CreateTrigger(ctx context.Context, input *glue.CreateTriggerInput) (*glue.CreateTriggerOutput, error)

func (*Activities) CreateWorkflow

func (a *Activities) CreateWorkflow(ctx context.Context, input *glue.CreateWorkflowInput) (*glue.CreateWorkflowOutput, error)

func (*Activities) DeleteClassifier

func (*Activities) DeleteConnection

func (*Activities) DeleteCrawler

func (a *Activities) DeleteCrawler(ctx context.Context, input *glue.DeleteCrawlerInput) (*glue.DeleteCrawlerOutput, error)

func (*Activities) DeleteDatabase

func (a *Activities) DeleteDatabase(ctx context.Context, input *glue.DeleteDatabaseInput) (*glue.DeleteDatabaseOutput, error)

func (*Activities) DeleteDevEndpoint

func (*Activities) DeleteJob

func (a *Activities) DeleteJob(ctx context.Context, input *glue.DeleteJobInput) (*glue.DeleteJobOutput, error)

func (*Activities) DeleteMLTransform

func (*Activities) DeletePartition

func (a *Activities) DeletePartition(ctx context.Context, input *glue.DeletePartitionInput) (*glue.DeletePartitionOutput, error)

func (*Activities) DeletePartitionIndex

func (*Activities) DeleteRegistry

func (a *Activities) DeleteRegistry(ctx context.Context, input *glue.DeleteRegistryInput) (*glue.DeleteRegistryOutput, error)

func (*Activities) DeleteResourcePolicy

func (*Activities) DeleteSchema

func (a *Activities) DeleteSchema(ctx context.Context, input *glue.DeleteSchemaInput) (*glue.DeleteSchemaOutput, error)

func (*Activities) DeleteSchemaVersions

func (*Activities) DeleteTable

func (a *Activities) DeleteTable(ctx context.Context, input *glue.DeleteTableInput) (*glue.DeleteTableOutput, error)

func (*Activities) DeleteTableVersion

func (*Activities) DeleteTrigger

func (a *Activities) DeleteTrigger(ctx context.Context, input *glue.DeleteTriggerInput) (*glue.DeleteTriggerOutput, error)

func (*Activities) DeleteWorkflow

func (a *Activities) DeleteWorkflow(ctx context.Context, input *glue.DeleteWorkflowInput) (*glue.DeleteWorkflowOutput, error)

func (*Activities) GetCatalogImportStatus

func (*Activities) GetClassifier

func (a *Activities) GetClassifier(ctx context.Context, input *glue.GetClassifierInput) (*glue.GetClassifierOutput, error)

func (*Activities) GetClassifiers

func (a *Activities) GetClassifiers(ctx context.Context, input *glue.GetClassifiersInput) (*glue.GetClassifiersOutput, error)

func (*Activities) GetConnection

func (a *Activities) GetConnection(ctx context.Context, input *glue.GetConnectionInput) (*glue.GetConnectionOutput, error)

func (*Activities) GetConnections

func (a *Activities) GetConnections(ctx context.Context, input *glue.GetConnectionsInput) (*glue.GetConnectionsOutput, error)

func (*Activities) GetCrawler

func (a *Activities) GetCrawler(ctx context.Context, input *glue.GetCrawlerInput) (*glue.GetCrawlerOutput, error)

func (*Activities) GetCrawlerMetrics

func (*Activities) GetCrawlers

func (a *Activities) GetCrawlers(ctx context.Context, input *glue.GetCrawlersInput) (*glue.GetCrawlersOutput, error)

func (*Activities) GetDatabase

func (a *Activities) GetDatabase(ctx context.Context, input *glue.GetDatabaseInput) (*glue.GetDatabaseOutput, error)

func (*Activities) GetDatabases

func (a *Activities) GetDatabases(ctx context.Context, input *glue.GetDatabasesInput) (*glue.GetDatabasesOutput, error)

func (*Activities) GetDataflowGraph

func (*Activities) GetDevEndpoint

func (a *Activities) GetDevEndpoint(ctx context.Context, input *glue.GetDevEndpointInput) (*glue.GetDevEndpointOutput, error)

func (*Activities) GetDevEndpoints

func (a *Activities) GetDevEndpoints(ctx context.Context, input *glue.GetDevEndpointsInput) (*glue.GetDevEndpointsOutput, error)

func (*Activities) GetJob

func (a *Activities) GetJob(ctx context.Context, input *glue.GetJobInput) (*glue.GetJobOutput, error)

func (*Activities) GetJobBookmark

func (a *Activities) GetJobBookmark(ctx context.Context, input *glue.GetJobBookmarkInput) (*glue.GetJobBookmarkOutput, error)

func (*Activities) GetJobRun

func (a *Activities) GetJobRun(ctx context.Context, input *glue.GetJobRunInput) (*glue.GetJobRunOutput, error)

func (*Activities) GetJobRuns

func (a *Activities) GetJobRuns(ctx context.Context, input *glue.GetJobRunsInput) (*glue.GetJobRunsOutput, error)

func (*Activities) GetJobs

func (a *Activities) GetJobs(ctx context.Context, input *glue.GetJobsInput) (*glue.GetJobsOutput, error)

func (*Activities) GetMLTaskRun

func (a *Activities) GetMLTaskRun(ctx context.Context, input *glue.GetMLTaskRunInput) (*glue.GetMLTaskRunOutput, error)

func (*Activities) GetMLTaskRuns

func (a *Activities) GetMLTaskRuns(ctx context.Context, input *glue.GetMLTaskRunsInput) (*glue.GetMLTaskRunsOutput, error)

func (*Activities) GetMLTransform

func (a *Activities) GetMLTransform(ctx context.Context, input *glue.GetMLTransformInput) (*glue.GetMLTransformOutput, error)

func (*Activities) GetMLTransforms

func (a *Activities) GetMLTransforms(ctx context.Context, input *glue.GetMLTransformsInput) (*glue.GetMLTransformsOutput, error)

func (*Activities) GetMapping

func (a *Activities) GetMapping(ctx context.Context, input *glue.GetMappingInput) (*glue.GetMappingOutput, error)

func (*Activities) GetPartition

func (a *Activities) GetPartition(ctx context.Context, input *glue.GetPartitionInput) (*glue.GetPartitionOutput, error)

func (*Activities) GetPartitionIndexes

func (*Activities) GetPartitions

func (a *Activities) GetPartitions(ctx context.Context, input *glue.GetPartitionsInput) (*glue.GetPartitionsOutput, error)

func (*Activities) GetPlan

func (a *Activities) GetPlan(ctx context.Context, input *glue.GetPlanInput) (*glue.GetPlanOutput, error)

func (*Activities) GetRegistry

func (a *Activities) GetRegistry(ctx context.Context, input *glue.GetRegistryInput) (*glue.GetRegistryOutput, error)

func (*Activities) GetResourcePolicies

func (*Activities) GetResourcePolicy

func (*Activities) GetSchema

func (a *Activities) GetSchema(ctx context.Context, input *glue.GetSchemaInput) (*glue.GetSchemaOutput, error)

func (*Activities) GetSchemaByDefinition

func (*Activities) GetSchemaVersion

func (*Activities) GetSchemaVersionsDiff

func (*Activities) GetSecurityConfiguration

func (*Activities) GetTable

func (a *Activities) GetTable(ctx context.Context, input *glue.GetTableInput) (*glue.GetTableOutput, error)

func (*Activities) GetTableVersion

func (a *Activities) GetTableVersion(ctx context.Context, input *glue.GetTableVersionInput) (*glue.GetTableVersionOutput, error)

func (*Activities) GetTableVersions

func (*Activities) GetTables

func (a *Activities) GetTables(ctx context.Context, input *glue.GetTablesInput) (*glue.GetTablesOutput, error)

func (*Activities) GetTags

func (a *Activities) GetTags(ctx context.Context, input *glue.GetTagsInput) (*glue.GetTagsOutput, error)

func (*Activities) GetTrigger

func (a *Activities) GetTrigger(ctx context.Context, input *glue.GetTriggerInput) (*glue.GetTriggerOutput, error)

func (*Activities) GetTriggers

func (a *Activities) GetTriggers(ctx context.Context, input *glue.GetTriggersInput) (*glue.GetTriggersOutput, error)

func (*Activities) GetUserDefinedFunction

func (*Activities) GetUserDefinedFunctions

func (*Activities) GetWorkflow

func (a *Activities) GetWorkflow(ctx context.Context, input *glue.GetWorkflowInput) (*glue.GetWorkflowOutput, error)

func (*Activities) GetWorkflowRun

func (a *Activities) GetWorkflowRun(ctx context.Context, input *glue.GetWorkflowRunInput) (*glue.GetWorkflowRunOutput, error)

func (*Activities) GetWorkflowRunProperties

func (*Activities) GetWorkflowRuns

func (a *Activities) GetWorkflowRuns(ctx context.Context, input *glue.GetWorkflowRunsInput) (*glue.GetWorkflowRunsOutput, error)

func (*Activities) ImportCatalogToGlue

func (*Activities) ListCrawlers

func (a *Activities) ListCrawlers(ctx context.Context, input *glue.ListCrawlersInput) (*glue.ListCrawlersOutput, error)

func (*Activities) ListDevEndpoints

func (*Activities) ListJobs

func (a *Activities) ListJobs(ctx context.Context, input *glue.ListJobsInput) (*glue.ListJobsOutput, error)

func (*Activities) ListMLTransforms

func (*Activities) ListRegistries

func (a *Activities) ListRegistries(ctx context.Context, input *glue.ListRegistriesInput) (*glue.ListRegistriesOutput, error)

func (*Activities) ListSchemaVersions

func (*Activities) ListSchemas

func (a *Activities) ListSchemas(ctx context.Context, input *glue.ListSchemasInput) (*glue.ListSchemasOutput, error)

func (*Activities) ListTriggers

func (a *Activities) ListTriggers(ctx context.Context, input *glue.ListTriggersInput) (*glue.ListTriggersOutput, error)

func (*Activities) ListWorkflows

func (a *Activities) ListWorkflows(ctx context.Context, input *glue.ListWorkflowsInput) (*glue.ListWorkflowsOutput, error)

func (*Activities) PutResourcePolicy

func (*Activities) PutSchemaVersionMetadata

func (*Activities) PutWorkflowRunProperties

func (*Activities) RegisterSchemaVersion

func (*Activities) ResetJobBookmark

func (*Activities) ResumeWorkflowRun

func (*Activities) SearchTables

func (a *Activities) SearchTables(ctx context.Context, input *glue.SearchTablesInput) (*glue.SearchTablesOutput, error)

func (*Activities) StartCrawler

func (a *Activities) StartCrawler(ctx context.Context, input *glue.StartCrawlerInput) (*glue.StartCrawlerOutput, error)

func (*Activities) StartCrawlerSchedule

func (*Activities) StartExportLabelsTaskRun

func (*Activities) StartImportLabelsTaskRun

func (*Activities) StartJobRun

func (a *Activities) StartJobRun(ctx context.Context, input *glue.StartJobRunInput) (*glue.StartJobRunOutput, error)

func (*Activities) StartMLEvaluationTaskRun

func (*Activities) StartTrigger

func (a *Activities) StartTrigger(ctx context.Context, input *glue.StartTriggerInput) (*glue.StartTriggerOutput, error)

func (*Activities) StartWorkflowRun

func (*Activities) StopCrawler

func (a *Activities) StopCrawler(ctx context.Context, input *glue.StopCrawlerInput) (*glue.StopCrawlerOutput, error)

func (*Activities) StopCrawlerSchedule

func (*Activities) StopTrigger

func (a *Activities) StopTrigger(ctx context.Context, input *glue.StopTriggerInput) (*glue.StopTriggerOutput, error)

func (*Activities) StopWorkflowRun

func (a *Activities) StopWorkflowRun(ctx context.Context, input *glue.StopWorkflowRunInput) (*glue.StopWorkflowRunOutput, error)

func (*Activities) TagResource

func (a *Activities) TagResource(ctx context.Context, input *glue.TagResourceInput) (*glue.TagResourceOutput, error)

func (*Activities) UntagResource

func (a *Activities) UntagResource(ctx context.Context, input *glue.UntagResourceInput) (*glue.UntagResourceOutput, error)

func (*Activities) UpdateClassifier

func (*Activities) UpdateConnection

func (*Activities) UpdateCrawler

func (a *Activities) UpdateCrawler(ctx context.Context, input *glue.UpdateCrawlerInput) (*glue.UpdateCrawlerOutput, error)

func (*Activities) UpdateCrawlerSchedule

func (*Activities) UpdateDatabase

func (a *Activities) UpdateDatabase(ctx context.Context, input *glue.UpdateDatabaseInput) (*glue.UpdateDatabaseOutput, error)

func (*Activities) UpdateDevEndpoint

func (*Activities) UpdateJob

func (a *Activities) UpdateJob(ctx context.Context, input *glue.UpdateJobInput) (*glue.UpdateJobOutput, error)

func (*Activities) UpdateMLTransform

func (*Activities) UpdatePartition

func (a *Activities) UpdatePartition(ctx context.Context, input *glue.UpdatePartitionInput) (*glue.UpdatePartitionOutput, error)

func (*Activities) UpdateRegistry

func (a *Activities) UpdateRegistry(ctx context.Context, input *glue.UpdateRegistryInput) (*glue.UpdateRegistryOutput, error)

func (*Activities) UpdateSchema

func (a *Activities) UpdateSchema(ctx context.Context, input *glue.UpdateSchemaInput) (*glue.UpdateSchemaOutput, error)

func (*Activities) UpdateTable

func (a *Activities) UpdateTable(ctx context.Context, input *glue.UpdateTableInput) (*glue.UpdateTableOutput, error)

func (*Activities) UpdateTrigger

func (a *Activities) UpdateTrigger(ctx context.Context, input *glue.UpdateTriggerInput) (*glue.UpdateTriggerOutput, error)

func (*Activities) UpdateWorkflow

func (a *Activities) UpdateWorkflow(ctx context.Context, input *glue.UpdateWorkflowInput) (*glue.UpdateWorkflowOutput, error)

type SessionFactory

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL