list

Documentation

Index

• func IsLastActionGroup(age event.ActionGroupEvent, ags []event.ActionGroup) bool
• type BaseListPrinter
  • func (b *BaseListPrinter) Print(ch <-chan event.Event, previewStrategy common.DryRunStrategy, printStatus bool) error
• type Collector
• type Formatter
• type FormatterFactory
• type StatusCollector
  • func (sc *StatusCollector) LatestStatus() map[object.ObjMetadata]event.StatusEvent

Functions

func IsLastActionGroup

func IsLastActionGroup(age event.ActionGroupEvent, ags []event.ActionGroup) bool

IsLastActionGroup returns true if the passed ActionGroupEvent is the last of its type in the slice of ActionGroup; false otherwise. For example, this function will determine if an ApplyAction is the last ApplyAction in the initialized task queue. This functionality is current used to determine when to print stats.

Types

type BaseListPrinter

type BaseListPrinter struct {
	FormatterFactory FormatterFactory
}

func (*BaseListPrinter) Print

func (b *BaseListPrinter) Print(ch <-chan event.Event, previewStrategy common.DryRunStrategy, printStatus bool) error

Print outputs the events from the provided channel in a simple format on StdOut. As we support other printer implementations this should probably be an interface. This function will block until the channel is closed.

type Collector

type Collector interface {
	LatestStatus() map[object.ObjMetadata]event.StatusEvent
}

type Formatter

type Formatter interface {
	FormatValidationEvent(ve event.ValidationEvent) error
	FormatApplyEvent(ae event.ApplyEvent) error
	FormatStatusEvent(se event.StatusEvent) error
	FormatPruneEvent(pe event.PruneEvent) error
	FormatDeleteEvent(de event.DeleteEvent) error
	FormatWaitEvent(we event.WaitEvent) error
	FormatErrorEvent(ee event.ErrorEvent) error
	FormatActionGroupEvent(
		age event.ActionGroupEvent,
		ags []event.ActionGroup,
		s stats.Stats,
		c Collector,
	) error
}

type FormatterFactory

type FormatterFactory func(previewStrategy common.DryRunStrategy) Formatter

type StatusCollector

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

func (*StatusCollector) LatestStatus

func (sc *StatusCollector) LatestStatus() map[object.ObjMetadata]event.StatusEvent