jsonrpc2/defs.go

// Copyright 2021 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package jsonrpc2

import (
	"golang.org/x/exp/event"
)

func Method(v string) event.Label       { return event.String("method", v) }
func RPCID(v string) event.Label        { return event.String("id", v) }
func RPCDirection(v string) event.Label { return event.String("direction", v) }
func StatusCode(v string) event.Label   { return event.String("status.code", v) }

var (
	Started       = event.NewCounter("started", "Count of started RPCs.")
	Finished      = event.NewCounter("finished", "Count of finished RPCs (includes error).")
	ReceivedBytes = event.NewIntDistribution("received_bytes", "Bytes received.") //, unit.Bytes)
	SentBytes     = event.NewIntDistribution("sent_bytes", "Bytes sent.")         //, unit.Bytes)
	Latency       = event.NewDuration("latency", "Elapsed time of an RPC.")       //, unit.Milliseconds)
)

const (
	Inbound  = "in"
	Outbound = "out"
)