storage

Documentation

Index

• type Datasource
  • func (d *Datasource) SetDatabase(database string)
  • func (d *Datasource) SetTable(table string)
  • func (d *Datasource) String() string
• type IStorage
• type WorkerParams
• type WorkerTrace
  • func NewWorkerTrace(params WorkerParams) *WorkerTrace
  • func (w *WorkerTrace) SetParams(params WorkerParams)
  • func (w *WorkerTrace) Start()
  • func (w *WorkerTrace) Stop()

Types

type Datasource

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

func (*Datasource) SetDatabase

func (d *Datasource) SetDatabase(database string)

func (*Datasource) SetTable

func (d *Datasource) SetTable(table string)

func (*Datasource) String

func (d *Datasource) String() string

type IStorage

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

IStorage 日志库相关

type WorkerParams

type WorkerParams struct {
	Spec string

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

	DB *sql.DB // clickhouse instance
}

type WorkerTrace

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

WorkerTrace Used to otel jaeger json data analysis

func NewWorkerTrace

func NewWorkerTrace(params WorkerParams) *WorkerTrace

func (*WorkerTrace) SetParams

func (w *WorkerTrace) SetParams(params WorkerParams)

func (*WorkerTrace) Start

func (w *WorkerTrace) Start()

func (*WorkerTrace) Stop

func (w *WorkerTrace) Stop()