testconnection

Documentation

Index

• func GetSpanCountTopicName(opts ...TopicNameOption) string
• func NewDsTestConnectionNotify(dsTestListener *Listener, tracer trace.Tracer) *dsTestConnectionNotify
• func NewDsTestConnectionRequest(tracer trace.Tracer, newTraceDBFn tracedb.FactoryFunc, enabled bool) *dsTestConnectionRequest
• func PostSpanCountTopicName(opts ...TopicNameOption) string
• func ResetSpanCountTopicName(opts ...TopicNameOption) string
• 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 GetSpanCountOption
  • func WithTimeout(timeout time.Duration) GetSpanCountOption
• 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
• type OTLPConnectionTestRequest
• type OTLPConnectionTestResponse
• type OTLPConnectionTester
  • func NewOTLPConnectionTester(subscriptionManager subscription.Manager) *OTLPConnectionTester
  • func (t *OTLPConnectionTester) GetSpanCount(ctx context.Context, opts ...GetSpanCountOption) (OTLPConnectionTestResponse, error)
  • func (t *OTLPConnectionTester) ResetSpanCount(ctx context.Context)
• type TopicNameOption
  • func WithTenantID(tenantID string) TopicNameOption

Functions

func GetSpanCountTopicName

func GetSpanCountTopicName(opts ...TopicNameOption) string

func NewDsTestConnectionNotify

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

func NewDsTestConnectionRequest

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

func PostSpanCountTopicName

func PostSpanCountTopicName(opts ...TopicNameOption) string

func ResetSpanCountTopicName

func ResetSpanCountTopicName(opts ...TopicNameOption) string

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 GetSpanCountOption

type GetSpanCountOption func(*getSpanCountConfig)

func WithTimeout

func WithTimeout(timeout time.Duration) GetSpanCountOption

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)

type OTLPConnectionTestRequest

type OTLPConnectionTestRequest struct{}

type OTLPConnectionTestResponse

type OTLPConnectionTestResponse struct {
	TenantID string

	NumberSpans       int
	LastSpanTimestamp time.Time
}

type OTLPConnectionTester

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

func NewOTLPConnectionTester

func NewOTLPConnectionTester(subscriptionManager subscription.Manager) *OTLPConnectionTester

func (*OTLPConnectionTester) GetSpanCount

func (t *OTLPConnectionTester) GetSpanCount(ctx context.Context, opts ...GetSpanCountOption) (OTLPConnectionTestResponse, error)

func (*OTLPConnectionTester) ResetSpanCount

func (t *OTLPConnectionTester) ResetSpanCount(ctx context.Context)

type TopicNameOption

type TopicNameOption func(*topicNameConfig)

func WithTenantID

func WithTenantID(tenantID string) TopicNameOption