schedulers

package
v0.4.39 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL