datasource

Documentation

Index

• type Callbacks
• type DataSource
  • func New(name string, cfg *datastore.MultiChannelClientConfig, callbacks Callbacks) DataSource
  • func NewGrpcClient(name string, config *datastore.GRPCClientSettings, callback GrpcCallback) DataSource
  • func NewHttpClient(name string, config *datastore.HttpClientConfig, callback HttpCallback) DataSource
• type GrpcCallback
• type GrpcClient
  • func (client *GrpcClient) Close() error
  • func (client *GrpcClient) Connect(ctx context.Context) error
  • func (client *GrpcClient) Endpoint() string
  • func (client *GrpcClient) GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)
  • func (client *GrpcClient) Ready() bool
  • func (client *GrpcClient) TestConnection(ctx context.Context) model.ConnectionTestStep
• type HttpCallback
• type HttpClient
  • func (client *HttpClient) Close() error
  • func (client *HttpClient) Connect(ctx context.Context) error
  • func (client *HttpClient) Endpoint() string
  • func (client *HttpClient) GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)
  • func (client *HttpClient) Ready() bool
  • func (client *HttpClient) Request(ctx context.Context, path, method, body string) (*http.Response, error)
  • func (client *HttpClient) TestConnection(ctx context.Context) model.ConnectionTestStep
• type SupportedDataSource

Types

type Callbacks

type Callbacks struct {
	GRPC GrpcCallback
	HTTP HttpCallback
}

type DataSource

type DataSource interface {
	Endpoint() string
	Connect(ctx context.Context) error
	Ready() bool
	GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)
	TestConnection(ctx context.Context) model.ConnectionTestStep
	Close() error
}

func New

func New(name string, cfg *datastore.MultiChannelClientConfig, callbacks Callbacks) DataSource

func NewGrpcClient

func NewGrpcClient(name string, config *datastore.GRPCClientSettings, callback GrpcCallback) DataSource

func NewHttpClient

func NewHttpClient(name string, config *datastore.HttpClientConfig, callback HttpCallback) DataSource

type GrpcCallback

type GrpcCallback func(ctx context.Context, traceID string, connection *grpc.ClientConn) (traces.Trace, error)

type GrpcClient

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

func (*GrpcClient) Close

func (client *GrpcClient) Close() error

func (*GrpcClient) Connect

func (client *GrpcClient) Connect(ctx context.Context) error

func (*GrpcClient) Endpoint

func (client *GrpcClient) Endpoint() string

func (*GrpcClient) GetTraceByID

func (client *GrpcClient) GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)

func (*GrpcClient) Ready

func (client *GrpcClient) Ready() bool

func (*GrpcClient) TestConnection

func (client *GrpcClient) TestConnection(ctx context.Context) model.ConnectionTestStep

type HttpCallback

type HttpCallback func(ctx context.Context, traceID string, client *HttpClient) (traces.Trace, error)

type HttpClient

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

func (*HttpClient) Close

func (client *HttpClient) Close() error

func (*HttpClient) Connect

func (client *HttpClient) Connect(ctx context.Context) error

func (*HttpClient) Endpoint

func (client *HttpClient) Endpoint() string

func (*HttpClient) GetTraceByID

func (client *HttpClient) GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)

func (*HttpClient) Ready

func (client *HttpClient) Ready() bool

func (*HttpClient) Request

func (client *HttpClient) Request(ctx context.Context, path, method, body string) (*http.Response, error)

func (*HttpClient) TestConnection

func (client *HttpClient) TestConnection(ctx context.Context) model.ConnectionTestStep

type SupportedDataSource

type SupportedDataSource string

var (
	GRPC SupportedDataSource = "grpc"
	HTTP SupportedDataSource = "http"
)