watcher

type EventParameters struct {
	v1alpha1.WatchRequest
	Type        pb.EventType
	ClusterName string
	Object      *unstructured.Unstructured
	TimeStamp   time.Time
}

type GRPCClient interface {
	SendEvent(ctx context.Context, params EventParameters) (pb.ResponseType, error)
	GetServerParams() (addr, port string)
}

type Params struct {
	v1alpha1.WatchRequest

	// InvokeWatcherAgentController is provided by watcheragent controller to
	// invoke the controller's Reconcile(https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/reconcile#Func.Reconcile)
	// func with the correct request (https://pkg.go.dev/sigs.k8s.io/controller-runtime/pkg/reconcile#Request).
	// This is needed for notifying the controller to update the resourceVersion
	// of a watch in the v1alpha1.WatcherAgentStatus.
	InvokeWatcherAgentController func()

	Clock             clock.Clock
	ResourceInterface dynamic.ResourceInterface
	ClusterName       string
}

type Watcher struct {
	Cancel context.CancelFunc

	*Params

	// ResourceVersionCh carries the most recent resourceVersion from
	// cache.Reflector for a one time read by watcheragent controller
	ResourceVersionCh chan string
	// contains filtered or unexported fields
}