storage

type Handler interface {
	HandleMessage(ctx context.Context, msg ScheduledMessage) error
}

type Message struct {
	Data       []byte
	Attributes map[string]string
}

type ScheduledMessage struct {
	Message
	MessageType   string
	ScheduledTime time.Time
}

type SchedulerStorage interface {
	io.Closer
	Save(ctx context.Context, scheduledTime time.Time, msgType string, aggregationID string, msg Message) error
	GetLatest(ctx context.Context, olderThan time.Time, handler Handler) (bool, error)
}