1
0
mirror of https://github.com/open-telemetry/opentelemetry-go.git synced 2026-06-03 18:35:08 +02:00
Files
renovate[bot] cf2a4a180f chore(deps): update module mvdan.cc/gofumpt to v0.10.0 (#8304)
This PR contains the following updates:

| Package | Change |
[Age](https://docs.renovatebot.com/merge-confidence/) |
[Confidence](https://docs.renovatebot.com/merge-confidence/) |
|---|---|---|---|
| [mvdan.cc/gofumpt](https://redirect.github.com/mvdan/gofumpt) |
`v0.9.2` → `v0.10.0` |
![age](https://developer.mend.io/api/mc/badges/age/go/mvdan.cc%2fgofumpt/v0.10.0?slim=true)
|
![confidence](https://developer.mend.io/api/mc/badges/confidence/go/mvdan.cc%2fgofumpt/v0.9.2/v0.10.0?slim=true)
|

---

### Release Notes

<details>
<summary>mvdan/gofumpt (mvdan.cc/gofumpt)</summary>

###
[`v0.10.0`](https://redirect.github.com/mvdan/gofumpt/blob/HEAD/CHANGELOG.md#v0100---2026-05-04)

[Compare
Source](https://redirect.github.com/mvdan/gofumpt/compare/v0.9.2...v0.10.0)

This release is based on Go 1.26's gofmt, and requires Go 1.25 or later.

A new rule is introduced to drop unnecessary parentheses around
expressions
where the inner expression is unambiguous on its own, such as `f((3))`.
Parentheses are kept where they are useful, such as on binary
expressions. See
[#&#8203;44](https://redirect.github.com/mvdan/gofumpt/issues/44).

A new rule is introduced to require multi-line function calls to match
the opening and closing parenthesis in terms of the use of newlines. See
[#&#8203;74](https://redirect.github.com/mvdan/gofumpt/issues/74).

The `-extra` flag now accepts a comma-separated list of rule names to
enable
individual extra rules, rather than enabling all of them at once. See
[#&#8203;339](https://redirect.github.com/mvdan/gofumpt/issues/339).

The following changes are included as well:

- Avoid crashing on `go.mod` files without a `module` directive -
[#&#8203;350](https://redirect.github.com/mvdan/gofumpt/issues/350)
- Avoid failing when an ignored directory cannot be read -
[#&#8203;351](https://redirect.github.com/mvdan/gofumpt/issues/351)
- Avoid prefixing more kinds of commented-out Go code with spaces -
[#&#8203;230](https://redirect.github.com/mvdan/gofumpt/issues/230)
- Avoid prefixing a shebang comment with a space -
[#&#8203;237](https://redirect.github.com/mvdan/gofumpt/issues/237)
- Narrow the newlines on assignments rule to ignore complex cases -
[#&#8203;354](https://redirect.github.com/mvdan/gofumpt/issues/354)
- Fix three bugs which caused a second gofumpt run to make changes -
[#&#8203;132](https://redirect.github.com/mvdan/gofumpt/issues/132),
[#&#8203;345](https://redirect.github.com/mvdan/gofumpt/issues/345)

</details>

---

### Configuration

📅 **Schedule**: (UTC)

- Branch creation
  - At any time (no schedule defined)
- Automerge
  - At any time (no schedule defined)

🚦 **Automerge**: Disabled by config. Please merge this manually once you
are satisfied.

♻ **Rebasing**: Whenever PR is behind base branch, or you tick the
rebase/retry checkbox.

🔕 **Ignore**: Close this PR and you won't be reminded about this update
again.

---

- [ ] <!-- rebase-check -->If you want to rebase/retry this PR, check
this box

---

This PR was generated by [Mend Renovate](https://mend.io/renovate/).
View the [repository job
log](https://developer.mend.io/github/open-telemetry/opentelemetry-go).

<!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiI0My4xNTkuMiIsInVwZGF0ZWRJblZlciI6IjQzLjE1OS4yIiwidGFyZ2V0QnJhbmNoIjoibWFpbiIsImxhYmVscyI6WyJTa2lwIENoYW5nZWxvZyIsImRlcGVuZGVuY2llcyJdfQ==-->

---------

Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
Co-authored-by: Tyler Yahn <codingalias@gmail.com>
2026-05-08 12:50:12 -07:00

1805 lines
49 KiB
Go

// Code generated from semantic convention specification. DO NOT EDIT.
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
// Package nfsconv provides types and functionality for OpenTelemetry semantic
// conventions in the "nfs" namespace.
package nfsconv
import (
"context"
"sync"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
"go.opentelemetry.io/otel/metric/noop"
)
var (
addOptPool = &sync.Pool{New: func() any { return &[]metric.AddOption{} }}
recOptPool = &sync.Pool{New: func() any { return &[]metric.RecordOption{} }}
)
// ErrorTypeAttr is an attribute conforming to the error.type semantic
// conventions. It represents the describes a class of error the operation ended
// with.
type ErrorTypeAttr string
// ErrorTypeOther is a fallback error value to be used when the instrumentation
// doesn't define a custom value.
var ErrorTypeOther ErrorTypeAttr = "_OTHER"
// NetworkIODirectionAttr is an attribute conforming to the network.io.direction
// semantic conventions. It represents the network IO operation direction.
type NetworkIODirectionAttr string
var (
// NetworkIODirectionTransmit is the standardized value "transmit" of
// NetworkIODirectionAttr.
NetworkIODirectionTransmit NetworkIODirectionAttr = "transmit"
// NetworkIODirectionReceive is the standardized value "receive" of
// NetworkIODirectionAttr.
NetworkIODirectionReceive NetworkIODirectionAttr = "receive"
)
// NetworkTransportAttr is an attribute conforming to the network.transport
// semantic conventions. It represents the [OSI transport layer] or
// [inter-process communication method].
//
// [OSI transport layer]: https://wikipedia.org/wiki/Transport_layer
// [inter-process communication method]: https://wikipedia.org/wiki/Inter-process_communication
type NetworkTransportAttr string
var (
// NetworkTransportTCP is the TCP.
NetworkTransportTCP NetworkTransportAttr = "tcp"
// NetworkTransportUDP is the UDP.
NetworkTransportUDP NetworkTransportAttr = "udp"
// NetworkTransportPipe is the named or anonymous pipe.
NetworkTransportPipe NetworkTransportAttr = "pipe"
// NetworkTransportUnix is the unix domain socket.
NetworkTransportUnix NetworkTransportAttr = "unix"
// NetworkTransportQUIC is the QUIC.
NetworkTransportQUIC NetworkTransportAttr = "quic"
)
// ClientNetCount is an instrument used to record metric values conforming to the
// "nfs.client.net.count" semantic conventions. It represents the reports the
// count of kernel NFS client TCP segments and UDP datagrams handled.
type ClientNetCount struct {
metric.Int64Counter
}
var newClientNetCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client TCP segments and UDP datagrams handled."),
metric.WithUnit("{record}"),
}
// NewClientNetCount returns a new ClientNetCount instrument.
func NewClientNetCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientNetCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientNetCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientNetCountOpts
} else {
opt = append(opt, newClientNetCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.net.count",
opt...,
)
if err != nil {
return ClientNetCount{noop.Int64Counter{}}, err
}
return ClientNetCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientNetCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientNetCount) Name() string {
return "nfs.client.net.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientNetCount) Unit() string {
return "{record}"
}
// Description returns the semantic convention description of the instrument
func (ClientNetCount) Description() string {
return "Reports the count of kernel NFS client TCP segments and UDP datagrams handled."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.netudpcnt and
// svc_stat.nettcpcnt
func (m ClientNetCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.netudpcnt and
// svc_stat.nettcpcnt
func (m ClientNetCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrNetworkTransport returns an optional attribute for the "network.transport"
// semantic convention. It represents the [OSI transport layer] or
// [inter-process communication method].
//
// [OSI transport layer]: https://wikipedia.org/wiki/Transport_layer
// [inter-process communication method]: https://wikipedia.org/wiki/Inter-process_communication
func (ClientNetCount) AttrNetworkTransport(val NetworkTransportAttr) attribute.KeyValue {
return attribute.String("network.transport", string(val))
}
// ClientNetTCPConnectionAccepted is an instrument used to record metric values
// conforming to the "nfs.client.net.tcp.connection.accepted" semantic
// conventions. It represents the reports the count of kernel NFS client TCP
// connections accepted.
type ClientNetTCPConnectionAccepted struct {
metric.Int64Counter
}
var newClientNetTCPConnectionAcceptedOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client TCP connections accepted."),
metric.WithUnit("{connection}"),
}
// NewClientNetTCPConnectionAccepted returns a new ClientNetTCPConnectionAccepted
// instrument.
func NewClientNetTCPConnectionAccepted(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientNetTCPConnectionAccepted, error) {
// Check if the meter is nil.
if m == nil {
return ClientNetTCPConnectionAccepted{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientNetTCPConnectionAcceptedOpts
} else {
opt = append(opt, newClientNetTCPConnectionAcceptedOpts...)
}
i, err := m.Int64Counter(
"nfs.client.net.tcp.connection.accepted",
opt...,
)
if err != nil {
return ClientNetTCPConnectionAccepted{noop.Int64Counter{}}, err
}
return ClientNetTCPConnectionAccepted{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientNetTCPConnectionAccepted) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientNetTCPConnectionAccepted) Name() string {
return "nfs.client.net.tcp.connection.accepted"
}
// Unit returns the semantic convention unit of the instrument
func (ClientNetTCPConnectionAccepted) Unit() string {
return "{connection}"
}
// Description returns the semantic convention description of the instrument
func (ClientNetTCPConnectionAccepted) Description() string {
return "Reports the count of kernel NFS client TCP connections accepted."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpconn
func (m ClientNetTCPConnectionAccepted) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpconn
func (m ClientNetTCPConnectionAccepted) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ClientOperationCount is an instrument used to record metric values conforming
// to the "nfs.client.operation.count" semantic conventions. It represents the
// reports the count of kernel NFSv4+ client operations.
type ClientOperationCount struct {
metric.Int64Counter
}
var newClientOperationCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFSv4+ client operations."),
metric.WithUnit("{operation}"),
}
// NewClientOperationCount returns a new ClientOperationCount instrument.
func NewClientOperationCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientOperationCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientOperationCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientOperationCountOpts
} else {
opt = append(opt, newClientOperationCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.operation.count",
opt...,
)
if err != nil {
return ClientOperationCount{noop.Int64Counter{}}, err
}
return ClientOperationCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientOperationCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientOperationCount) Name() string {
return "nfs.client.operation.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientOperationCount) Unit() string {
return "{operation}"
}
// Description returns the semantic convention description of the instrument
func (ClientOperationCount) Description() string {
return "Reports the count of kernel NFSv4+ client operations."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
func (m ClientOperationCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
func (m ClientOperationCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrOperationName returns an optional attribute for the "nfs.operation.name"
// semantic convention. It represents the NFSv4+ operation name.
func (ClientOperationCount) AttrOperationName(val string) attribute.KeyValue {
return attribute.String("nfs.operation.name", val)
}
// AttrOncRPCVersion returns an optional attribute for the "onc_rpc.version"
// semantic convention. It represents the ONC/Sun RPC program version.
func (ClientOperationCount) AttrOncRPCVersion(val int) attribute.KeyValue {
return attribute.Int("onc_rpc.version", val)
}
// ClientProcedureCount is an instrument used to record metric values conforming
// to the "nfs.client.procedure.count" semantic conventions. It represents the
// reports the count of kernel NFS client procedures.
type ClientProcedureCount struct {
metric.Int64Counter
}
var newClientProcedureCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client procedures."),
metric.WithUnit("{procedure}"),
}
// NewClientProcedureCount returns a new ClientProcedureCount instrument.
func NewClientProcedureCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientProcedureCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientProcedureCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientProcedureCountOpts
} else {
opt = append(opt, newClientProcedureCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.procedure.count",
opt...,
)
if err != nil {
return ClientProcedureCount{noop.Int64Counter{}}, err
}
return ClientProcedureCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientProcedureCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientProcedureCount) Name() string {
return "nfs.client.procedure.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientProcedureCount) Unit() string {
return "{procedure}"
}
// Description returns the semantic convention description of the instrument
func (ClientProcedureCount) Description() string {
return "Reports the count of kernel NFS client procedures."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
func (m ClientProcedureCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
func (m ClientProcedureCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrOncRPCProcedureName returns an optional attribute for the
// "onc_rpc.procedure.name" semantic convention. It represents the ONC/Sun RPC
// procedure name.
func (ClientProcedureCount) AttrOncRPCProcedureName(val string) attribute.KeyValue {
return attribute.String("onc_rpc.procedure.name", val)
}
// AttrOncRPCVersion returns an optional attribute for the "onc_rpc.version"
// semantic convention. It represents the ONC/Sun RPC program version.
func (ClientProcedureCount) AttrOncRPCVersion(val int) attribute.KeyValue {
return attribute.Int("onc_rpc.version", val)
}
// ClientRPCAuthrefreshCount is an instrument used to record metric values
// conforming to the "nfs.client.rpc.authrefresh.count" semantic conventions. It
// represents the reports the count of kernel NFS client RPC authentication
// refreshes.
type ClientRPCAuthrefreshCount struct {
metric.Int64Counter
}
var newClientRPCAuthrefreshCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client RPC authentication refreshes."),
metric.WithUnit("{authrefresh}"),
}
// NewClientRPCAuthrefreshCount returns a new ClientRPCAuthrefreshCount
// instrument.
func NewClientRPCAuthrefreshCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientRPCAuthrefreshCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientRPCAuthrefreshCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientRPCAuthrefreshCountOpts
} else {
opt = append(opt, newClientRPCAuthrefreshCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.rpc.authrefresh.count",
opt...,
)
if err != nil {
return ClientRPCAuthrefreshCount{noop.Int64Counter{}}, err
}
return ClientRPCAuthrefreshCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientRPCAuthrefreshCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientRPCAuthrefreshCount) Name() string {
return "nfs.client.rpc.authrefresh.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientRPCAuthrefreshCount) Unit() string {
return "{authrefresh}"
}
// Description returns the semantic convention description of the instrument
func (ClientRPCAuthrefreshCount) Description() string {
return "Reports the count of kernel NFS client RPC authentication refreshes."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpcauthrefresh
func (m ClientRPCAuthrefreshCount) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpcauthrefresh
func (m ClientRPCAuthrefreshCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ClientRPCCount is an instrument used to record metric values conforming to the
// "nfs.client.rpc.count" semantic conventions. It represents the reports the
// count of kernel NFS client RPCs sent, regardless of whether they're
// accepted/rejected by the server.
type ClientRPCCount struct {
metric.Int64Counter
}
var newClientRPCCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client RPCs sent, regardless of whether they're accepted/rejected by the server."),
metric.WithUnit("{request}"),
}
// NewClientRPCCount returns a new ClientRPCCount instrument.
func NewClientRPCCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientRPCCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientRPCCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientRPCCountOpts
} else {
opt = append(opt, newClientRPCCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.rpc.count",
opt...,
)
if err != nil {
return ClientRPCCount{noop.Int64Counter{}}, err
}
return ClientRPCCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientRPCCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientRPCCount) Name() string {
return "nfs.client.rpc.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientRPCCount) Unit() string {
return "{request}"
}
// Description returns the semantic convention description of the instrument
func (ClientRPCCount) Description() string {
return "Reports the count of kernel NFS client RPCs sent, regardless of whether they're accepted/rejected by the server."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpccnt
func (m ClientRPCCount) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpccnt
func (m ClientRPCCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ClientRPCRetransmitCount is an instrument used to record metric values
// conforming to the "nfs.client.rpc.retransmit.count" semantic conventions. It
// represents the reports the count of kernel NFS client RPC retransmits.
type ClientRPCRetransmitCount struct {
metric.Int64Counter
}
var newClientRPCRetransmitCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS client RPC retransmits."),
metric.WithUnit("{retransmit}"),
}
// NewClientRPCRetransmitCount returns a new ClientRPCRetransmitCount instrument.
func NewClientRPCRetransmitCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ClientRPCRetransmitCount, error) {
// Check if the meter is nil.
if m == nil {
return ClientRPCRetransmitCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newClientRPCRetransmitCountOpts
} else {
opt = append(opt, newClientRPCRetransmitCountOpts...)
}
i, err := m.Int64Counter(
"nfs.client.rpc.retransmit.count",
opt...,
)
if err != nil {
return ClientRPCRetransmitCount{noop.Int64Counter{}}, err
}
return ClientRPCRetransmitCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ClientRPCRetransmitCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ClientRPCRetransmitCount) Name() string {
return "nfs.client.rpc.retransmit.count"
}
// Unit returns the semantic convention unit of the instrument
func (ClientRPCRetransmitCount) Unit() string {
return "{retransmit}"
}
// Description returns the semantic convention description of the instrument
func (ClientRPCRetransmitCount) Description() string {
return "Reports the count of kernel NFS client RPC retransmits."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpcretrans
func (m ClientRPCRetransmitCount) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpcretrans
func (m ClientRPCRetransmitCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ServerFhStaleCount is an instrument used to record metric values conforming to
// the "nfs.server.fh.stale.count" semantic conventions. It represents the
// reports the count of kernel NFS server stale file handles.
type ServerFhStaleCount struct {
metric.Int64Counter
}
var newServerFhStaleCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server stale file handles."),
metric.WithUnit("{fh}"),
}
// NewServerFhStaleCount returns a new ServerFhStaleCount instrument.
func NewServerFhStaleCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerFhStaleCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerFhStaleCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerFhStaleCountOpts
} else {
opt = append(opt, newServerFhStaleCountOpts...)
}
i, err := m.Int64Counter(
"nfs.server.fh.stale.count",
opt...,
)
if err != nil {
return ServerFhStaleCount{noop.Int64Counter{}}, err
}
return ServerFhStaleCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerFhStaleCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerFhStaleCount) Name() string {
return "nfs.server.fh.stale.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerFhStaleCount) Unit() string {
return "{fh}"
}
// Description returns the semantic convention description of the instrument
func (ServerFhStaleCount) Description() string {
return "Reports the count of kernel NFS server stale file handles."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel NFSD_STATS_FH_STALE counter
// in the nfsd_net struct
func (m ServerFhStaleCount) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel NFSD_STATS_FH_STALE counter
// in the nfsd_net struct
func (m ServerFhStaleCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ServerIO is an instrument used to record metric values conforming to the
// "nfs.server.io" semantic conventions. It represents the reports the count of
// kernel NFS server bytes returned to receive and transmit (read and write)
// requests.
type ServerIO struct {
metric.Int64Counter
}
var newServerIOOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server bytes returned to receive and transmit (read and write) requests."),
metric.WithUnit("By"),
}
// NewServerIO returns a new ServerIO instrument.
func NewServerIO(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerIO, error) {
// Check if the meter is nil.
if m == nil {
return ServerIO{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerIOOpts
} else {
opt = append(opt, newServerIOOpts...)
}
i, err := m.Int64Counter(
"nfs.server.io",
opt...,
)
if err != nil {
return ServerIO{noop.Int64Counter{}}, err
}
return ServerIO{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerIO) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerIO) Name() string {
return "nfs.server.io"
}
// Unit returns the semantic convention unit of the instrument
func (ServerIO) Unit() string {
return "By"
}
// Description returns the semantic convention description of the instrument
func (ServerIO) Description() string {
return "Reports the count of kernel NFS server bytes returned to receive and transmit (read and write) requests."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
//
// Linux: this metric is taken from the Linux kernel NFSD_STATS_IO_READ and
// NFSD_STATS_IO_WRITE counters in the nfsd_net struct
func (m ServerIO) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel NFSD_STATS_IO_READ and
// NFSD_STATS_IO_WRITE counters in the nfsd_net struct
func (m ServerIO) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrNetworkIODirection returns an optional attribute for the
// "network.io.direction" semantic convention. It represents the network IO
// operation direction.
func (ServerIO) AttrNetworkIODirection(val NetworkIODirectionAttr) attribute.KeyValue {
return attribute.String("network.io.direction", string(val))
}
// ServerNetCount is an instrument used to record metric values conforming to the
// "nfs.server.net.count" semantic conventions. It represents the reports the
// count of kernel NFS server TCP segments and UDP datagrams handled.
type ServerNetCount struct {
metric.Int64Counter
}
var newServerNetCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server TCP segments and UDP datagrams handled."),
metric.WithUnit("{record}"),
}
// NewServerNetCount returns a new ServerNetCount instrument.
func NewServerNetCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerNetCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerNetCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerNetCountOpts
} else {
opt = append(opt, newServerNetCountOpts...)
}
i, err := m.Int64Counter(
"nfs.server.net.count",
opt...,
)
if err != nil {
return ServerNetCount{noop.Int64Counter{}}, err
}
return ServerNetCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerNetCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerNetCount) Name() string {
return "nfs.server.net.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerNetCount) Unit() string {
return "{record}"
}
// Description returns the semantic convention description of the instrument
func (ServerNetCount) Description() string {
return "Reports the count of kernel NFS server TCP segments and UDP datagrams handled."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpcnt and
// svc_stat.netudpcnt
func (m ServerNetCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpcnt and
// svc_stat.netudpcnt
func (m ServerNetCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrNetworkTransport returns an optional attribute for the "network.transport"
// semantic convention. It represents the [OSI transport layer] or
// [inter-process communication method].
//
// [OSI transport layer]: https://wikipedia.org/wiki/Transport_layer
// [inter-process communication method]: https://wikipedia.org/wiki/Inter-process_communication
func (ServerNetCount) AttrNetworkTransport(val NetworkTransportAttr) attribute.KeyValue {
return attribute.String("network.transport", string(val))
}
// ServerNetTCPConnectionAccepted is an instrument used to record metric values
// conforming to the "nfs.server.net.tcp.connection.accepted" semantic
// conventions. It represents the reports the count of kernel NFS server TCP
// connections accepted.
type ServerNetTCPConnectionAccepted struct {
metric.Int64Counter
}
var newServerNetTCPConnectionAcceptedOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server TCP connections accepted."),
metric.WithUnit("{connection}"),
}
// NewServerNetTCPConnectionAccepted returns a new ServerNetTCPConnectionAccepted
// instrument.
func NewServerNetTCPConnectionAccepted(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerNetTCPConnectionAccepted, error) {
// Check if the meter is nil.
if m == nil {
return ServerNetTCPConnectionAccepted{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerNetTCPConnectionAcceptedOpts
} else {
opt = append(opt, newServerNetTCPConnectionAcceptedOpts...)
}
i, err := m.Int64Counter(
"nfs.server.net.tcp.connection.accepted",
opt...,
)
if err != nil {
return ServerNetTCPConnectionAccepted{noop.Int64Counter{}}, err
}
return ServerNetTCPConnectionAccepted{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerNetTCPConnectionAccepted) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerNetTCPConnectionAccepted) Name() string {
return "nfs.server.net.tcp.connection.accepted"
}
// Unit returns the semantic convention unit of the instrument
func (ServerNetTCPConnectionAccepted) Unit() string {
return "{connection}"
}
// Description returns the semantic convention description of the instrument
func (ServerNetTCPConnectionAccepted) Description() string {
return "Reports the count of kernel NFS server TCP connections accepted."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpconn
func (m ServerNetTCPConnectionAccepted) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.nettcpconn
func (m ServerNetTCPConnectionAccepted) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// ServerOperationCount is an instrument used to record metric values conforming
// to the "nfs.server.operation.count" semantic conventions. It represents the
// reports the count of kernel NFSv4+ server operations.
type ServerOperationCount struct {
metric.Int64Counter
}
var newServerOperationCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFSv4+ server operations."),
metric.WithUnit("{operation}"),
}
// NewServerOperationCount returns a new ServerOperationCount instrument.
func NewServerOperationCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerOperationCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerOperationCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerOperationCountOpts
} else {
opt = append(opt, newServerOperationCountOpts...)
}
i, err := m.Int64Counter(
"nfs.server.operation.count",
opt...,
)
if err != nil {
return ServerOperationCount{noop.Int64Counter{}}, err
}
return ServerOperationCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerOperationCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerOperationCount) Name() string {
return "nfs.server.operation.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerOperationCount) Unit() string {
return "{operation}"
}
// Description returns the semantic convention description of the instrument
func (ServerOperationCount) Description() string {
return "Reports the count of kernel NFSv4+ server operations."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
func (m ServerOperationCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
func (m ServerOperationCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrOperationName returns an optional attribute for the "nfs.operation.name"
// semantic convention. It represents the NFSv4+ operation name.
func (ServerOperationCount) AttrOperationName(val string) attribute.KeyValue {
return attribute.String("nfs.operation.name", val)
}
// AttrOncRPCVersion returns an optional attribute for the "onc_rpc.version"
// semantic convention. It represents the ONC/Sun RPC program version.
func (ServerOperationCount) AttrOncRPCVersion(val int) attribute.KeyValue {
return attribute.Int("onc_rpc.version", val)
}
// ServerProcedureCount is an instrument used to record metric values conforming
// to the "nfs.server.procedure.count" semantic conventions. It represents the
// reports the count of kernel NFS server procedures.
type ServerProcedureCount struct {
metric.Int64Counter
}
var newServerProcedureCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server procedures."),
metric.WithUnit("{procedure}"),
}
// NewServerProcedureCount returns a new ServerProcedureCount instrument.
func NewServerProcedureCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerProcedureCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerProcedureCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerProcedureCountOpts
} else {
opt = append(opt, newServerProcedureCountOpts...)
}
i, err := m.Int64Counter(
"nfs.server.procedure.count",
opt...,
)
if err != nil {
return ServerProcedureCount{noop.Int64Counter{}}, err
}
return ServerProcedureCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerProcedureCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerProcedureCount) Name() string {
return "nfs.server.procedure.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerProcedureCount) Unit() string {
return "{procedure}"
}
// Description returns the semantic convention description of the instrument
func (ServerProcedureCount) Description() string {
return "Reports the count of kernel NFS server procedures."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
func (m ServerProcedureCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
func (m ServerProcedureCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrOncRPCProcedureName returns an optional attribute for the
// "onc_rpc.procedure.name" semantic convention. It represents the ONC/Sun RPC
// procedure name.
func (ServerProcedureCount) AttrOncRPCProcedureName(val string) attribute.KeyValue {
return attribute.String("onc_rpc.procedure.name", val)
}
// AttrOncRPCVersion returns an optional attribute for the "onc_rpc.version"
// semantic convention. It represents the ONC/Sun RPC program version.
func (ServerProcedureCount) AttrOncRPCVersion(val int) attribute.KeyValue {
return attribute.Int("onc_rpc.version", val)
}
// ServerRepcacheRequests is an instrument used to record metric values
// conforming to the "nfs.server.repcache.requests" semantic conventions. It
// represents the reports the kernel NFS server reply cache request count by
// cache hit status.
type ServerRepcacheRequests struct {
metric.Int64Counter
}
var newServerRepcacheRequestsOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the kernel NFS server reply cache request count by cache hit status."),
metric.WithUnit("{request}"),
}
// NewServerRepcacheRequests returns a new ServerRepcacheRequests instrument.
func NewServerRepcacheRequests(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerRepcacheRequests, error) {
// Check if the meter is nil.
if m == nil {
return ServerRepcacheRequests{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerRepcacheRequestsOpts
} else {
opt = append(opt, newServerRepcacheRequestsOpts...)
}
i, err := m.Int64Counter(
"nfs.server.repcache.requests",
opt...,
)
if err != nil {
return ServerRepcacheRequests{noop.Int64Counter{}}, err
}
return ServerRepcacheRequests{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerRepcacheRequests) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerRepcacheRequests) Name() string {
return "nfs.server.repcache.requests"
}
// Unit returns the semantic convention unit of the instrument
func (ServerRepcacheRequests) Unit() string {
return "{request}"
}
// Description returns the semantic convention description of the instrument
func (ServerRepcacheRequests) Description() string {
return "Reports the kernel NFS server reply cache request count by cache hit status."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
func (m ServerRepcacheRequests) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
func (m ServerRepcacheRequests) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrServerRepcacheStatus returns an optional attribute for the
// "nfs.server.repcache.status" semantic convention. It represents the linux: one
// of "hit" (NFSD_STATS_RC_HITS), "miss" (NFSD_STATS_RC_MISSES), or "nocache"
// (NFSD_STATS_RC_NOCACHE -- uncacheable).
func (ServerRepcacheRequests) AttrServerRepcacheStatus(val string) attribute.KeyValue {
return attribute.String("nfs.server.repcache.status", val)
}
// ServerRPCCount is an instrument used to record metric values conforming to the
// "nfs.server.rpc.count" semantic conventions. It represents the reports the
// count of kernel NFS server RPCs handled.
type ServerRPCCount struct {
metric.Int64Counter
}
var newServerRPCCountOpts = []metric.Int64CounterOption{
metric.WithDescription("Reports the count of kernel NFS server RPCs handled."),
metric.WithUnit("{request}"),
}
// NewServerRPCCount returns a new ServerRPCCount instrument.
func NewServerRPCCount(
m metric.Meter,
opt ...metric.Int64CounterOption,
) (ServerRPCCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerRPCCount{noop.Int64Counter{}}, nil
}
if len(opt) == 0 {
opt = newServerRPCCountOpts
} else {
opt = append(opt, newServerRPCCountOpts...)
}
i, err := m.Int64Counter(
"nfs.server.rpc.count",
opt...,
)
if err != nil {
return ServerRPCCount{noop.Int64Counter{}}, err
}
return ServerRPCCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerRPCCount) Inst() metric.Int64Counter {
return m.Int64Counter
}
// Name returns the semantic convention name of the instrument.
func (ServerRPCCount) Name() string {
return "nfs.server.rpc.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerRPCCount) Unit() string {
return "{request}"
}
// Description returns the semantic convention description of the instrument
func (ServerRPCCount) Description() string {
return "Reports the count of kernel NFS server RPCs handled."
}
// Add adds incr to the existing count for attrs.
//
// All additional attrs passed are included in the recorded value.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpccnt, the count
// of good RPCs. This metric can have
// an error.type of "format", "auth", or "client" for svc_stat.badfmt,
// svc_stat.badauth, and svc_stat.badclnt.
func (m ServerRPCCount) Add(
ctx context.Context,
incr int64,
attrs ...attribute.KeyValue,
) {
if len(attrs) == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(
*o,
metric.WithAttributes(
attrs...,
),
)
m.Int64Counter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel's svc_stat.rpccnt, the count
// of good RPCs. This metric can have
// an error.type of "format", "auth", or "client" for svc_stat.badfmt,
// svc_stat.badauth, and svc_stat.badclnt.
func (m ServerRPCCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64Counter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64Counter.Add(ctx, incr, *o...)
}
// AttrErrorType returns an optional attribute for the "error.type" semantic
// convention. It represents the describes a class of error the operation ended
// with.
func (ServerRPCCount) AttrErrorType(val ErrorTypeAttr) attribute.KeyValue {
return attribute.String("error.type", string(val))
}
// ServerThreadCount is an instrument used to record metric values conforming to
// the "nfs.server.thread.count" semantic conventions. It represents the reports
// the count of kernel NFS server available threads.
type ServerThreadCount struct {
metric.Int64UpDownCounter
}
var newServerThreadCountOpts = []metric.Int64UpDownCounterOption{
metric.WithDescription("Reports the count of kernel NFS server available threads."),
metric.WithUnit("{thread}"),
}
// NewServerThreadCount returns a new ServerThreadCount instrument.
func NewServerThreadCount(
m metric.Meter,
opt ...metric.Int64UpDownCounterOption,
) (ServerThreadCount, error) {
// Check if the meter is nil.
if m == nil {
return ServerThreadCount{noop.Int64UpDownCounter{}}, nil
}
if len(opt) == 0 {
opt = newServerThreadCountOpts
} else {
opt = append(opt, newServerThreadCountOpts...)
}
i, err := m.Int64UpDownCounter(
"nfs.server.thread.count",
opt...,
)
if err != nil {
return ServerThreadCount{noop.Int64UpDownCounter{}}, err
}
return ServerThreadCount{i}, nil
}
// Inst returns the underlying metric instrument.
func (m ServerThreadCount) Inst() metric.Int64UpDownCounter {
return m.Int64UpDownCounter
}
// Name returns the semantic convention name of the instrument.
func (ServerThreadCount) Name() string {
return "nfs.server.thread.count"
}
// Unit returns the semantic convention unit of the instrument
func (ServerThreadCount) Unit() string {
return "{thread}"
}
// Description returns the semantic convention description of the instrument
func (ServerThreadCount) Description() string {
return "Reports the count of kernel NFS server available threads."
}
// Add adds incr to the existing count for attrs.
//
// Linux: this metric is taken from the Linux kernel nfsd_th_cnt variable
func (m ServerThreadCount) Add(ctx context.Context, incr int64, attrs ...attribute.KeyValue) {
if len(attrs) == 0 {
m.Int64UpDownCounter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributes(attrs...))
m.Int64UpDownCounter.Add(ctx, incr, *o...)
}
// AddSet adds incr to the existing count for set.
//
// Linux: this metric is taken from the Linux kernel nfsd_th_cnt variable
func (m ServerThreadCount) AddSet(ctx context.Context, incr int64, set attribute.Set) {
if set.Len() == 0 {
m.Int64UpDownCounter.Add(ctx, incr)
return
}
o := addOptPool.Get().(*[]metric.AddOption)
defer func() {
*o = (*o)[:0]
addOptPool.Put(o)
}()
*o = append(*o, metric.WithAttributeSet(set))
m.Int64UpDownCounter.Add(ctx, incr, *o...)
}