Documentation
¶
Index ¶
Constants ¶
View Source
const (
PropertyName string = "schedulerName"
PulsarSchedulerAttribute string = "pulsar"
LegacySchedulerAttribute string = "legacy"
AllSchedulersAttribute string = "all"
)
Variables ¶
This section is empty.
Functions ¶
func ForLegacyScheduler ¶
func ForLegacyScheduler(msg pulsar.Message) bool
ForLegacyScheduler returns true if this message should be processed by the legacy scheduler
func ForPulsarScheduler ¶
func ForPulsarScheduler(msg pulsar.Message) bool
ForPulsarScheduler returns true if this message should be processed by the pulsar scheduler
func MsgPropertyFromScheduler ¶
func MsgPropertyFromScheduler(s Scheduler) string
MsgPropertyFromScheduler returns the pulsar message property associated with the scheduler
Types ¶
type Scheduler ¶
type Scheduler int
const (
Legacy Scheduler = iota
Pulsar
All
)
func SchedulerFromMsg ¶
func SchedulerFromMsg(msg pulsar.Message) Scheduler
SchedulerFromMsg parses the message properties to retrieve the Scheduler associated with the message
Source Files
Click to show internal directories.
Click to hide internal directories.