Skip to content

Commit 12f04e8

Browse files
committed
add network stats
1 parent 9212a2b commit 12f04e8

13 files changed

Lines changed: 1043 additions & 496 deletions

common/messages.pb.go

Lines changed: 14 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

common/messages.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ message NetworkDeviceStatsMessage {
3030
uint64 bytes_out = 3;
3131
uint64 packets_in = 4;
3232
uint64 packets_out = 5;
33+
optional string socket_id = 6;
3334
}
3435

3536
message PeerOnlineMessage {

connector/connector.pb.go

Lines changed: 543 additions & 477 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

connector/connector.proto

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ message ControlStreamRequest {
3232
border0.common.v1.DiscoveryDetailsMessage discovery_details = 14;
3333
AuthorizePeerRequest authorize_peer = 15;
3434
SessionRequest session = 16;
35-
border0.common.v1.StatsMessage stats = 17;
35+
Stats stats = 17;
3636
}
3737
}
3838

@@ -301,4 +301,8 @@ message AllowedNetworksSocketConfig {
301301

302302
message AllowedNetworksSubnets {
303303
repeated string subnets = 1;
304+
}
305+
306+
message Stats {
307+
repeated border0.common.v1.StatsMessage network_device_stats = 1;
304308
}

gen/kotlin/border0/common/v1/NetworkDeviceStatsMessageKt.kt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,30 @@ public object NetworkDeviceStatsMessageKt {
113113
public fun clearPacketsOut() {
114114
_builder.clearPacketsOut()
115115
}
116+
117+
/**
118+
* <code>optional string socket_id = 6;</code>
119+
*/
120+
public var socketId: kotlin.String
121+
@JvmName("getSocketId")
122+
get() = _builder.getSocketId()
123+
@JvmName("setSocketId")
124+
set(value) {
125+
_builder.setSocketId(value)
126+
}
127+
/**
128+
* <code>optional string socket_id = 6;</code>
129+
*/
130+
public fun clearSocketId() {
131+
_builder.clearSocketId()
132+
}
133+
/**
134+
* <code>optional string socket_id = 6;</code>
135+
* @return Whether the socketId field is set.
136+
*/
137+
public fun hasSocketId(): kotlin.Boolean {
138+
return _builder.hasSocketId()
139+
}
116140
}
117141
}
118142
@kotlin.jvm.JvmSynthetic

