Documentation
¶
Overview ¶
Code generated by generate-cached. DO NOT EDIT.
Index ¶
- type Application
- type ApplicationList
- type AwsClient
- type EMRServerlessRepository
- func (r *EMRServerlessRepository) DescribeApplication(applicationId *string) (*Application, error)
- func (r *EMRServerlessRepository) DescribeApplicationByInput(query *awsemr.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 *awsemr.ListApplicationsInput) ([]Application, error)
- func (r *EMRServerlessRepository) ListJobRunsAll() ([]JobRun, error)
- func (r *EMRServerlessRepository) ListJobRunsByInput(query *awsemr.ListJobRunsInput) ([]JobRun, error)
- func (r *EMRServerlessRepository) WithCache(dc *cache.DataCache) *EMRServerlessRepositoryCached
- type EMRServerlessRepositoryCached
- func (c *EMRServerlessRepositoryCached) ListApplicationsActive() ([]Application, error)
- func (c *EMRServerlessRepositoryCached) ListApplicationsAll(maxResults *int32) ([]Application, error)
- func (c *EMRServerlessRepositoryCached) ListApplicationsByInput(query *awsemr.ListApplicationsInput) ([]Application, error)
- func (c *EMRServerlessRepositoryCached) ListJobRunsAll() ([]JobRun, error)
- func (c *EMRServerlessRepositoryCached) ListJobRunsByInput(query *awsemr.ListJobRunsInput) ([]JobRun, error)
- type JobRun
- type JobRunList
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Application ¶
type Application struct {
service.AbstractResource
*types.Application
}
func NewApplication ¶
func NewApplication(client AwsClient, application *types.Application) Application
func (Application) GetName ¶
func (e Application) GetName() string
func (Application) GetTagValue ¶
func (e Application) GetTagValue(tag string) string
func (Application) GetTags ¶
func (e Application) GetTags() map[string]string
type ApplicationList ¶
type ApplicationList struct {
Items []Application
}
type AwsClient ¶
type AwsClient interface {
GetRegion() ptypes.AwsRegion
GetAccountID() ptypes.AwsAccountID
}
type EMRServerlessRepository ¶
type EMRServerlessRepository struct {
// contains filtered or unexported fields
}
func NewEMRServerlessRepository ¶
func NewEMRServerlessRepository(ctx context.Context, client *v3.Client) *EMRServerlessRepository
func (*EMRServerlessRepository) DescribeApplication ¶
func (r *EMRServerlessRepository) DescribeApplication(applicationId *string) (*Application, error)
func (*EMRServerlessRepository) DescribeApplicationByInput ¶
func (r *EMRServerlessRepository) DescribeApplicationByInput(query *awsemr.GetApplicationInput) (*Application, error)
func (*EMRServerlessRepository) GetRegion ¶
func (r *EMRServerlessRepository) GetRegion() ptypes.AwsRegion
func (*EMRServerlessRepository) ListApplicationsActive ¶
func (r *EMRServerlessRepository) ListApplicationsActive() ([]Application, error)
func (*EMRServerlessRepository) ListApplicationsAll ¶
func (r *EMRServerlessRepository) ListApplicationsAll(maxResults *int32) ([]Application, error)
func (*EMRServerlessRepository) ListApplicationsByInput ¶
func (r *EMRServerlessRepository) ListApplicationsByInput(query *awsemr.ListApplicationsInput) ([]Application, error)
func (*EMRServerlessRepository) ListJobRunsAll ¶
func (r *EMRServerlessRepository) ListJobRunsAll() ([]JobRun, error)
func (*EMRServerlessRepository) ListJobRunsByInput ¶
func (r *EMRServerlessRepository) ListJobRunsByInput(query *awsemr.ListJobRunsInput) ([]JobRun, error)
ListJobRunsByInput returns all job runs for a given Input
func (*EMRServerlessRepository) WithCache ¶ added in v0.4.0
func (r *EMRServerlessRepository) WithCache(dc *cache.DataCache) *EMRServerlessRepositoryCached
WithCache returns a EMRServerlessRepositoryCached that stores/retrieves results via the given DataCache. The cache namespace is set to "<accountID>:<region>".
type EMRServerlessRepositoryCached ¶ added in v0.4.0
type EMRServerlessRepositoryCached struct {
// contains filtered or unexported fields
}
EMRServerlessRepositoryCached wraps EMRServerlessRepository and caches results of Get*/List* calls.
func (*EMRServerlessRepositoryCached) ListApplicationsActive ¶ added in v0.4.0
func (c *EMRServerlessRepositoryCached) ListApplicationsActive() ([]Application, error)
ListApplicationsActive returns cached results when available, otherwise delegates to the underlying repository.
func (*EMRServerlessRepositoryCached) ListApplicationsAll ¶ added in v0.4.0
func (c *EMRServerlessRepositoryCached) ListApplicationsAll(maxResults *int32) ([]Application, error)
ListApplicationsAll returns cached results when available, otherwise delegates to the underlying repository.
func (*EMRServerlessRepositoryCached) ListApplicationsByInput ¶ added in v0.4.0
func (c *EMRServerlessRepositoryCached) ListApplicationsByInput(query *awsemr.ListApplicationsInput) ([]Application, error)
ListApplicationsByInput returns cached results when available, otherwise delegates to the underlying repository.
func (*EMRServerlessRepositoryCached) ListJobRunsAll ¶ added in v0.4.0
func (c *EMRServerlessRepositoryCached) ListJobRunsAll() ([]JobRun, error)
ListJobRunsAll returns cached results when available, otherwise delegates to the underlying repository.
func (*EMRServerlessRepositoryCached) ListJobRunsByInput ¶ added in v0.4.0
func (c *EMRServerlessRepositoryCached) ListJobRunsByInput(query *awsemr.ListJobRunsInput) ([]JobRun, error)
ListJobRunsByInput returns cached results when available, otherwise delegates to the underlying repository.
type JobRun ¶
type JobRun struct {
service.AbstractResource
*types.JobRun
}
func (JobRun) GetTagValue ¶
type JobRunList ¶
type JobRunList struct {
Items []JobRun
}
Source Files
Click to show internal directories.
Click to hide internal directories.