scheduler

package

v0.0.3 Latest Latest Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler defines the service in charge of retrieving the next batch of scheduled messages.

func New(
	da action.DeliveryActioner,
	ma action.MessageActioner,
	clk clock.Clocker,
) *Scheduler

New creates a Scheduler instance.

func (s *Scheduler) DeliverMessage(message *resource.Message) error

DeliverMessage queues the message with the specified id to be delivered.

func (s *Scheduler) RetrieveScheduledMessages() ([]*resource.Message, error)