connection

Oct 26, 2023

Changes in this version

+ var ErrConnectionFailed = errors.New("could not connect to data store")

+ var ErrInvalidConfiguration = errors.New("invalid data store configuration")

+ var ErrTraceNotFound = errors.New("trace not found")

+ func CheckReachability(endpoint string, protocol model.Protocol) error

+ type DataStore interface

+ GetTraceByID func(context.Context, string) (traces.Trace, error)

+ GetTraceID func() trace.TraceID

+ type TestStep interface

+ TestConnection func(ctx context.Context) model.ConnectionTestStep

+ func ConnectivityStep(protocol model.Protocol, endpoints ...string) TestStep

+ func NewTestStep(f func(ctx context.Context) (string, error)) TestStep

+ func PortLinter(dataStoreName string, expectedPorts []string, endpoints ...string) TestStep

+ func TracePollingTestStep(ds DataStore) TestStep

+ type Tester struct

+ func NewTester(opts ...TesterOption) Tester

+ func (t *Tester) TestConnection(ctx context.Context) (res model.ConnectionResult)

+ type TesterOption func(*Tester)

+ func WithAuthenticationTest(step TestStep) TesterOption

+ func WithConnectivityTest(step TestStep) TesterOption

+ func WithPollingTest(step TestStep) TesterOption

+ func WithPortLintingTest(step TestStep) TesterOption