run

Imports

• go.uber.org/zap/zapcore
• k8s.io/apimachinery/pkg/runtime
• k8s.io/api/core/v1
• k8s.io/client-go/rest
• k8s.io/client-go/tools/clientcmd
• sigs.k8s.io/controller-runtime/pkg/client
• sigs.k8s.io/controller-runtime/pkg/log/zap
• github.com/go-logr/logr

Imports in module “github.com/dataflow-operator/dataflow”

• github.com/dataflow-operator/dataflow/api/v1
• github.com/dataflow-operator/dataflow/internal/controller
• github.com/dataflow-operator/dataflow/internal/logkeys
• github.com/dataflow-operator/dataflow/internal/processor
• github.com/dataflow-operator/dataflow/internal/checkpoint
• github.com/dataflow-operator/dataflow/pkg/providers

Standard library imports

• context
• encoding/json
• fmt
• strings