cmd

type CaptureIdentifiersFilter ¶

type CaptureIdentifiersFilter struct {
	Identifiers []wait.ResourceIdentifier
}

CaptureIdentifiersFilter implements the Filter interface in the kio package. It captures the identifiers for all resources passed through the pipeline.

func (f *CaptureIdentifiersFilter) Filter(slice []*yaml.RNode) ([]*yaml.RNode, error)

type CollectorStatusInfo ¶

type CollectorStatusInfo struct {
	Collector *ResourceStatusCollector
}

CollectorStatusInfo is a wrapper around the ResourceStatusCollector to make it adhere to the interface of the TableWriter.

func (f CollectorStatusInfo) CurrentStatus() StatusData

type EventPrinter ¶

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

type EventsRunner ¶

type EventsRunner struct {
	IncludeSubpackages bool
	Interval           time.Duration
	Timeout            time.Duration
	Command            *cobra.Command
	// contains filtered or unexported fields
}

EventsRunner captures the parameters for the command and contains the run function.

func GetEventsRunner() *EventsRunner

type FetchRunner ¶

type FetchRunner struct {
	IncludeSubpackages bool
	Command            *cobra.Command
	// contains filtered or unexported fields
}

FetchRunner captures the parameters for the command and contains the run function.

func GetFetchRunner() *FetchRunner

type FetchStatusInfo ¶

type FetchStatusInfo struct {
	Results []wait.ResourceResult
}

FetchStatusInfo wraps the results from the FetchAndResolve function to the format expected in the TablePrinter.

func (f FetchStatusInfo) CurrentStatus() StatusData

type ResourceStatus ¶

type ResourceStatus struct {
	Identifier wait.ResourceIdentifier
	Status     status.Status
	Message    string
}

ResourceStatus contains the status information for a single resource.

type ResourceStatusCollector ¶

type ResourceStatusCollector struct {
	AggregateStatus  status.Status
	ResourceStatuses []*ResourceStatus
	// contains filtered or unexported fields
}

ResourceStatusCollector captures the latest state seen for all resources based on the events from the Wait channel. This is used by the TablePrinter to display status for all resources.

type ResourceStatusData ¶

type ResourceStatusData struct {
	Identifier wait.ResourceIdentifier
	Status     status.Status
	Message    string
}

type RowData ¶

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

type StatusData ¶

type StatusData struct {
	AggregateStatus  status.Status
	ResourceStatuses []ResourceStatusData
}

type StatusInfo ¶

type StatusInfo interface {
	CurrentStatus() StatusData
}

type TablePrinter ¶

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

func (s *TablePrinter) Print()

func (s *TablePrinter) PrintUntil(stop <-chan struct{}, interval time.Duration) <-chan struct{}

type WaitRunner ¶

type WaitRunner struct {
	IncludeSubpackages bool
	Interval           time.Duration
	Timeout            time.Duration
	Command            *cobra.Command
	// contains filtered or unexported fields
}

WaitRunner captures the parameters for the command and contains the run function.

func GetWaitRunner() *WaitRunner