Package schedulermocks is a generated GoMock package.

EventsFromSchedulerResult generates necessary EventSequences from the provided SchedulerResult.

JavaStringHash is the default hashing algorithm used by Pulsar copied from https://github.com/apache/pulsar-client-go/blob/master/pulsar/internal/hash.go.

Run sets up a Scheduler application and runs it until a SIGTERM is received.

ExecutorApi is the gRPC service executors use to synchronise their state with that of the scheduler.

MetricsCollector is a Prometheus Collector that handles scheduler metrics.

PulsarPublisher is the default implementation of Publisher.

Scheduler is the main Armada scheduler.

Publisher is an interface to be implemented by structs that handle publishing messages to pulsar.