streamer

Documentation

Index

• type StackEvents
• type StackEventsRecord
• type Streamer
  • func New(svc cloudformationiface.CloudFormationAPI, logger *logrus.Logger) *Streamer
  • func (s *Streamer) DescribeStackEvents(stackName *string, seenEvents StackEvents) (stackEvents *StackEventsRecord)
  • func (s *Streamer) StartStreaming(stackName *string, seenEvents StackEvents, wr *writer.StringWriter, ...) error
• type Streameriface

Types

type StackEvents

type StackEvents map[string]*cloudformation.StackEvent

type StackEventsRecord

type StackEventsRecord struct {
	Records StackEvents
	Err     error
}

type Streamer

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

func New

func New(svc cloudformationiface.CloudFormationAPI, logger *logrus.Logger) *Streamer

func (*Streamer) DescribeStackEvents

func (s *Streamer) DescribeStackEvents(stackName *string, seenEvents StackEvents) (stackEvents *StackEventsRecord)

func (*Streamer) StartStreaming

func (s *Streamer) StartStreaming(stackName *string, seenEvents StackEvents, wr *writer.StringWriter, done <-chan bool) error

type Streameriface

type Streameriface interface {
	StartStreaming(*string, StackEvents, *writer.StringWriter, <-chan bool) error
	DescribeStackEvents(*string, StackEvents) (stackEvents *StackEventsRecord)
}