Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Ingress ¶
func (*Ingress) SubsribeHandler ¶
SubsribeHandler subscribes to specific subject and unmarshal the message into talaria's event type. The event message then will be used as the input of the handler function defined.
func (*Ingress) SubsribeHandlerWithPool ¶
func (i *Ingress) SubsribeHandlerWithPool(ctx context.Context, handler func(b []map[string]interface{}, split string)) error
SubscribeHandlerWithPool process the message concurrently using goroutine pool. The message will be asynchornously executed to reduce the message process time to avoid being slow consumer.
Click to show internal directories.
Click to hide internal directories.