controller

Documentation

Index

• type PodEvent
• type RPCServiceController
  • func NewRPCServiceController(reg registry.Registry, namespace string, syncperiod time.Duration) *RPCServiceController
  • func (c *RPCServiceController) HasSynced() bool
  • func (c *RPCServiceController) LastSyncResourceVersion() string
  • func (c *RPCServiceController) Start()

Types

type PodEvent

type PodEvent struct {
	// contains filtered or unexported fields
}

type RPCServiceController

type RPCServiceController struct {
	// contains filtered or unexported fields
}

func NewRPCServiceController

func NewRPCServiceController(reg registry.Registry, namespace string, syncperiod time.Duration) *RPCServiceController

func (*RPCServiceController) HasSynced

func (c *RPCServiceController) HasSynced() bool

func (*RPCServiceController) LastSyncResourceVersion

func (c *RPCServiceController) LastSyncResourceVersion() string

func (*RPCServiceController) Start

func (c *RPCServiceController) Start()

Start the controller, then waits for process termination signals