Documentation
¶
Index ¶
Constants ¶
View Source
const (
RingCapacity = 1024
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActionInvoker ¶
type HotPathExecutor ¶
type HotPathExecutor struct {
// contains filtered or unexported fields
}
func NewHotPathExecutor ¶
func NewHotPathExecutor(ring *LockFreeRingBuffer) *HotPathExecutor
func (*HotPathExecutor) ExecuteNode ¶
func (e *HotPathExecutor) ExecuteNode( ctx context.Context, nodeID [16]byte, invoker ActionInvoker, payloadInput []byte, ) (out any, err error)
type LockFreeRingBuffer ¶
type LockFreeRingBuffer struct {
// contains filtered or unexported fields
}
func NewLockFreeRingBuffer ¶
func NewLockFreeRingBuffer() *LockFreeRingBuffer
func (*LockFreeRingBuffer) Pop ¶
func (rb *LockFreeRingBuffer) Pop(dst *EventSlot) bool
Click to show internal directories.
Click to hide internal directories.