cluster

Documentation

Index

• func WithDefaultScheme(o *cluster.Options)
• func WithDisableCaches() func(o *cluster.Options)
• func WithInNamespace(ns string) func(o *cluster.Options)
• func WithWatchClient(o *cluster.Options)
• type Cluster
  • func NewCluster(config *rest.Config, options ...cluster.Option) (*Cluster, error)
  • func NewClusterAndStart(ctx context.Context, config *rest.Config, apply func(c cluster.Cluster) error, ...) (*Cluster, error)
  • func NewLocalAgentClusterAndStart(ctx context.Context, options ...cluster.Option) (*Cluster, error)
  • func (c *Cluster) Discovery() discovery.CachedDiscoveryInterface
  • func (c *Cluster) Kubernetes() kubernetes.Interface
  • func (c *Cluster) Watch(ctx context.Context, list client.ObjectList, callback func(watch.Event) error, ...) error
• type Interface
• type WatchableDelegatingClient
  • func (c *WatchableDelegatingClient) Watch(ctx context.Context, obj client.ObjectList, opts ...client.ListOption) (watch.Interface, error)

Functions

func WithDefaultScheme

func WithDefaultScheme(o *cluster.Options)

func WithDisableCaches

func WithDisableCaches() func(o *cluster.Options)

func WithInNamespace

func WithInNamespace(ns string) func(o *cluster.Options)

func WithWatchClient

func WithWatchClient(o *cluster.Options)

Types

type Cluster

type Cluster struct {
	cluster.Cluster
	// contains filtered or unexported fields
}

func NewCluster

func NewCluster(config *rest.Config, options ...cluster.Option) (*Cluster, error)

func NewClusterAndStart

func NewClusterAndStart(ctx context.Context, config *rest.Config, apply func(c cluster.Cluster) error, options ...cluster.Option) (*Cluster, error)

func NewLocalAgentClusterAndStart

func NewLocalAgentClusterAndStart(ctx context.Context, options ...cluster.Option) (*Cluster, error)

func (*Cluster) Discovery

func (c *Cluster) Discovery() discovery.CachedDiscoveryInterface

func (*Cluster) Kubernetes

func (c *Cluster) Kubernetes() kubernetes.Interface

func (*Cluster) Watch

func (c *Cluster) Watch(ctx context.Context, list client.ObjectList, callback func(watch.Event) error, opts ...client.ListOption) error

type Interface

type Interface interface {
	cluster.Cluster
	Kubernetes() kubernetes.Interface
	Discovery() discovery.CachedDiscoveryInterface
	Watch(ctx context.Context, list client.ObjectList, callback func(watch.Event) error, opts ...client.ListOption) error
}

type WatchableDelegatingClient

type WatchableDelegatingClient struct {
	client.Client
	// contains filtered or unexported fields
}

func (*WatchableDelegatingClient) Watch

func (c *WatchableDelegatingClient) Watch(ctx context.Context, obj client.ObjectList, opts ...client.ListOption) (watch.Interface, error)