Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

resources

package

Go to main page

Versions in this module

v1

v1.3.14

May 13, 2026

Changes in this version

+ type ResourceInfo struct

+ Group string

+ Version string

type WatcherConfig

+ ApiVersion string

v1.3.13

Apr 17, 2026

Changes in this version

+ const MutationCheckpointInterval

+ type Factory struct

+ ClusterName string

+ FlowCollectorType pb.FlowCollector

+ K8sClient k8sclient.Client

+ Logger *zap.Logger

+ Stats *stream.Stats

+ func (f *Factory) Name() string

+ func (f *Factory) NewStreamClient(ctx context.Context, grpcConn grpc.ClientConnInterface) (stream.StreamClient, error)

+ type KubernetesResourcesStream interface

+ Recv func() (*pb.SendKubernetesResourcesResponse, error)

+ Send func(req *pb.SendKubernetesResourcesRequest) error

+ type ResourceStreamSender interface

+ CreateMutationObject func(metadata *pb.KubernetesObjectData, eventType watch.EventType) *pb.KubernetesResourceMutation

+ SendObjectData func(logger *zap.Logger, metadata *pb.KubernetesObjectData) error

+ type Watcher struct

+ func NewWatcher(config WatcherConfig) *Watcher

+ func (r *Watcher) DynamicListResources(ctx context.Context, logger *zap.Logger, apiGroup string) (string, error)

+ func (r *Watcher) ExtractObjectMetas(resources *unstructured.UnstructuredList) ([]metav1.ObjectMeta, error)

+ func (r *Watcher) FetchResources(ctx context.Context, resource schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error)

+ func (r *Watcher) ListResources(ctx context.Context, resource schema.GroupVersionResource, namespace string) ([]metav1.ObjectMeta, string, string, error)

+ func (r *Watcher) WatchK8sResources(ctx context.Context, cancel context.CancelFunc, resourceVersion string, ...)

+ type WatcherConfig struct

+ ApiGroup string

+ BaseLogger *zap.Logger

+ Clientset kubernetes.Interface

+ DynamicClient dynamic.Interface

+ Limiter *rate.Limiter

+ ResourceName string

+ ResourcesClient ResourceStreamSender