call

Documentation

Overview

Package call helps support tracking latency and other metrics for calls.

Copyright 2022 Outreach Corporation. All Rights Reserved. Description: This file contains the call option definition used by trace.

Index

• type Info
  • func (info *Info) AddArgs(ctx context.Context, args ...logf.Marshaler)
  • func (info *Info) ApplyOpts(ctx context.Context, args ...logf.Marshaler)
  • func (info *Info) End(ctx context.Context)
  • func (info *Info) MarshalLog(addField func(key string, value interface{}))
  • func (info *Info) ReportLatency(ctx context.Context)
  • func (info *Info) SetStatus(ctx context.Context, err error)
  • func (info *Info) Start(ctx context.Context, name string)
• type Option
  • func (Option) MarshalLog(addField func(string, interface{}))
• type Tracker
  • func (t *Tracker) EndCall(ctx context.Context)
  • func (t *Tracker) Info(ctx context.Context) *Info
  • func (t *Tracker) StartCall(ctx context.Context, name string, args []logf.Marshaler) context.Context
• type Type

Types

type Info

type Info struct {
	Name string
	Type Type
	Kind metrics.CallKind
	Args []logf.Marshaler

	events.Times
	events.Durations

	ErrInfo *events.ErrorInfo
	// contains filtered or unexported fields
}

Info tracks information about an ongoing synchronous call.

func (*Info) AddArgs

func (info *Info) AddArgs(ctx context.Context, args ...logf.Marshaler)

AddArgs appends the provided logf.Marshalers to the Args slice.

func (*Info) ApplyOpts

func (info *Info) ApplyOpts(ctx context.Context, args ...logf.Marshaler)

ApplyOpts applies call Option functions to the call Info object. even if args are logf.Marshalers, but there might be some call.Options this is done intentionally to preserve compatibility of StartCall API and extend it with new functionality

func (*Info) End

func (info *Info) End(ctx context.Context)

End records the finished time and updates durations.

func (*Info) MarshalLog

func (info *Info) MarshalLog(addField func(key string, value interface{}))

MarshalLog addes log.Marshaler support, logging most of the fields.

func (*Info) ReportLatency

func (info *Info) ReportLatency(ctx context.Context)

ReportLatency reports the call latency via the metrics package based on the call Kind. If the Kind is not one of HTTP, GRPC or Outbound, it does nothing.

func (*Info) SetStatus

func (info *Info) SetStatus(ctx context.Context, err error)

SetStatus updates the ErrInfo field based on the error.

func (*Info) Start

func (info *Info) Start(ctx context.Context, name string)

Start initializes info with the start time and some name.

type Option

type Option func(c *Info)

Option defines the call Info adjustment function

func (Option) MarshalLog

func (Option) MarshalLog(addField func(string, interface{}))

MarshalLog is defined for being compliant with trace.StartCall contract

type Tracker

type Tracker struct {
}

Tracker helps manage a call info via the context.

func (*Tracker) EndCall

func (t *Tracker) EndCall(ctx context.Context)

EndCall is meant to be called in a defer abc.EndCall(ctx) pattern. It checks if there is a panic. If so, it uses that to update the current call Info object. It calls info.End(ctx) before returning. It rethrows any panic.

func (*Tracker) Info

func (t *Tracker) Info(ctx context.Context) *Info

Info returns the call Info object stashed in the context.

func (*Tracker) StartCall

func (t *Tracker) StartCall(ctx context.Context, name string, args []logf.Marshaler) context.Context

StartCall creates a new call Info object and returns a new context where tracker.Info(ctx) will return the newly setup call Info object.

type Type

type Type string

Type tracks the call type.

const (
	// TypeHTTP is a constant that denotes the call type being an HTTP
	// request.
	TypeHTTP Type = "http"

	// TypeGRPC is a constant that denotes the call type being a gRPC
	// request.
	TypeGRPC Type = "grpc"

	// TypeOutbound is a constant that denotes the call type being an
	// outbound request.
	TypeOutbound Type = "outbound"
)