Registry /
messaging / smartystreets-prototypes-go-disruptor
Install & Compatibility
Where this runs
No compatibility data collected yet for this library.
Code
Verified usage
Verified import paths — ran on the pinned version, not inferred.
disruptor
✓ github.com/smartystreets-prototypes/go-disruptor
Sets up a disruptor ring buffer with a consumer.
package main
import (
"fmt"
"github.com/smartystreets-prototypes/go-disruptor"
)
func main() {
ringBuffer := disruptor.New(
disruptor.WithCapacity(1024),
disruptor.WithConsumerGroup(disruptor.NewConsumer(func(seq int64) {
fmt.Println(seq)
})),
)
ringBuffer.Start()
defer ringBuffer.Stop()
}
Debug
Known issues
No known issues recorded.
Upgrade
Version history
0.5.0latest on pkg.go.dev
Audit
Dependencies
No dependency data recorded yet.