k8s

type Client interface {
	runtimeclient.Client
	GetLogs(string, string, *corev1.PodLogOptions) (io.ReadCloser, error)
	Attach(*corev1.Pod) error
}

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

type FactoryInterface interface {
	NewConfig(string) (*rest.Config, error)
	NewClient(*rest.Config) (Client, error)
	NewManager(*rest.Config, string) (*Manager, error)
	GenerateName(string) string
}

type ManagedReporter struct {
	Reporter
	// contains filtered or unexported fields
}

type Manager struct {
	runtimecache.Cache
	Objs []runtime.Object
	// contains filtered or unexported fields
}

type Reporter interface {
	// Register creates an informer for a given kind/obj.
	Register(cache.Cache) (cache.Informer, error)

	// MatchingObj tells the cache manager which objects the reporter receives events for.
	// Allows tests to inject objects.
	MatchingObj(interface{}) bool

	// Handler receives events from the informer. Invoked only once.
	Handler(context.Context, <-chan ctrl.Request) error
}