storageworker

Documentation

Index

• type Trace
  • func NewTrace(params WorkerParams) *Trace
  • func (w *Trace) SetParams(params WorkerParams)
  • func (w *Trace) Start()
  • func (w *Trace) Stop()
• type WorkerParams

Types

type Trace

type Trace struct {
	// contains filtered or unexported fields
}

Trace Used to otel jaeger json data analysis

func NewTrace

func NewTrace(params WorkerParams) *Trace

func (*Trace) SetParams

func (w *Trace) SetParams(params WorkerParams)

func (*Trace) Start

func (w *Trace) Start()

func (*Trace) Stop

func (w *Trace) Stop()

type WorkerParams

type WorkerParams struct {
	Spec string

	// for trace worker
	Source storage.Datasource // source database.table
	Target storage.Datasource // target database.table

	DB *sql.DB // clickhouse instance
}