broadcast

Documentation

Index

• Variables
• type CopyReceiver
  • func NewCopyReceiver(receiver *Receiver) *CopyReceiver
  • func (bcast *CopyReceiver) Receive(handler Handler) int
• type Handler
• type Receiver
  • func NewReceiver(buffer *atomic.Buffer) (*Receiver, error)
  • func (recv *Receiver) GetLappedCount() int64
  • func (recv *Receiver) Validate() bool

Variables

var BufferDescriptor = struct {
	tailIntentCounterOffset int32
	tailCounterOffset       int32
	latestCounterOffset     int32
	trailerLength           int32
}{
	0,
	util.SizeOfInt64,
	util.SizeOfInt64 * 2,
	util.CacheLineLength * 2,
}

Types

type CopyReceiver

type CopyReceiver struct {
	// contains filtered or unexported fields
}

func NewCopyReceiver

func NewCopyReceiver(receiver *Receiver) *CopyReceiver

func (*CopyReceiver) Receive

func (bcast *CopyReceiver) Receive(handler Handler) int

type Handler

type Handler func(int32, *atomic.Buffer, int32, int32)

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(buffer *atomic.Buffer) (*Receiver, error)

func (*Receiver) GetLappedCount

func (recv *Receiver) GetLappedCount() int64

func (*Receiver) Validate

func (recv *Receiver) Validate() bool