Function NewTelemetryAPIJSONClient

internal/barista/observability/telemetry.twirp.go:146–177

NewTelemetryAPIJSONClient creates a JSON client that implements the TelemetryAPI interface. It communicates using JSON and can be configured with a custom HTTPClient.

(baseURL string, client HTTPClient, opts ...twirp.ClientOption)

// NewTelemetryAPIJSONClient creates a JSON client that implements the TelemetryAPI interface.
// It communicates using JSON and can be configured with a custom HTTPClient.
func NewTelemetryAPIJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) TelemetryAPI {
	if c, ok := client.(*http.Client); ok {
		client = withoutRedirects(c)
	}

	clientOpts := twirp.ClientOptions{}
	for _, o := range opts {
		o(&clientOpts)
	}

	// Using ReadOpt allows backwards and forwards compatibility with new options in the future
	literalURLs := false
	_ = clientOpts.ReadOpt("literalURLs", &literalURLs)
	var pathPrefix string
	if ok := clientOpts.ReadOpt("pathPrefix", &pathPrefix); !ok {
		pathPrefix = "/twirp" // default prefix
	}

	// Build method URLs: <baseURL>[<prefix>]/<package>.<Service>/<Method>
	serviceURL := sanitizeBaseURL(baseURL)
	serviceURL += baseServicePath(pathPrefix, "clientappsfe.observability.v1", "TelemetryAPI")
	urls := [1]string{
		serviceURL + "RecordEvents",
	}

	return &telemetryAPIJSONClient{
		client:      client,
		urls:        urls,
		interceptor: twirp.ChainInterceptors(clientOpts.Interceptors...),
		opts:        clientOpts,
	}
}

func (c *telemetryAPIJSONClient) RecordEvents(ctx context.Context, in *RecordEventsRequest) (*RecordEventsResponse, error) {
	ctx = ctxsetters.WithPackageName(ctx, "clientappsfe.observability.v1")