Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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.
Click to show internal directories.
Click to hide internal directories.