emitter

Documentation

Index

• type NATSEmitter
  • func NewNATSEmitter(natsClient diegonats.NATSClient, workPool *workpool.WorkPool, ...) NATSEmitter
• type RoutingAPIEmitter
  • func NewRoutingAPIEmitter(logger lager.Logger, routingAPIClient routing_api.Client, ...) RoutingAPIEmitter

Types

type NATSEmitter

type NATSEmitter interface {
	Emit(messagesToEmit routingtable.MessagesToEmit) error
}

func NewNATSEmitter

func NewNATSEmitter(natsClient diegonats.NATSClient, workPool *workpool.WorkPool, logger lager.Logger, metronClient loggingclient.IngressClient, emitInternalRoutes bool) NATSEmitter

type RoutingAPIEmitter

type RoutingAPIEmitter interface {
	Emit(routingEvents routingtable.TCPRouteMappings) error
}

func NewRoutingAPIEmitter

func NewRoutingAPIEmitter(logger lager.Logger, routingAPIClient routing_api.Client, uaaTokenFetcher uaaclient.TokenFetcher, routeTTL int) RoutingAPIEmitter