publisher

Documentation

Index

• Constants
• func InitFlags(flagset *pflag.FlagSet)
• type Controller
  • func NewController(kubeclientset kubernetes.Interface, carbonclientset clientset.Interface, ...) *Controller
  • func (c *Controller) GetObj(namespace, key string) (interface{}, error)
  • func (c *Controller) Sync(key string) error
  • func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool

Constants

const (
	ErrorCodeServerUnvailable = 503
)

error code

Functions

func InitFlags

func InitFlags(flagset *pflag.FlagSet)

InitFlags is for explicitly initializing the flags.

Types

type Controller

type Controller struct {
	// GroupVersionKind indicates the controller type.
	// Different instances of this struct may handle different GVKs.
	// For example, this struct can be used (with adapters) to handle ReplicationController.
	schema.GroupVersionKind
	controller.DefaultController
	// contains filtered or unexported fields
}

Controller is the controller implementation for ServicePublisher resources

func NewController

func NewController(
	kubeclientset kubernetes.Interface,
	carbonclientset clientset.Interface,
	workerInformer carboninformers.WorkerNodeInformer,
	publisherInformer carboninformers.ServicePublisherInformer,
	serviceInformer coreinformers.ServiceInformer) *Controller

NewController returns a new rollingset controller

func (*Controller) GetObj

func (c *Controller) GetObj(namespace, key string) (interface{}, error)

GetObj grep replica

func (*Controller) Sync

func (c *Controller) Sync(key string) error

Sync compares the actual state with the desired, and attempts to converge the two.

func (*Controller) WaitForCacheSync

func (c *Controller) WaitForCacheSync(stopCh <-chan struct{}) bool

WaitForCacheSync wait for informers synced