emrserverless

package

v0.1.3 Latest Latest Go to latest Published: Dec 5, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Application struct {
	service.AbstractResource
	*types.Application
}

func NewApplication(client AwsClient, application *types.Application) Application

func (e Application) GetName() string

func (e Application) GetTagValue(tag string) string

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

type ApplicationList struct {
	Items []Application
}

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	EMRServerless() *emrserverless.Client
}

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

func NewEMRServerlessRepository(ctx context.Context, client AwsClient) *EMRServerlessRepository

func (r *EMRServerlessRepository) DescribeApplication(applicationId *string) (*Application, error)

func (r *EMRServerlessRepository) DescribeApplicationByInput(query *emrserverless.GetApplicationInput) (*Application, error)

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

func (r *EMRServerlessRepository) ListApplicationsActive() ([]Application, error)

func (r *EMRServerlessRepository) ListApplicationsAll(maxResults *int32) ([]Application, error)

func (r *EMRServerlessRepository) ListApplicationsByInput(query *emrserverless.ListApplicationsInput) ([]Application, error)

func (r *EMRServerlessRepository) ListJobRunsAll() ([]JobRun, error)

func (r *EMRServerlessRepository) ListJobRunsByInput(query *emrserverless.ListJobRunsInput) ([]JobRun, error)

ListJobRunsByInput returns all job runs for a given Input

type JobRun struct {
	service.AbstractResource
	*types.JobRun
}

func NewJobRun(client AwsClient, jobRun *types.JobRun) JobRun

func (e JobRun) GetName() string

func (e JobRun) GetTagValue(tag string) string

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

type JobRunList struct {
	Items []JobRun
}