ringbuffer

Documentation

Index

• type RingBuffer
  • func New(size int, pool *bufferpool.BufferPool) *RingBuffer
  • func (r *RingBuffer) Close()
  • func (r *RingBuffer) Send(s *tracesegment.TraceSegment)
  • func (r *RingBuffer) TruncatedCount() uint64

Types

type RingBuffer

type RingBuffer struct {
	// Channel used to store trace segment received on X-Ray daemon address.
	Channel <-chan *tracesegment.TraceSegment

	// Boolean, set to true of buffer is empty
	Empty bool
	// contains filtered or unexported fields
}

RingBuffer is used to store trace segment received on X-Ray daemon address.

func New

func New(size int, pool *bufferpool.BufferPool) *RingBuffer

New returns new instance of RingBuffer configured with BufferPool pool.

func (*RingBuffer) Close

func (r *RingBuffer) Close()

Close closes the RingBuffer.

func (*RingBuffer) Send

func (r *RingBuffer) Send(s *tracesegment.TraceSegment)

Send sends trace segment s to trace segment channel.

func (*RingBuffer) TruncatedCount

func (r *RingBuffer) TruncatedCount() uint64

TruncatedCount returns trace segment truncated count.