Versions in this module Expand all Collapse all v0 v0.1.5 Mar 2, 2021 Changes in this version + const ACF + const AWS + const GCF + const ICF + const OW + type CSVWriter struct + func (c *CSVWriter) Name() string + func (c *CSVWriter) Open(writer io.Writer, append bool) + func (c *CSVWriter) Write(traces []*Trace) error + type Platform string + type ResultCollector struct + func NewCollector() *ResultCollector + func (c *ResultCollector) Add(t *Trace) + func (c *ResultCollector) AddObserver(observer TraceObserver) + func (c *ResultCollector) Close() + func (c *ResultCollector) Decode(reader io.Reader) error + func (c *ResultCollector) GetTraces() []*Trace + func (c *ResultCollector) Write(writer TraceWriter) error + type TCPCollector struct + func NewTCPCollector(port, worker, maxConnections int) *TCPCollector + func (t *TCPCollector) Close() + func (t *TCPCollector) Listen() + type Trace struct + Args []string + BootTime *timestamp.Timestamp + ChildOf string + CodeVersion string + ConfigVersion string + ContainerID string + Cost float32 + EndTime *timestamp.Timestamp + Env map[string]string + ExecutionDelay *duration.Duration + ExecutionLatency *duration.Duration + HostID string + ID string + Logs map[uint64]string + Memory int32 + Platform string + Region string + RequestEndTime *timestamp.Timestamp + RequestResponseLatency *duration.Duration + RequestStartTime *timestamp.Timestamp + Runtime string + StartTime *timestamp.Timestamp + Status int32 + Tags map[string]string + Timestamp *timestamp.Timestamp + TransportDelay *duration.Duration + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewTrace() Trace + func (*Trace) Descriptor() ([]byte, []int) + func (*Trace) ProtoMessage() + func (m *Trace) GetArgs() []string + func (m *Trace) GetBootTime() *timestamp.Timestamp + func (m *Trace) GetChildOf() string + func (m *Trace) GetCodeVersion() string + func (m *Trace) GetConfigVersion() string + func (m *Trace) GetContainerID() string + func (m *Trace) GetCost() float32 + func (m *Trace) GetEndTime() *timestamp.Timestamp + func (m *Trace) GetEnv() map[string]string + func (m *Trace) GetExecutionDelay() *duration.Duration + func (m *Trace) GetExecutionLatency() *duration.Duration + func (m *Trace) GetHostID() string + func (m *Trace) GetID() string + func (m *Trace) GetLogs() map[uint64]string + func (m *Trace) GetMemory() int32 + func (m *Trace) GetPlatform() string + func (m *Trace) GetRegion() string + func (m *Trace) GetRequestEndTime() *timestamp.Timestamp + func (m *Trace) GetRequestResponseLatency() *duration.Duration + func (m *Trace) GetRequestStartTime() *timestamp.Timestamp + func (m *Trace) GetRuntime() string + func (m *Trace) GetStartTime() *timestamp.Timestamp + func (m *Trace) GetStatus() int32 + func (m *Trace) GetTags() map[string]string + func (m *Trace) GetTimestamp() *timestamp.Timestamp + func (m *Trace) GetTransportDelay() *duration.Duration + func (m *Trace) Reset() + func (m *Trace) String() string + func (m *Trace) XXX_DiscardUnknown() + func (m *Trace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Trace) XXX_Merge(src proto.Message) + func (m *Trace) XXX_Size() int + func (m *Trace) XXX_Unmarshal(b []byte) error + func (t *Trace) Merge(partial *Trace) error + type TraceObserver interface + Close func() + Observe func(trace *Trace) + type TraceWriter interface + Name func() string + Open func(io.Writer, bool) + Write func([]*Trace) error + func NewCSVWriter() TraceWriter