counters

Documentation

Index

• Constants
• type Counter
• type MetaDataFlyweight
  • func MapFile(filename string) (*MetaDataFlyweight, *memmap.File, error)
  • func (m *MetaDataFlyweight) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight
• type Reader
  • func NewReader(values, metaData *atomic.Buffer) *Reader
  • func (reader *Reader) Scan(cb func(Counter))

Constants

const (
	CncFile                 = "cnc.dat"
	CurrentCncVersion int32 = 15
)

const COUNTER_LENGTH = util.CacheLineLength * 2

const FULL_LABEL_LENGTH = util.CacheLineLength * 6

const LABEL_OFFSET = util.CacheLineLength * 2

const METADATA_LENGTH = LABEL_OFFSET + FULL_LABEL_LENGTH

const RECORD_ALLOCATED int32 = 1

const RECORD_UNUSED int32 = 0

Types

type Counter

type Counter struct {
	Id     int32
	TypeId int32
	Value  int64
	Label  string
}

type MetaDataFlyweight

type MetaDataFlyweight struct {
	flyweight.FWBase

	CncVersion flyweight.Int32Field

	ToDriverBufLen flyweight.Int32Field
	ToClientBufLen flyweight.Int32Field

	ClientLivenessTo flyweight.Int64Field

	ToDriverBuf  flyweight.RawDataField
	ToClientsBuf flyweight.RawDataField
	MetaDataBuf  flyweight.RawDataField
	ValuesBuf    flyweight.RawDataField
	ErrorBuf     flyweight.RawDataField
	// contains filtered or unexported fields
}

*

• Description of the command and control file used between driver and clients.
• <p>
• File Layout
• <pre>
• +-----------------------------+
• | Meta Data |
• +-----------------------------+
• | to-driver Buffer |
• +-----------------------------+
• | to-clients Buffer |
• +-----------------------------+
• | Counters Metadata Buffer |
• +-----------------------------+
• | Counters Values Buffer |
• +-----------------------------+
• | Error Log |
• +-----------------------------+
• </pre>
• <p>
• Meta Data Layout (CnC Version 7)
• <pre>
• 0 1 2 3
• 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
• +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
• | Aeron CnC Version |
• +---------------------------------------------------------------+
• | to-driver buffer length |
• +---------------------------------------------------------------+
• | to-clients buffer length |
• +---------------------------------------------------------------+
• | Counters Metadata buffer length |
• +---------------------------------------------------------------+
• | Counters Values buffer length |
• +---------------------------------------------------------------+
• | Error Log buffer length |
• +---------------------------------------------------------------+
• | Client Liveness Timeout |
• | |
• +---------------------------------------------------------------+
• </pre>

func MapFile

func MapFile(filename string) (*MetaDataFlyweight, *memmap.File, error)

func (*MetaDataFlyweight) Wrap

func (m *MetaDataFlyweight) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

type Reader

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

func NewReader

func NewReader(values, metaData *atomic.Buffer) *Reader

func (*Reader) Scan

func (reader *Reader) Scan(cb func(Counter))