routing

Documentation

Index

• type Route
  • func NewRoute(def *config.RouteDef, partition int32, kafkaOps kafkaOps, ...) *Route
  • func (r *Route) String() string
  • func (r *Route) Subscribe(msgChan chan *kafka.Message)
• type RouteOps
• type Router
  • func ProvideRouter(kafkaCtx *config.KafkaContext, cfg *config.RouteConfig, ...) *Router

Types

type Route

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

func NewRoute

func NewRoute(def *config.RouteDef, partition int32, kafkaOps kafkaOps, logger *zap.SugaredLogger) *Route

func (*Route) String

func (r *Route) String() string

func (*Route) Subscribe

func (r *Route) Subscribe(msgChan chan *kafka.Message)

Subscribe is intended to run in goroutine. Assumes that messages in the channel are coming from the intended topic & partition. Subscription loop terminates once msgChan is closed.

type RouteOps

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

type Router

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

func ProvideRouter

func ProvideRouter(kafkaCtx *config.KafkaContext, cfg *config.RouteConfig, logger *zap.SugaredLogger, lc fx.Lifecycle) *Router