sharedcfg

Documentation

Index

• Variables
• type Configs
• type Runner
• type RunnerFunc
  • func (rf RunnerFunc) Run(stopC <-chan struct{})
• type SharedConfigs
  • func New(ctx context.Context, ns string) SharedConfigs

Variables

var (
	// We'll attempt to recompute EVERY service's endpoints at least this
	// often. Higher numbers = lower CPU/network load; lower numbers =
	// shorter amount of time before a mistaken endpoint is corrected.
	FullyResyncPeriod = time.Minute
)

common vars

Types

type Configs

type Configs interface {
	Context() context.Context
	Namespace() string

	RestConfig() *rest.Config

	KubeClient() kubernetes.Interface
	KubeInformers() k8sinformers.SharedInformerFactory

	RefuncClient() clientset.Interface
	RefuncInformers() rfinformers.SharedInformerFactory
}

Configs provides client resources to use

type Runner

type Runner interface {
	Run(stopC <-chan struct{})
}

Runner is block and long running object defines a configs consumer

type RunnerFunc

type RunnerFunc func(stopC <-chan struct{})

func (RunnerFunc) Run

func (rf RunnerFunc) Run(stopC <-chan struct{})

type SharedConfigs

type SharedConfigs interface {
	Runner
	Configs() Configs
	AddController(func(cfg Configs) Runner)
}

SharedConfigs are collection of k8s configs & clients shared by multiple consumers

func New

func New(ctx context.Context, ns string) SharedConfigs

New creates a new SharedConfigs