testconnection

Documentation

Index

• func NewDsTestConnectionNotify(dsTestListener *Listener, tracer trace.Tracer) *dsTestConnectionNotify
• func NewDsTestConnectionRequest(tracer trace.Tracer, newTraceDBFn tracedb.FactoryFunc, enabled bool) *dsTestConnectionRequest
• type Configurer
  • func NewConfigurer(meter metric.Meter) *Configurer[Job]
  • func (c *Configurer[Job]) Configure(queue *pipeline.Queue[Job])
• type DataStoreTestPipeline
  • func NewDataStoreTestPipeline(pipeline *pipeline.Pipeline[Job], listener DsTestListener) *DataStoreTestPipeline
  • func (p *DataStoreTestPipeline) NewJob(ctx context.Context, datastore datastore.DataStore) Job
  • func (p *DataStoreTestPipeline) Run(ctx context.Context, job Job)
  • func (p *DataStoreTestPipeline) Subscribe(jobID string, notifier NotifierFn) error
  • func (p *DataStoreTestPipeline) Unsubscribe(jobID string)
• type DsTestListener
• type Job
• type Listener
  • func NewListener() *Listener
  • func (m *Listener) Notify(job Job)
  • func (m *Listener) Subscribe(jobID string, notifier NotifierFn) error
  • func (m *Listener) Unsubscribe(jobID string)
• type NotifierFn

Functions

func NewDsTestConnectionNotify

func NewDsTestConnectionNotify(
	dsTestListener *Listener,
	tracer trace.Tracer,
) *dsTestConnectionNotify

func NewDsTestConnectionRequest

func NewDsTestConnectionRequest(
	tracer trace.Tracer,
	newTraceDBFn tracedb.FactoryFunc,
	enabled bool,
) *dsTestConnectionRequest

Types

type Configurer

type Configurer[T any] struct {
	// contains filtered or unexported fields
}

func NewConfigurer

func NewConfigurer(meter metric.Meter) *Configurer[Job]

func (*Configurer[Job]) Configure

func (c *Configurer[Job]) Configure(queue *pipeline.Queue[Job])

type DataStoreTestPipeline

type DataStoreTestPipeline struct {
	*pipeline.Pipeline[Job]
	// contains filtered or unexported fields
}

func NewDataStoreTestPipeline

func NewDataStoreTestPipeline(
	pipeline *pipeline.Pipeline[Job],
	listener DsTestListener,
) *DataStoreTestPipeline

func (*DataStoreTestPipeline) NewJob

func (p *DataStoreTestPipeline) NewJob(ctx context.Context, datastore datastore.DataStore) Job

func (*DataStoreTestPipeline) Run

func (p *DataStoreTestPipeline) Run(ctx context.Context, job Job)

func (*DataStoreTestPipeline) Subscribe

func (p *DataStoreTestPipeline) Subscribe(jobID string, notifier NotifierFn) error

func (*DataStoreTestPipeline) Unsubscribe

func (p *DataStoreTestPipeline) Unsubscribe(jobID string)

type DsTestListener

type DsTestListener interface {
	Notify(Job)
	Subscribe(jobID string, notifier NotifierFn) error
	Unsubscribe(jobID string)
}

type Job

type Job struct {
	TenantID   string                 `json:"tenantId"`
	ID         string                 `json:"id"`
	DataStore  datastore.DataStore    `json:"datastore"`
	TestResult model.ConnectionResult `json:"testResult"`
}

type Listener

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

func NewListener

func NewListener() *Listener

func (*Listener) Notify

func (m *Listener) Notify(job Job)

func (*Listener) Subscribe

func (m *Listener) Subscribe(jobID string, notifier NotifierFn) error

func (*Listener) Unsubscribe

func (m *Listener) Unsubscribe(jobID string)

type NotifierFn

type NotifierFn func(Job)