Katyusha's blog

1
// Code generated by bpf2go; DO NOT EDIT.
2
//go:build 386 || amd64 || arm || arm64 || loong64 || mips64le || mipsle || ppc64le || riscv64
3

4
package collector
5

6
import (
7
  "bytes"
8
  _ "embed"
9
  "fmt"
10
  "io"
11

12
  "github.com/cilium/ebpf"
13
)
14

15
type blockDevStat struct {
16
  Count      uint64
17
  TotalLatNs uint64
18
  MaxLatNs   uint64
19
  Bytes      uint64
20
  Inflight   int64
21
  Slots      [32]uint64
22
}
23

24
type blockRqKey struct {
25
  Dev    uint32
26
  Pad    uint32
27
  Sector uint64
28
}
29

30
// loadBlock returns the embedded CollectionSpec for block.
31
func loadBlock() (*ebpf.CollectionSpec, error) {
32
  reader := bytes.NewReader(_BlockBytes)
33
  spec, err := ebpf.LoadCollectionSpecFromReader(reader)
34
  if err != nil {
35
    return nil, fmt.Errorf("can't load block: %w", err)
36
  }
37

38
  return spec, err
39
}
40

41
// loadBlockObjects loads block and converts it into a struct.
42
//
43
// The following types are suitable as obj argument:
44
//
45
//  *blockObjects
46
//  *blockPrograms
47
//  *blockMaps
48
//
49
// See ebpf.CollectionSpec.LoadAndAssign documentation for details.
50
func loadBlockObjects(obj interface{}, opts *ebpf.CollectionOptions) error {
51
  spec, err := loadBlock()
52
  if err != nil {
53
    return err
54
  }
55

56
  return spec.LoadAndAssign(obj, opts)
57
}
58

59
// blockSpecs contains maps and programs before they are loaded into the kernel.
60
//
61
// It can be passed ebpf.CollectionSpec.Assign.
62
type blockSpecs struct {
63
  blockProgramSpecs
64
  blockMapSpecs
65
}
66

67
// blockSpecs contains programs before they are loaded into the kernel.
68
//
69
// It can be passed ebpf.CollectionSpec.Assign.
70
type blockProgramSpecs struct {
71
  HandleComplete *ebpf.ProgramSpec `ebpf:"handle_complete"`
72
  HandleIssue    *ebpf.ProgramSpec `ebpf:"handle_issue"`
73
}
74

75
// blockMapSpecs contains maps before they are loaded into the kernel.
76
//
77
// It can be passed ebpf.CollectionSpec.Assign.
78
type blockMapSpecs struct {
79
  DevStats *ebpf.MapSpec `ebpf:"dev_stats"`
80
  Start    *ebpf.MapSpec `ebpf:"start"`
81
}
82

83
// blockObjects contains all objects after they have been loaded into the kernel.
84
//
85
// It can be passed to loadBlockObjects or ebpf.CollectionSpec.LoadAndAssign.
86
type blockObjects struct {
87
  blockPrograms
88
  blockMaps
89
}
90

91
func (o *blockObjects) Close() error {
92
  return _BlockClose(
93
    &o.blockPrograms,
94
    &o.blockMaps,
95
  )
96
}
97

98
// blockMaps contains all maps after they have been loaded into the kernel.
99
//
100
// It can be passed to loadBlockObjects or ebpf.CollectionSpec.LoadAndAssign.
101
type blockMaps struct {
102
  DevStats *ebpf.Map `ebpf:"dev_stats"`
103
  Start    *ebpf.Map `ebpf:"start"`
104
}
105

106
func (m *blockMaps) Close() error {
107
  return _BlockClose(
108
    m.DevStats,
109
    m.Start,
110
  )
111
}
112

113
// blockPrograms contains all programs after they have been loaded into the kernel.
114
//
115
// It can be passed to loadBlockObjects or ebpf.CollectionSpec.LoadAndAssign.
116
type blockPrograms struct {
117
  HandleComplete *ebpf.Program `ebpf:"handle_complete"`
118
  HandleIssue    *ebpf.Program `ebpf:"handle_issue"`
119
}
120

121
func (p *blockPrograms) Close() error {
122
  return _BlockClose(
123
    p.HandleComplete,
124
    p.HandleIssue,
125
  )
126
}
127

128
func _BlockClose(closers ...io.Closer) error {
129
  for _, closer := range closers {
130
    if err := closer.Close(); err != nil {
131
      return err
132
    }
133
  }
134
  return nil
135
}
136

137
// Do not access this directly.
138
//
139
//go:embed block_bpfel.o
140
var _BlockBytes []byte