awscache

Documentation

Index

• type AWSCache
  • func (a *AWSCache) Session(profile string, region string) (*AWSClients, error)
• type AWSClients
  • func (a *AWSClients) AccountID() (string, error)
  • func (a *AWSClients) CancelStackUpdate(ctx context.Context, stackName string) error
  • func (a *AWSClients) CreateChangesetWaitForStatus(ctx context.Context, in *cloudformation.CreateChangeSetInput, ...) (*cloudformation.DescribeChangeSetOutput, error)
  • func (a *AWSClients) DescribeStack(ctx context.Context, name string) (*cloudformation.Stack, error)
  • func (a *AWSClients) ExecuteChangeset(ctx context.Context, changesetARN string) error
  • func (a *AWSClients) FixTemplateBody(ctx context.Context, in *cloudformation.CreateChangeSetInput, bucket string, ...) error
  • func (a *AWSClients) Region() string
  • func (a *AWSClients) WaitForTerminalState(ctx context.Context, stackID string, log *logger.Logger) error
• type StackStreamer
  • func (s *StackStreamer) Close() error
  • func (s *StackStreamer) Start(ctx context.Context, clients *AWSClients, stackID string, ...) error

Types

type AWSCache

type AWSCache struct {
	Cleanup      *cleanup.Cleanup
	PollInterval time.Duration
	// contains filtered or unexported fields
}

func (*AWSCache) Session

func (a *AWSCache) Session(profile string, region string) (*AWSClients, error)

type AWSClients

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

func (*AWSClients) AccountID

func (a *AWSClients) AccountID() (string, error)

func (*AWSClients) CancelStackUpdate

func (a *AWSClients) CancelStackUpdate(ctx context.Context, stackName string) error

func (*AWSClients) CreateChangesetWaitForStatus

func (a *AWSClients) CreateChangesetWaitForStatus(ctx context.Context, in *cloudformation.CreateChangeSetInput, existingStack *cloudformation.Stack, logger *logger.Logger) (*cloudformation.DescribeChangeSetOutput, error)

func (*AWSClients) DescribeStack

func (a *AWSClients) DescribeStack(ctx context.Context, name string) (*cloudformation.Stack, error)

func (*AWSClients) ExecuteChangeset

func (a *AWSClients) ExecuteChangeset(ctx context.Context, changesetARN string) error

func (*AWSClients) FixTemplateBody

func (a *AWSClients) FixTemplateBody(ctx context.Context, in *cloudformation.CreateChangeSetInput, bucket string, logger *logger.Logger) error

func (*AWSClients) Region

func (a *AWSClients) Region() string

func (*AWSClients) WaitForTerminalState

func (a *AWSClients) WaitForTerminalState(ctx context.Context, stackID string, log *logger.Logger) error

waitForTerminalState loops forever until either the context ends, or something fails

type StackStreamer

type StackStreamer struct {
	PollInterval time.Duration
	Logger       *logger.Logger
	// contains filtered or unexported fields
}

StackStreamer sends cloudformation events about a stack into stdout

func (*StackStreamer) Close

func (s *StackStreamer) Close() error

Close stops streaming cloudformation events

func (*StackStreamer) Start

func (s *StackStreamer) Start(ctx context.Context, clients *AWSClients, stackID string, streamInto chan<- *cloudformation.StackEvent) error

Start streaming clouformation events