gosd alternatives and similar packages
Based on the "Messaging" category.
Alternatively, view gosd alternatives based on common mentions on social networks and blogs.
-
sarama
DISCONTINUED. Sarama is a Go library for Apache Kafka. [Moved to: https://github.com/IBM/sarama] -
Centrifugo
Scalable real-time messaging server in a language-agnostic way. Self-hosted alternative to Pubnub, Pusher, Ably. Set up once and forever. -
-
-
-
-
-
APNs2
⚡ HTTP/2 Apple Push Notification Service (APNs) push provider for Go — Send push notifications to iOS, tvOS, Safari and OSX apps, using the APNs HTTP/2 protocol. -
-
Uniqush-Push
Uniqush is a free and open source software system which provides a unified push service for server side notification to apps on mobile devices. -
amqp
An AMQP 0-9-1 Go client maintained by the RabbitMQ team. Originally by @streadway: `streadway/amqp` -
Chanify
Chanify is a safe and simple notification tools. This repository is command line tools for Chanify. -
-
-
-
PingMe
PingMe is a CLI which provides the ability to send messages or alerts to multiple messaging platforms & email. -
emitter
Emits events in Go way, with wildcard, predicates, cancellation possibilities and many other good wins -
-
Bus
🔊Minimalist message bus implementation for internal communication with zero-allocation magic on Emit -
-
go-mq
Declare AMQP entities like queues, producers, and consumers in a declarative way. Can be used to work with RabbitMQ. -
Ratus
Ratus is a RESTful asynchronous task queue server. It translated concepts of distributed task queues into a set of resources that conform to REST principles and provides a consistent HTTP API for various backends. -
RapidMQ
RapidMQ is a pure, extremely productive, lightweight and reliable library for managing of the local messages queue -
-
-
InfluxDB - Power Real-Time Data Analytics at Scale
Do you think we are missing an alternative of gosd or a related project?
README
gosd
go-schedulable-dispatcher (gosd), is a library for scheduling when to dispatch a message to a channel.
Implementation
The implementation provides an ease-of-use API with both an ingress (ingest) channel and egress (dispatch) channel. Messages are ingested and processed into a heap based priority queue for dispatching. At most two separate goroutines are used, one for processing of messages from both the ingest channel and heap then the other as a timer. Order is not guaranteed by default when messages have the same scheduled time, but can be changed through the config. By guaranteeing order, performance will be slightly worse. If strict-ordering isn't critical to your application, it's recommended to keep the default setting.
Example
// create instance of dispatcher
dispatcher, err := gosd.NewDispatcher(&gosd.DispatcherConfig{
IngressChannelSize: 100,
DispatchChannelSize: 100,
MaxMessages: 100,
GuaranteeOrder: false,
})
checkErr(err)
// spawn process
go dispatcher.Start()
// schedule a message
dispatcher.IngressChannel() <- &gosd.ScheduledMessage{
At: time.Now().Add(1 * time.Second),
Message: "Hello World in 1 second!",
}
// wait for the message
msg := <-dispatcher.DispatchChannel()
// type assert
msgStr := msg.(string)
fmt.Println(msgStr)
// Hello World in 1 second!
// shutdown without deadline
dispatcher.Shutdown(context.Background(), false)
More examples under [examples](examples).
Benchmarking
Tested with Intel Core i7-8700K CPU @ 3.70GHz, DDR4 RAM and 1000 messages per iteration.
Benchmark_integration_unordered-12 142 8654906 ns/op
Benchmark_integration_unorderedSmallBuffer-12 147 9503403 ns/op
Benchmark_integration_unorderedSmallHeap-12 122 8860732 ns/op
Benchmark_integration_ordered-12 96 13354174 ns/op
Benchmark_integration_orderedSmallBuffer-12 121 10115702 ns/op
Benchmark_integration_orderedSmallHeap-12 129 10441857 ns/op
Benchmark_integration_orderedSameTime-12 99 12575961 ns/op