rb

Documentation

Index

• Variables
• func EncodedMsgOffset(recordOffset int32) int32
• func LengthOffset(recordOffset int32) int32
• func TypeOffset(recordOffset int32) int32
• type ManyToOne
  • func (buf *ManyToOne) ConsumerHeartbeatTime() int64
  • func (buf *ManyToOne) Init(buffer *atomic.Buffer) *ManyToOne
  • func (buf *ManyToOne) NextCorrelationID() int64
  • func (buf *ManyToOne) Write(msgTypeID int32, srcBuffer *atomic.Buffer, srcIndex int32, length int32) bool

Variables

var RecordDescriptor = struct {
	HeaderLength     int32
	RecordAlignment  int32
	PaddingMsgTypeID int32
	LengthOffset     int32
	TypeOffset       int32
}{
	util.SizeOfInt32 * 2,
	util.SizeOfInt32 * 2,
	-1,
	0,
	4,
}

Functions

func EncodedMsgOffset

func EncodedMsgOffset(recordOffset int32) int32

func LengthOffset

func LengthOffset(recordOffset int32) int32

func TypeOffset

func TypeOffset(recordOffset int32) int32

Types

type ManyToOne

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

func (*ManyToOne) ConsumerHeartbeatTime

func (buf *ManyToOne) ConsumerHeartbeatTime() int64

func (*ManyToOne) Init

func (buf *ManyToOne) Init(buffer *atomic.Buffer) *ManyToOne

Init is the main initialization method

func (*ManyToOne) NextCorrelationID

func (buf *ManyToOne) NextCorrelationID() int64

func (*ManyToOne) Write

func (buf *ManyToOne) Write(msgTypeID int32, srcBuffer *atomic.Buffer, srcIndex int32, length int32) bool

Write will attempt to append the bytes from srcBuffer to this ring buffer