testconnection

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

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

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

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

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

type NotifierFn func(Job)