accumulator

Apr 10, 2025

Changes in this version

+ var ErrNoData = errors.New("no data")

Jul 24, 2024

Changes in this version

type Batch

+ func (b *Batch) OnPlatformStart(reqID string)

+ func (b *Batch) PlatformStartReqID() string

Sep 11, 2023

Changes in this version

type APMData

+ AgentInfo string

May 3, 2023

Changes in this version

type Invocation

+ func (inc *Invocation) MaybeCreateProxyTxn(status string, time time.Time) ([]byte, error)

Feb 22, 2023

Changes in this version

+ var ErrBatchFull = errors.New("batch is full")

+ var ErrInvalidEncoding = errors.New("encoded data not supported")

+ var ErrMetadataUnavailable = errors.New("metadata is not yet available")

+ func GetUncompressedBytes(rawBytes []byte, encodingType string) ([]byte, error)

+ func ProcessMetadata(data APMData) ([]byte, error)

+ type APMData struct

+ ContentEncoding string

+ Data []byte

+ type Batch struct

+ func NewBatch(maxSize int, maxAge time.Duration) *Batch

+ func (b *Batch) AddAgentData(apmData APMData) error

+ func (b *Batch) AddLambdaData(d []byte) error

+ func (b *Batch) Count() int

+ func (b *Batch) OnAgentInit(reqID, txnID string, payload []byte) error

+ func (b *Batch) OnLambdaLogRuntimeDone(reqID, status string, time time.Time) error

+ func (b *Batch) OnPlatformReport(reqID string) (string, int64, time.Time, error)

+ func (b *Batch) OnShutdown(status string) error

+ func (b *Batch) RegisterInvocation(reqID, functionARN string, deadlineMs int64, timestamp time.Time)

+ func (b *Batch) Reset()

+ func (b *Batch) ShouldShip() bool

+ func (b *Batch) Size() int

+ func (b *Batch) ToAPMData() APMData

+ type Invocation struct

+ AgentPayload []byte

+ DeadlineMs int64

+ Finalized bool

+ FunctionARN string

+ RequestID string

+ Timestamp time.Time

+ TransactionID string

+ TransactionObserved bool

+ func (inc *Invocation) CreateProxyTxn(status string, time time.Time) ([]byte, error)

+ func (inc *Invocation) NeedProxyTransaction() bool