gen/kotlin/border0/common/v1/WireGuardPeerKt.kt

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ public object WireGuardPeerKt {
110110
*
111111
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
112112
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
113-
* See messages.proto;l=59
113+
* See messages.proto;l=60
114114
* @return A list containing the allowedIps.
115115
*/
116116
@kotlin.Deprecated(message = "Field allowedIps is deprecated") public val allowedIps: com.google.protobuf.kotlin.DslList<kotlin.String, AllowedIpsProxy>
@@ -125,7 +125,7 @@ public object WireGuardPeerKt {
125125
*
126126
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
127127
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
128-
* See messages.proto;l=59
128+
* See messages.proto;l=60
129129
* @param value The allowedIps to add.
130130
*/
131131
@kotlin.jvm.JvmSynthetic
@@ -140,7 +140,7 @@ public object WireGuardPeerKt {
140140
*
141141
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
142142
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
143-
* See messages.proto;l=59
143+
* See messages.proto;l=60
144144
* @param value The allowedIps to add.
145145
*/
146146
@kotlin.jvm.JvmSynthetic
@@ -156,7 +156,7 @@ public object WireGuardPeerKt {
156156
*
157157
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
158158
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
159-
* See messages.proto;l=59
159+
* See messages.proto;l=60
160160
* @param values The allowedIps to add.
161161
*/
162162
@kotlin.jvm.JvmSynthetic
@@ -171,7 +171,7 @@ public object WireGuardPeerKt {
171171
*
172172
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
173173
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
174-
* See messages.proto;l=59
174+
* See messages.proto;l=60
175175
* @param values The allowedIps to add.
176176
*/
177177
@kotlin.jvm.JvmSynthetic
@@ -187,7 +187,7 @@ public object WireGuardPeerKt {
187187
*
188188
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
189189
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
190-
* See messages.proto;l=59
190+
* See messages.proto;l=60
191191
* @param index The index to set the value at.
192192
* @param value The allowedIps to set.
193193
*/
@@ -202,7 +202,7 @@ public object WireGuardPeerKt {
202202
*
203203
* <code>repeated string allowed_ips = 4 [deprecated = true];</code>
204204
* @deprecated border0.common.v1.WireGuardPeer.allowed_ips is deprecated.
205-
* See messages.proto;l=59
205+
* See messages.proto;l=60
206206
*/
207207
@kotlin.jvm.JvmSynthetic
208208
@kotlin.jvm.JvmName("clearAllowedIps")
Lines changed: 90 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,90 @@
1+
//Generated by the protocol buffer compiler. DO NOT EDIT!
2+
// source: connector.proto
3+
4+
package border0.v1;
5+
6+
@kotlin.jvm.JvmName("-initializeallowedNetworks")
7+
public inline fun allowedNetworks(block: border0.v1.AllowedNetworksKt.Dsl.() -> kotlin.Unit): border0.v1.Connector.AllowedNetworks =
8+
border0.v1.AllowedNetworksKt.Dsl._create(border0.v1.Connector.AllowedNetworks.newBuilder()).apply { block() }._build()
9+
public object AllowedNetworksKt {
10+
@kotlin.OptIn(com.google.protobuf.kotlin.OnlyForUseByGeneratedProtoCode::class)
11+
@com.google.protobuf.kotlin.ProtoDslMarker
12+
public class Dsl private constructor(
13+
private val _builder: border0.v1.Connector.AllowedNetworks.Builder
14+
) {
15+
public companion object {
16+
@kotlin.jvm.JvmSynthetic
17+
@kotlin.PublishedApi
18+
internal fun _create(builder: border0.v1.Connector.AllowedNetworks.Builder): Dsl = Dsl(builder)
19+
}
20+
21+
@kotlin.jvm.JvmSynthetic
22+
@kotlin.PublishedApi
23+
internal fun _build(): border0.v1.Connector.AllowedNetworks = _builder.build()
24+
25+
/**
26+
* An uninstantiable, behaviorless type to represent the field in
27+
* generics.
28+
*/
29+
@kotlin.OptIn(com.google.protobuf.kotlin.OnlyForUseByGeneratedProtoCode::class)
30+
public class DevicesProxy private constructor() : com.google.protobuf.kotlin.DslProxy()
31+
/**
32+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
33+
*/
34+
public val devices: com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
35+
@kotlin.jvm.JvmSynthetic
36+
@JvmName("getDevicesMap")
37+
get() = com.google.protobuf.kotlin.DslMap(
38+
_builder.getDevicesMap()
39+
)
40+
/**
41+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
42+
*/
43+
@JvmName("putDevices")
44+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
45+
.put(key: kotlin.String, value: border0.v1.Connector.AllowedNetworksSocketConfig) {
46+
_builder.putDevices(key, value)
47+
}
48+
/**
49+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
50+
*/
51+
@kotlin.jvm.JvmSynthetic
52+
@JvmName("setDevices")
53+
@Suppress("NOTHING_TO_INLINE")
54+
public inline operator fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
55+
.set(key: kotlin.String, value: border0.v1.Connector.AllowedNetworksSocketConfig) {
56+
put(key, value)
57+
}
58+
/**
59+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
60+
*/
61+
@kotlin.jvm.JvmSynthetic
62+
@JvmName("removeDevices")
63+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
64+
.remove(key: kotlin.String) {
65+
_builder.removeDevices(key)
66+
}
67+
/**
68+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
69+
*/
70+
@kotlin.jvm.JvmSynthetic
71+
@JvmName("putAllDevices")
72+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
73+
.putAll(map: kotlin.collections.Map<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig>) {
74+
_builder.putAllDevices(map)
75+
}
76+
/**
77+
* <code>map&lt;string, .border0.v1.AllowedNetworksSocketConfig&gt; devices = 1;</code>
78+
*/
79+
@kotlin.jvm.JvmSynthetic
80+
@JvmName("clearDevices")
81+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSocketConfig, DevicesProxy>
82+
.clear() {
83+
_builder.clearDevices()
84+
}
85+
}
86+
}
87+
@kotlin.jvm.JvmSynthetic
88+
public inline fun border0.v1.Connector.AllowedNetworks.copy(block: border0.v1.AllowedNetworksKt.Dsl.() -> kotlin.Unit): border0.v1.Connector.AllowedNetworks =
89+
border0.v1.AllowedNetworksKt.Dsl._create(this.toBuilder()).apply { block() }._build()
90+
Lines changed: 90 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,90 @@
1+
//Generated by the protocol buffer compiler. DO NOT EDIT!
2+
// source: connector.proto
3+
4+
package border0.v1;
5+
6+
@kotlin.jvm.JvmName("-initializeallowedNetworksSocketConfig")
7+
public inline fun allowedNetworksSocketConfig(block: border0.v1.AllowedNetworksSocketConfigKt.Dsl.() -> kotlin.Unit): border0.v1.Connector.AllowedNetworksSocketConfig =
8+
border0.v1.AllowedNetworksSocketConfigKt.Dsl._create(border0.v1.Connector.AllowedNetworksSocketConfig.newBuilder()).apply { block() }._build()
9+
public object AllowedNetworksSocketConfigKt {
10+
@kotlin.OptIn(com.google.protobuf.kotlin.OnlyForUseByGeneratedProtoCode::class)
11+
@com.google.protobuf.kotlin.ProtoDslMarker
12+
public class Dsl private constructor(
13+
private val _builder: border0.v1.Connector.AllowedNetworksSocketConfig.Builder
14+
) {
15+
public companion object {
16+
@kotlin.jvm.JvmSynthetic
17+
@kotlin.PublishedApi
18+
internal fun _create(builder: border0.v1.Connector.AllowedNetworksSocketConfig.Builder): Dsl = Dsl(builder)
19+
}
20+
21+
@kotlin.jvm.JvmSynthetic
22+
@kotlin.PublishedApi
23+
internal fun _build(): border0.v1.Connector.AllowedNetworksSocketConfig = _builder.build()
24+
25+
/**
26+
* An uninstantiable, behaviorless type to represent the field in
27+
* generics.
28+
*/
29+
@kotlin.OptIn(com.google.protobuf.kotlin.OnlyForUseByGeneratedProtoCode::class)
30+
public class SocketsProxy private constructor() : com.google.protobuf.kotlin.DslProxy()
31+
/**
32+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
33+
*/
34+
public val sockets: com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
35+
@kotlin.jvm.JvmSynthetic
36+
@JvmName("getSocketsMap")
37+
get() = com.google.protobuf.kotlin.DslMap(
38+
_builder.getSocketsMap()
39+
)
40+
/**
41+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
42+
*/
43+
@JvmName("putSockets")
44+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
45+
.put(key: kotlin.String, value: border0.v1.Connector.AllowedNetworksSubnets) {
46+
_builder.putSockets(key, value)
47+
}
48+
/**
49+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
50+
*/
51+
@kotlin.jvm.JvmSynthetic
52+
@JvmName("setSockets")
53+
@Suppress("NOTHING_TO_INLINE")
54+
public inline operator fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
55+
.set(key: kotlin.String, value: border0.v1.Connector.AllowedNetworksSubnets) {
56+
put(key, value)
57+
}
58+
/**
59+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
60+
*/
61+
@kotlin.jvm.JvmSynthetic
62+
@JvmName("removeSockets")
63+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
64+
.remove(key: kotlin.String) {
65+
_builder.removeSockets(key)
66+
}
67+
/**
68+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
69+
*/
70+
@kotlin.jvm.JvmSynthetic
71+
@JvmName("putAllSockets")
72+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
73+
.putAll(map: kotlin.collections.Map<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets>) {
74+
_builder.putAllSockets(map)
75+
}
76+
/**
77+
* <code>map&lt;string, .border0.v1.AllowedNetworksSubnets&gt; sockets = 1;</code>
78+
*/
79+
@kotlin.jvm.JvmSynthetic
80+
@JvmName("clearSockets")
81+
public fun com.google.protobuf.kotlin.DslMap<kotlin.String, border0.v1.Connector.AllowedNetworksSubnets, SocketsProxy>
82+
.clear() {
83+
_builder.clearSockets()
84+
}
85+
}
86+
}
87+
@kotlin.jvm.JvmSynthetic
88+
public inline fun border0.v1.Connector.AllowedNetworksSocketConfig.copy(block: border0.v1.AllowedNetworksSocketConfigKt.Dsl.() -> kotlin.Unit): border0.v1.Connector.AllowedNetworksSocketConfig =
89+
border0.v1.AllowedNetworksSocketConfigKt.Dsl._create(this.toBuilder()).apply { block() }._build()
90+

0 commit comments

Comments
 (0)