Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Processor ¶
type Processor struct { // Boolean channel, set to true when processor has no segments in priority and standard ring buffer. Done chan bool // contains filtered or unexported fields }
Processor buffers segments and send to X-Ray service.
func New ¶
func New(awsConfig *aws.Config, s *session.Session, segmentBatchProcessorCount int, std *ringbuffer.RingBuffer, pool *bufferpool.BufferPool, c *cfg.ParameterConfig) *Processor
New creates new instance of Processor.
func (*Processor) ProcessedCount ¶
ProcessedCount returns number of trace segment received.
func (*Processor) SetIdleTimer ¶
func (p *Processor) SetIdleTimer()
SetIdleTimer sets idle timer for the processor instance.
Click to show internal directories.
Click to hide internal directories.