Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + const FlushTimeout + type Daemon struct + ExecutionContext *serverlessLog.ExecutionContext + ExtraTags *serverlessLog.Tags + InvcWg *sync.WaitGroup + MetricAgent *metrics.ServerlessMetricAgent + TraceAgent *trace.ServerlessTraceAgent + func StartDaemon(addr string) *Daemon + func (d *Daemon) AutoSelectStrategy() flush.Strategy + func (d *Daemon) ComputeGlobalTags(configTags []string) + func (d *Daemon) FinishInvocation() + func (d *Daemon) InvocationInterval() time.Duration + func (d *Daemon) LogFlushStategy() string + func (d *Daemon) RestoreCurrentStateFromFile() error + func (d *Daemon) SaveCurrentExecutionContext() error + func (d *Daemon) SetClientReady(isReady bool) + func (d *Daemon) SetExecutionContext(arn string, requestID string) + func (d *Daemon) SetFlushStrategy(strategy flush.Strategy) + func (d *Daemon) SetStatsdServer(metricAgent *metrics.ServerlessMetricAgent) + func (d *Daemon) SetTraceAgent(traceAgent *trace.ServerlessTraceAgent) + func (d *Daemon) SetupLogCollectionHandler(route string, logsChan chan *logConfig.ChannelMessage, logsEnabled bool, ...) + func (d *Daemon) ShouldFlush(moment flush.Moment, t time.Time) bool + func (d *Daemon) StartInvocation() + func (d *Daemon) Stop() + func (d *Daemon) StoreInvocationTime(t time.Time) bool + func (d *Daemon) TriggerFlush(isLastFlushBeforeShutdown bool) + func (d *Daemon) UpdateStrategy() + func (d *Daemon) UseAdaptiveFlush(enabled bool) + func (d *Daemon) WaitForDaemon() + func (d *Daemon) WaitUntilClientReady(timeout time.Duration) bool + type Flush struct + func (f *Flush) ServeHTTP(w http.ResponseWriter, r *http.Request) + type Hello struct + func (h *Hello) ServeHTTP(w http.ResponseWriter, r *http.Request)
Go to main page