glue

Documentation

Index

• type AwsClient
• type Database
  • func NewDatabase(client AwsClient, database types.Database, tags map[string]string) Database
  • func (e Database) GetName() string
  • func (e Database) GetTagValue(tag string) string
  • func (e Database) GetTags() map[string]string
• type DatabaseList
• type GlueRepository
  • func NewGlueRepository(ctx context.Context, client AwsClient) *GlueRepository
  • func (r *GlueRepository) GetRegion() ptypes.AwsRegion
  • func (r *GlueRepository) ListDatabaseAll() ([]Database, error)
  • func (r *GlueRepository) ListDatabaseByInput(query *glue.GetDatabasesInput) ([]Database, error)
  • func (r *GlueRepository) ListJobsAll() ([]Job, error)
  • func (r *GlueRepository) ListJobsByInput(query *glue.GetJobsInput) ([]Job, error)
  • func (r *GlueRepository) ListTablesAll() ([]Table, error)
  • func (r *GlueRepository) ListTablesByInput(query *glue.GetTablesInput) ([]Table, error)
• type Job
  • func NewJob(client AwsClient, job types.Job, tags map[string]string) Job
  • func (e Job) GetName() string
  • func (e Job) GetTagValue(tag string) string
  • func (e Job) GetTags() map[string]string
• type JobList
• type Table
  • func NewTable(client AwsClient, table types.Table, tags map[string]string) Table
  • func (e Table) GetName() string
  • func (e Table) GetTagValue(tag string) string
  • func (e Table) GetTags() map[string]string
• type TableList

Types

type AwsClient

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	Glue() *glue.Client
}

type Database

type Database struct {
	service.AbstractResource
	types.Database
	Tags map[string]string
}

func NewDatabase

func NewDatabase(client AwsClient, database types.Database, tags map[string]string) Database

func (Database) GetName

func (e Database) GetName() string

func (Database) GetTagValue

func (e Database) GetTagValue(tag string) string

func (Database) GetTags

func (e Database) GetTags() map[string]string

type DatabaseList

type DatabaseList struct {
	Items []Database
}

type GlueRepository

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

func NewGlueRepository

func NewGlueRepository(ctx context.Context, client AwsClient) *GlueRepository

func (*GlueRepository) GetRegion

func (r *GlueRepository) GetRegion() ptypes.AwsRegion

func (*GlueRepository) ListDatabaseAll

func (r *GlueRepository) ListDatabaseAll() ([]Database, error)

func (*GlueRepository) ListDatabaseByInput

func (r *GlueRepository) ListDatabaseByInput(query *glue.GetDatabasesInput) ([]Database, error)

func (*GlueRepository) ListJobsAll

func (r *GlueRepository) ListJobsAll() ([]Job, error)

func (*GlueRepository) ListJobsByInput

func (r *GlueRepository) ListJobsByInput(query *glue.GetJobsInput) ([]Job, error)

func (*GlueRepository) ListTablesAll

func (r *GlueRepository) ListTablesAll() ([]Table, error)

func (*GlueRepository) ListTablesByInput

func (r *GlueRepository) ListTablesByInput(query *glue.GetTablesInput) ([]Table, error)

type Job

type Job struct {
	service.AbstractResource
	types.Job
	Tags map[string]string
}

func NewJob

func NewJob(client AwsClient, job types.Job, tags map[string]string) Job

func (Job) GetName

func (e Job) GetName() string

func (Job) GetTagValue

func (e Job) GetTagValue(tag string) string

func (Job) GetTags

func (e Job) GetTags() map[string]string

type JobList

type JobList struct {
	Items []Job
}

type Table

type Table struct {
	service.AbstractResource
	types.Table
	Tags map[string]string
}

func NewTable

func NewTable(client AwsClient, table types.Table, tags map[string]string) Table

func (Table) GetName

func (e Table) GetName() string

func (Table) GetTagValue

func (e Table) GetTagValue(tag string) string

func (Table) GetTags

func (e Table) GetTags() map[string]string

type TableList

type TableList struct {
	Items []Table
}