README
¶
ShiftLock integrations
These packages are optional adapters. They compile without queue/cloud SDKs so the core module stays dependency-light.
| Package | Role |
|---|---|
integration/kafka |
Bind consumer work to claim ownership |
integration/nats |
Queue-group singleton guard |
integration/rabbitmq |
Consumer ownership guard |
integration/sqs |
SQS poll loop ownership guard |
integration/scheduler |
Singleton ticker under ownership |
integration/httpserver |
HTTP middleware requiring ownership |
integration/grpcserver |
RPC ownership gate (no grpc dep) |
Pattern: wait for Lease, run work on lease.Context(), fence mutations with
lease.FencingToken().
Directories
¶
| Path | Synopsis |
|---|---|
|
Package grpcserver integrates ShiftLock ownership with gRPC unary interceptors.
|
Package grpcserver integrates ShiftLock ownership with gRPC unary interceptors. |
|
Package httpserver integrates ShiftLock ownership with HTTP leadership gates.
|
Package httpserver integrates ShiftLock ownership with HTTP leadership gates. |
|
Package kafka integrates ShiftLock ownership with Kafka consumer groups.
|
Package kafka integrates ShiftLock ownership with Kafka consumer groups. |
|
Package nats integrates ShiftLock ownership with NATS queue groups.
|
Package nats integrates ShiftLock ownership with NATS queue groups. |
|
Package rabbitmq integrates ShiftLock ownership with RabbitMQ consumers.
|
Package rabbitmq integrates ShiftLock ownership with RabbitMQ consumers. |
|
Package scheduler integrates ShiftLock ownership with singleton schedulers.
|
Package scheduler integrates ShiftLock ownership with singleton schedulers. |
|
Package sqs integrates ShiftLock ownership with AWS SQS consumers.
|
Package sqs integrates ShiftLock ownership with AWS SQS consumers. |
Click to show internal directories.
Click to hide internal directories.