client

type Client ¶

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

Client sends RPC calls to a remote service.

func New(opts Options) (*Client, error)

func (c *Client) RoundTrip(ctx context.Context, method ctypes.Method, req any, respObj any) error

type IHttpClient ¶

type IHttpClient interface {
	Do(req *http.Request) (*http.Response, error)
}

IHttpClient is a minimal HTTP client interface.

type OptOptionsSetter ¶

type OptOptionsSetter func(o *Options)

func WithHttpClient(opt IHttpClient) OptOptionsSetter

func WithLogger(opt *slog.Logger) OptOptionsSetter

func WithName(opt string) OptOptionsSetter

func WithPropagator(opt Propagator) OptOptionsSetter

func WithServiceToken(opt string) OptOptionsSetter

func WithServiceUrl(opt string) OptOptionsSetter

func WithTracerProvider(opt TracerProvider) OptOptionsSetter

type Options ¶

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

Options configures the client.

func NewOptions(
	options ...OptOptionsSetter,
) Options

func (o *Options) Validate() error

type Payload ¶

type Payload struct {
	ID      ctypes.ID `json:"id"`
	Version string    `json:"lrpc"` //nolint:tagliatelle
	Params  any       `json:"params"`
}

Payload is the request body sent by client.

type Propagator ¶

type Propagator = interface {
	Inject(ctx context.Context, headers http.Header)
}

Propagator injects trace headers into outgoing requests.

type Span ¶

type Span = internalobs.Span

Span represents an active trace span.

type Tracer ¶

type Tracer = internalobs.Tracer

Tracer starts spans.

type TracerProvider ¶

type TracerProvider = internalobs.TracerProvider

TracerProvider creates tracers.