data

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2022 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const LOADING_ALIAS = "..."
View Source
const MAX_RESULTS = 32

Variables

View Source
var ISO_8601 = "2006-01-02T15:04:05.000-0700"

YYYY-MM-DDThh:mm:ss.sTZD

Functions

This section is empty.

Types

type Client

type Client struct {
	Glue          *GlueClient
	IAM           *IAMClient
	LakeFormation *LakeFormationClient
	Lambda        *LambdaClient
	RDS           *RDSClient
	S3            *S3Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*Client, error)

func (*Client) GetCurrentAWSAccountId

func (c *Client) GetCurrentAWSAccountId() (string, error)

type GlueClient

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

func NewGlueClient

func NewGlueClient(ctx context.Context, glue *glue.Client, s3 *s3.Client) *GlueClient

func (*GlueClient) GetCrawlersRows

func (c *GlueClient) GetCrawlersRows(nextToken *string) ([]table.Row, *string, error)

func (*GlueClient) GetJobDetails

func (c *GlueClient) GetJobDetails(jobName string) ([]table.Row, error)

func (*GlueClient) GetJobRuns

func (c *GlueClient) GetJobRuns(jobName string) ([]table.Row, error)

func (*GlueClient) GetJobScript

func (c *GlueClient) GetJobScript(jobName string) (string, string, error)

func (*GlueClient) GetJobsRows

func (c *GlueClient) GetJobsRows(nextToken *string) ([]table.Row, *string, error)

type IAMClient

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

func NewIAMClient

func NewIAMClient(ctx context.Context, iam *iam.Client) *IAMClient

func (*IAMClient) GetAssumeRolePolicy

func (c *IAMClient) GetAssumeRolePolicy(roleName string) (string, error)

func (*IAMClient) GetInlineRolePolicy

func (c *IAMClient) GetInlineRolePolicy(roleName string, policyName string) (string, error)

func (*IAMClient) GetInlineUserPolicy

func (c *IAMClient) GetInlineUserPolicy(userName string, policyName string) (string, error)

func (*IAMClient) GetManagedPolicy

func (c *IAMClient) GetManagedPolicy(policyArn string) (string, error)

func (*IAMClient) GetRolePolicies

func (c *IAMClient) GetRolePolicies(roleName string, nextToken *string) ([]table.Row, *string, error)

func (*IAMClient) GetRoleTags

func (c *IAMClient) GetRoleTags(roleName string, nextToken *string) ([]table.Row, *string, error)

func (*IAMClient) GetRoles

func (c *IAMClient) GetRoles(nextToken *string) ([]table.Row, *string, error)

func (*IAMClient) GetUserPolicies

func (c *IAMClient) GetUserPolicies(userName string, nextToken *string) ([]table.Row, *string, error)

func (*IAMClient) GetUserTags

func (c *IAMClient) GetUserTags(userName string, nextToken *string) ([]table.Row, *string, error)

func (*IAMClient) GetUsers

func (c *IAMClient) GetUsers(nextToken *string) ([]table.Row, *string, error)

type LakeFormationClient

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

func NewLakeFormationClient

func NewLakeFormationClient(ctx context.Context, lf *lakeformation.Client, glue *glue.Client) *LakeFormationClient

func (*LakeFormationClient) GetDataLakeLocations

func (c *LakeFormationClient) GetDataLakeLocations(nextToken *string) ([]table.Row, *string, error)

func (*LakeFormationClient) GetDatabaseDetails added in v0.0.3

func (c *LakeFormationClient) GetDatabaseDetails(databaseName string) ([]table.Row, error)

func (*LakeFormationClient) GetDatabaseTables added in v0.0.4

func (c *LakeFormationClient) GetDatabaseTables(databaseName string) ([]table.Row, error)

func (*LakeFormationClient) GetDatabaseTags added in v0.0.3

func (c *LakeFormationClient) GetDatabaseTags(databaseName string) ([]table.Row, error)

func (*LakeFormationClient) GetDatabases

func (c *LakeFormationClient) GetDatabases(nextToken *string) ([]table.Row, *string, error)

func (*LakeFormationClient) GetLFTagPermissions

func (c *LakeFormationClient) GetLFTagPermissions(nextToken *string) ([]table.Row, *string, error)

func (*LakeFormationClient) GetLFTags

func (c *LakeFormationClient) GetLFTags(nextToken *string) ([]table.Row, *string, error)

func (*LakeFormationClient) GetTableDetailsAndSchema added in v0.0.3

func (c *LakeFormationClient) GetTableDetailsAndSchema(tableName string, databaseName string) ([]table.Row, []table.Row, error)

func (*LakeFormationClient) GetTableTags added in v0.0.3

func (c *LakeFormationClient) GetTableTags(tableName string, databaseName string) ([]table.Row, error)

func (*LakeFormationClient) GetTables

func (c *LakeFormationClient) GetTables(nextToken *string) ([]table.Row, *string, error)

type LambdaClient

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

func NewLambdaClient

func NewLambdaClient(ctx context.Context, lambda *lambda.Client, cloudwatch *cloudwatch.Client) *LambdaClient

func (*LambdaClient) GetFunctionDetails

func (c *LambdaClient) GetFunctionDetails(functionName string) ([]table.Row, error)

func (*LambdaClient) GetFunctions

func (c *LambdaClient) GetFunctions(nextToken *string) ([]table.Row, *string, error)

func (*LambdaClient) GetMetric

func (c *LambdaClient) GetMetric(functionName string, metricName string, statistic types.Statistic) ([]float64, error)

type RDSClient

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

func NewRDSClient

func NewRDSClient(ctx context.Context, rds *rds.Client, cloudwatch *cloudwatch.Client) *RDSClient

func (*RDSClient) GetDBInstances

func (c *RDSClient) GetDBInstances(nextToken *string) ([]table.Row, *string, error)

func (*RDSClient) GetInstanceDetails

func (c *RDSClient) GetInstanceDetails(instance string) ([]table.Row, error)

func (*RDSClient) GetInstanceTags

func (c *RDSClient) GetInstanceTags(instance string) ([]table.Row, error)

func (*RDSClient) GetMetric

func (c *RDSClient) GetMetric(instance string, metricName string) ([]float64, error)

type S3Client

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

func NewS3Client

func NewS3Client(ctx context.Context, s3 *s3.Client) *S3Client

func (*S3Client) GetBucketPolicy

func (c *S3Client) GetBucketPolicy(bucket string, region string) (string, error)

func (*S3Client) GetBucketRegion added in v0.0.3

func (c *S3Client) GetBucketRegion(bucket string) (string, error)

func (*S3Client) GetBucketTags

func (c *S3Client) GetBucketTags(bucket string, region string) ([]table.Row, error)

func (*S3Client) GetBuckets

func (c *S3Client) GetBuckets() ([]table.Row, error)

func (*S3Client) GetObjectProperties

func (c *S3Client) GetObjectProperties(bucket string, key string, region string) ([]table.Row, error)

func (*S3Client) GetObjects

func (c *S3Client) GetObjects(bucket string, region string, prefix string, nextToken *string) ([]table.Row, *string, error)

Jump to

Keyboard shortcuts

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