Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 FormatSummary(s stats.Stats) 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
Click to show internal directories.
Click to hide internal directories.