-
Notifications
You must be signed in to change notification settings - Fork 38
Sample usage #21
Comments
Hey @sann3, thanks for your interest in this project. We are hoping to publish our Scaladocs externally, but haven't quite got around to it yet. In the meantime, I've replaced all the private links with links to code/docs available in GitHub (see #22). Regarding sample usage, you're right that we should have something. Below is the general idea, however: val scheduler = new SchedulerImpl(
schedulerSettings,
typesafeConfig,
schedulerMetrics,
cassCluster,
schedulerKeyspace,
CassandraTaskExecutorService.factory(workersPerSchedulerPartition, taskRunner)
)(
schedulerLogging
)
scheduler.start()
val schedulerClient = new SchedulerClient(
kafkaProducer,
schedulerSettings.kafkaTopic,
schedulerSettings.schedulingGraceWindow,
schedulerMetrics
)(schedulerClientLogging)
val task = Task("some-ordering-id", Instant.now(), "some-uniqueness-key", Map("taskName" -> "my-task")
schedulerClient.scheduleTask(task) Admittedly, you'll have to dig on how to build some of these dependencies like |
Hi @DWvanGeest thanks for the sample code. I saw your speech in the Strange Loop. It was very good speech and very clear, so only I start exploring this project. Thanks for sharing this great project as open source. |
Hi @DWvanGeest any sample application available. thanks |
Hi @sann3 you did any sample application. |
No @kumar-cherry, I didn't created. Just waiting for long time. |
Sorry for the late response here, I was on vacation. We do not have a sample application available yet, unfortunately, but it's still on the to-do list. |
Any idea at what time we will get.
On 03-Aug-2017 8:10 PM, David van Geest <[email protected]> wrote:
Sorry for the late response here, I was on vacation. We do not have a sample application available yet, unfortunately, but it's still on the to-do list.
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub<#21 (comment)>, or mute the thread<https://github.com/notifications/unsubscribe-auth/AT3ZZzR1L1BaVt5ciJ7_sbR-QwO3mUJVks5sUdvqgaJpZM4M-_b0>.
|
No, we don't have an expected time to deliver a sample application. As a team we have plenty of other priorities at the moment. You would be welcome to contribute a sample application, which we could review and link to. |
OK thanks I will try my best, can you share some more additional details or document how to use library, it will helpful us.
On 03-Aug-2017 9:09 PM, David van Geest <[email protected]> wrote:
No, we don't have an expected time to deliver a sample application. As a team we have plenty of other priorities at the moment. You would be welcome to contribute a sample application, which we could review and link to.
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub<#21 (comment)>, or mute the thread<https://github.com/notifications/unsubscribe-auth/AT3ZZz6MlCviCAYcx4Yg9VI_mxcjMb0_ks5sUemxgaJpZM4M-_b0>.
|
@DWvanGeest Is it possible to create a how-to document to start using this library? Or a reference app will be even better. |
Thanks for sharing the scheduler.
I like to use in our application. I am new to Scala, so if you give me an the Sample main class to run this scheduler it will be very helpful for us.
Also some of the docs are private, is it possible to make as public. For example https://docs.pd-internal.com/scala/scheduler
The text was updated successfully, but these errors were encountered: