Documentation
¶
Index ¶
Constants ¶
View Source
const ( // keep these in sync with attributes sent from the sdks AttrHatchetTaskRunID = "hatchet.step_run_id" // Task run external ID from SDK AttrHatchetWorkflowRunID = "hatchet.workflow_run_id" // Workflow run ID from SDK AttrHatchetRetryCount = "hatchet.retry_count" // Retry count from SDK )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OTelCollector ¶
type OTelCollector interface {
Export(ctx context.Context, req *collectortracev1.ExportTraceServiceRequest) (*collectortracev1.ExportTraceServiceResponse, error)
}
OTelCollector is the standard OTLP TraceService, which the engine serves for OTel SDK compatibility.
func NewOTelCollector ¶
func NewOTelCollector(fs ...OTelCollectorOpt) (OTelCollector, error)
type OTelCollectorOpt ¶
type OTelCollectorOpt func(*OTelCollectorOpts)
func WithAnalytics ¶ added in v0.83.13
func WithAnalytics(a analytics.Analytics) OTelCollectorOpt
func WithLogger ¶
func WithLogger(l *zerolog.Logger) OTelCollectorOpt
func WithMaxBatchSize ¶ added in v0.82.0
func WithMaxBatchSize(n int) OTelCollectorOpt
func WithO11yUsage ¶ added in v0.105.20
func WithO11yUsage(agg *o11yusage.Aggregator) OTelCollectorOpt
func WithRepository ¶
func WithRepository(r repository.Repository) OTelCollectorOpt
type OTelCollectorOpts ¶
type OTelCollectorOpts struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.