- Extract a
worker.Worker
interface, and create aworker.DefaultWorker
implementation.
- Fix a critical issue in the worker package which prevented janitors from being able to clean up dead workers.
- Implement the
worker
package.
- Breaking Change: Allow the specification of a timeout parameter to several (previously) infinitely-blocking methods.
- Implement the
queue
package.
- Implement the
heartbeat
package.
- Breaking Change:
ConnectionParam
has moved from thepubsub
package to theconn
package. - Breaking Change:
pubsub.New
no longer takes aConnectionParam
, rather it takes a*redis.Pool
and aconn.ReconnectPolicy
.
- Breaking Change: New() now takes a ConnectionParam value rather than a pointer.
- Breaking Change: GetState() now returns a uint8 rather than a user-defined type, for greater compatibility with fsm. mumble mumble generics
- Fix potential data races on the internal subscription registry.
- Fix potential data race resulting in subscription duplication during multiple reconnections.
- Allow specification of connection timeout (deadlines).
- Allow specification of reconnection policies.
- Cause subscription, unsubscriptions, and teardowns to happen more quickly.
- Improve events system for increased flexibility.
- Significantly improve conciseness and speed.
- Breaking Change: New() now takes a *ConnectionParam struct as its first argument.
- Add password authentication options (from @janeczku).
- Fix failing tests in Go 1.3
- Prevent paniking when tearing down a client which was not set up.
Initial