emr

Documentation

Index

• func MigrateClusters(db *gorm.DB) error
• func NewClient(session *session.Session, awsConfig *aws.Config, db *gorm.DB, log *zap.Logger, ...) resource.ClientInterface
• type Client
  • func (c *Client) CollectResource(resource string, config interface{}) error
• type Cluster
  • func (Cluster) TableName() string
• type ClusterStatus
  • func (ClusterStatus) TableName() string

Functions

func MigrateClusters

func MigrateClusters(db *gorm.DB) error

func NewClient

func NewClient(session *session.Session, awsConfig *aws.Config, db *gorm.DB, log *zap.Logger,
	accountID string, region string) resource.ClientInterface

Types

type Client

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

func (*Client) CollectResource

func (c *Client) CollectResource(resource string, config interface{}) error

type Cluster

type Cluster struct {
	ID                      uint `gorm:"primarykey"`
	AccountID               string
	Region                  string
	ClusterArn              *string
	Id                      *string
	Name                    *string
	NormalizedInstanceHours *int64
	OutpostArn              *string
	Status                  *ClusterStatus `gorm:"constraint:OnDelete:CASCADE;"`
}

func (Cluster) TableName

func (Cluster) TableName() string

type ClusterStatus

type ClusterStatus struct {
	ID                uint `gorm:"primarykey"`
	ClusterID         uint
	State             *string
	StateChangeReason *emr.ClusterStateChangeReason `gorm:"embedded;embeddedPrefix:state_change_reason_"`
	Timeline          *emr.ClusterTimeline          `gorm:"embedded;embeddedPrefix:timeline_"`
}

func (ClusterStatus) TableName

func (ClusterStatus) TableName() string