routehandlers

Documentation

Index

• type Handler
  • func NewHandler(routingTable routingtable.RoutingTable, natsEmitter emitter.NATSEmitter, ...) *Handler
  • func (handler *Handler) EmitExternal(logger lager.Logger)
  • func (handler *Handler) EmitInternal(logger lager.Logger)
  • func (handler *Handler) HandleEvent(logger lager.Logger, event models.Event)
  • func (handler *Handler) RefreshDesired(logger lager.Logger, desiredLRPs []*models.DesiredLRP)
  • func (handler *Handler) ShouldRefreshDesired(actualLRP *models.ActualLRP) bool
  • func (handler *Handler) Sync(logger lager.Logger, desired []*models.DesiredLRP, actuals []*models.ActualLRP, ...)

Types

type Handler

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

func NewHandler

func NewHandler(
	routingTable routingtable.RoutingTable,
	natsEmitter emitter.NATSEmitter,
	routingAPIEmitter emitter.RoutingAPIEmitter,
	localMode bool,
	tcpTLSEnabled bool,
	metronClient loggingclient.IngressClient,
	unregistrationCache unregistration.Cache,
) *Handler

func (*Handler) EmitExternal

func (handler *Handler) EmitExternal(logger lager.Logger)

func (*Handler) EmitInternal

func (handler *Handler) EmitInternal(logger lager.Logger)

func (*Handler) HandleEvent

func (handler *Handler) HandleEvent(logger lager.Logger, event models.Event)

func (*Handler) RefreshDesired

func (handler *Handler) RefreshDesired(logger lager.Logger, desiredLRPs []*models.DesiredLRP)

func (*Handler) ShouldRefreshDesired

func (handler *Handler) ShouldRefreshDesired(actualLRP *models.ActualLRP) bool

func (*Handler) Sync

func (handler *Handler) Sync(
	logger lager.Logger,
	desired []*models.DesiredLRP,
	actuals []*models.ActualLRP,
	domains models.DomainSet,
	cachedEvents map[string]models.Event,
)