ipc

package

v0.0.0-...-c23f155 Latest Latest Go to latest Published: May 4, 2024 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type BlockStrategy interface {
	WaitFor(eqFn func() bool)
	Done()
}

func NewXCacheChannelBlockStrategy() BlockStrategy

func NewXCondBlockStrategy() BlockStrategy

func NewXCpuNoOpLoopBlockStrategy(cycles uint32) BlockStrategy

func NewXGoSchedBlockStrategy() BlockStrategy

func NewXOsYieldBlockStrategy() BlockStrategy

func NewXSleepBlockStrategy(sleepTime time.Duration) BlockStrategy

type Disruptor[T any] interface {
	Publisher[T]

	RegisterSubscriber(sub Subscriber[T]) error
	// contains filtered or unexported methods
}

func NewXDisruptor[T any](
	capacity uint64,
	strategy BlockStrategy,
	handler EventHandler[T],
) Disruptor[T]

type EventHandler[T any] func(event T) error // OnEvent

type Producer[T any] Publisher[T]

type Publisher[T any] interface {
	Publish(event T) (uint64, bool, error)
	PublishTimeout(event T, timeout time.Duration)
}

type Sequencer interface {
	Capacity() uint64
	GetReadCursor() queue.RingBufferCursor
	GetWriteCursor() queue.RingBufferCursor
}

func NewXSequencer(capacity uint64) Sequencer

type Subscriber[T any] interface {
	HandleEvent(event T) error
}