Skip to content

Commit 4ce17eb

Browse files
btoonkbtoonk
committed
add network stats
1 parent 9212a2b commit 4ce17eb

10 files changed

Lines changed: 960 additions & 162 deletions

File tree

‎common/messages.pb.go‎

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

‎common/messages.proto‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ message HeartbeatMessage {}
2121
message StatsMessage {
2222
oneof StatsMessageType {
2323
NetworkDeviceStatsMessage network_device_stats = 1;
24+
SocketsStatsMessage sockets_stats = 2;
2425
}
2526
}
2627

@@ -32,6 +33,20 @@ message NetworkDeviceStatsMessage {
3233
uint64 packets_out = 5;
3334
}
3435

36+
message SocketsStatsMessage {
37+
google.protobuf.Timestamp timestamp = 1;
38+
uint64 bytes_in = 2;
39+
uint64 bytes_out = 3;
40+
uint64 packets_in = 4;
41+
uint64 packets_out = 5;
42+
string socket_id = 6;
43+
}
44+
45+
46+
message SocketStatsMessage {
47+
repeated SocketStatsMessage socket_stats = 1;
48+
}
49+
3550
message PeerOnlineMessage {
3651
string network_id = 1;
3752
WireGuardPeer peer = 2;

‎connector/connector.proto‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -301,4 +301,5 @@ message AllowedNetworksSocketConfig {
301301

302302
message AllowedNetworksSubnets {
303303
repeated string subnets = 1;
304-
}
304+
}
305+

‎gen/kotlin/border0/common/v1/StatsMessageKt.kt‎

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,30 @@ public object StatsMessageKt {
4545
public fun hasNetworkDeviceStats(): kotlin.Boolean {
4646
return _builder.hasNetworkDeviceStats()
4747
}
48+
49+
/**
50+
* <code>.border0.common.v1.SocketsStatsMessage sockets_stats = 2;</code>
51+
*/
52+
public var socketsStats: border0.common.v1.Messages.SocketsStatsMessage
53+
@JvmName("getSocketsStats")
54+
get() = _builder.getSocketsStats()
55+
@JvmName("setSocketsStats")
56+
set(value) {
57+
_builder.setSocketsStats(value)
58+
}
59+
/**
60+
* <code>.border0.common.v1.SocketsStatsMessage sockets_stats = 2;</code>
61+
*/
62+
public fun clearSocketsStats() {
63+
_builder.clearSocketsStats()
64+
}
65+
/**
66+
* <code>.border0.common.v1.SocketsStatsMessage sockets_stats = 2;</code>
67+
* @return Whether the socketsStats field is set.
68+
*/
69+
public fun hasSocketsStats(): kotlin.Boolean {
70+
return _builder.hasSocketsStats()
71+
}
4872
public val statsMessageTypeCase: border0.common.v1.Messages.StatsMessage.StatsMessageTypeCase
4973
@JvmName("getStatsMessageTypeCase")
5074
get() = _builder.getStatsMessageTypeCase()
@@ -61,3 +85,6 @@ public inline fun border0.common.v1.Messages.StatsMessage.copy(block: border0.co
6185
public val border0.common.v1.Messages.StatsMessageOrBuilder.networkDeviceStatsOrNull: border0.common.v1.Messages.NetworkDeviceStatsMessage?
6286
get() = if (hasNetworkDeviceStats()) getNetworkDeviceStats() else null
6387

88+
public val border0.common.v1.Messages.StatsMessageOrBuilder.socketsStatsOrNull: border0.common.v1.Messages.SocketsStatsMessage?
89+
get() = if (hasSocketsStats()) getSocketsStats() else null
90+

‎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=74
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=74
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=74
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=74
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=74
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=74
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=74
206206
*/
207207
@kotlin.jvm.JvmSynthetic
208208
@kotlin.jvm.JvmName("clearAllowedIps")

‎gen/kotlin/border0/v1/AllowedNetworksKt.kt‎

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+

‎gen/kotlin/border0/v1/AllowedNetworksSocketConfigKt.kt‎

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)