subscription

type ClientFactory struct{}

type Factory interface {
	Client(ctx context.Context, url string) (Watcher, error)
}

type PodLister interface {
	List(context.Context, metav1.ListOptions) (*corev1.PodList, error)
}

type Processor struct {
	Factory             Factory
	ProcessorRepository ProcessorRepository
	PodLister           PodLister
}

type ProcessorRepository interface {
	PodsByProcessors(context.Context, []int) ([][]*model.Pod, error)
	ByID(context.Context, int) (*model.Processor, error)
	ComponentByProcessors(context.Context, []int) ([]*model.Component, error)
}

type Subscribers struct {
	PodLister           PodLister
	Factory             Factory
	ProcessorRepository ProcessorRepository
}

type Watcher interface {
	Processor(ctx context.Context, in *watchv1.ProcessorRequest, opts ...grpc.CallOption) (watchv1.WatchAPI_ProcessorClient, error)
}