router

Documentation

Index

• type Router
  • func NewRouter(log logr.Logger, listener, advertiseListener *net.TCPAddr, clusterID string, ...) (*Router, error)
  • func (r *Router) ListenAndServe() error
  • func (r *Router) Shutdown() error

Types

type Router

type Router struct {
	Broker *logical_broker.LogicalBroker
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(log logr.Logger, listener, advertiseListener *net.TCPAddr, clusterID string, brokerID int32, redisAddresses []string) (*Router, error)

func (*Router) ListenAndServe

func (r *Router) ListenAndServe() error

func (*Router) Shutdown

func (r *Router) Shutdown() error