schedulers

Documentation

Index

• Constants
• func ForLegacyScheduler(msg pulsar.Message) bool
• func ForPulsarScheduler(msg pulsar.Message) bool
• func MsgPropertyFromScheduler(s Scheduler) string
• type Scheduler
  • func SchedulerFromMsg(msg pulsar.Message) Scheduler

Constants

const (
	PropertyName             string = "schedulerName"
	PulsarSchedulerAttribute string = "pulsar"
	LegacySchedulerAttribute string = "legacy"
	AllSchedulersAttribute   string = "all"
)

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