tracings

type Config struct {
	Enable      bool            `json:"enable"`
	BatchSize   int             `json:"batchSize"`
	ChannelSize int             `json:"channelSize"`
	Reporter    json.RawMessage `json:"reporter"`
}

type Reporter interface {
	Construct(options ReporterOptions) (err error)
	Report(ctx context.Context, trace *Trace)
}

type ReporterOptions struct {
	Log    logs.Logger
	Config configures.Config
}

type Span struct {
	Id       string            `json:"id" avro:"id"`
	Endpoint string            `json:"endpoint" avro:"endpoint"`
	Fn       string            `json:"fn" avro:"fn"`
	Begin    time.Time         `json:"begin" avro:"begin"`
	Waited   time.Time         `json:"waited" avro:"waited"`
	End      time.Time         `json:"end" avro:"end"`
	Tags     map[string]string `json:"tags" avro:"tags"`
	Children []*Span           `json:"children" avro:"children"`
	// contains filtered or unexported fields
}

type Trace struct {
	Id   string
	Span *Span
}

type Tracer struct {
	Id   string
	Span *Span
	// contains filtered or unexported fields
}