mirror of
https://github.com/XTLS/Xray-core.git
synced 2024-11-16 12:03:03 +00:00
fa5d7a255b
* v5: Health Check & LeastLoad Strategy (rebased from 2c5a71490368500a982018a74a6d519c7e121816) Some changes will be necessary to integrate it into V2Ray * Update proto * parse duration conf with time.Parse() * moving health ping to observatory as a standalone component * moving health ping to observatory as a standalone component: auto generated file * add initialization for health ping * incorporate changes in router implementation * support principle target output * add v4 json support for BurstObservatory & fix balancer reference * update API command * remove cancelled API * return zero length value when observer is not found * remove duplicated targeted dispatch * adjust test with updated structure * bug fix for observer * fix strategy selector * fix strategy least load * Fix ticker usage ticker.Close does not close ticker.C * feat: Replace default Health Ping URL to HTTPS (#1991) * fix selectLeastLoad() returns wrong number of nodes (#2083) * Test: fix leastload strategy unit test * fix(router): panic caused by concurrent map read and write (#2678) * Clean up code --------- Co-authored-by: Jebbs <qjebbs@gmail.com> Co-authored-by: Shelikhoo <xiaokangwang@outlook.com> Co-authored-by: 世界 <i@sekai.icu> Co-authored-by: Bernd Eichelberger <46166740+4-FLOSS-Free-Libre-Open-Source-Software@users.noreply.github.com> Co-authored-by: 秋のかえで <autmaple@protonmail.com> Co-authored-by: Rinka <kujourinka@gmail.com>
101 lines
3.1 KiB
Protocol Buffer
101 lines
3.1 KiB
Protocol Buffer
syntax = "proto3";
|
|
|
|
package xray.app.router.command;
|
|
option csharp_namespace = "Xray.App.Router.Command";
|
|
option go_package = "github.com/xtls/xray-core/app/router/command";
|
|
option java_package = "com.xray.app.router.command";
|
|
option java_multiple_files = true;
|
|
|
|
import "common/net/network.proto";
|
|
|
|
// RoutingContext is the context with information relative to routing process.
|
|
// It conforms to the structure of xray.features.routing.Context and
|
|
// xray.features.routing.Route.
|
|
message RoutingContext {
|
|
string InboundTag = 1;
|
|
xray.common.net.Network Network = 2;
|
|
repeated bytes SourceIPs = 3;
|
|
repeated bytes TargetIPs = 4;
|
|
uint32 SourcePort = 5;
|
|
uint32 TargetPort = 6;
|
|
string TargetDomain = 7;
|
|
string Protocol = 8;
|
|
string User = 9;
|
|
map<string, string> Attributes = 10;
|
|
repeated string OutboundGroupTags = 11;
|
|
string OutboundTag = 12;
|
|
}
|
|
|
|
// SubscribeRoutingStatsRequest subscribes to routing statistics channel if
|
|
// opened by xray-core.
|
|
// * FieldSelectors selects a subset of fields in routing statistics to return.
|
|
// Valid selectors:
|
|
// - inbound: Selects connection's inbound tag.
|
|
// - network: Selects connection's network.
|
|
// - ip: Equivalent as "ip_source" and "ip_target", selects both source and
|
|
// target IP.
|
|
// - port: Equivalent as "port_source" and "port_target", selects both source
|
|
// and target port.
|
|
// - domain: Selects target domain.
|
|
// - protocol: Select connection's protocol.
|
|
// - user: Select connection's inbound user email.
|
|
// - attributes: Select connection's additional attributes.
|
|
// - outbound: Equivalent as "outbound" and "outbound_group", select both
|
|
// outbound tag and outbound group tags.
|
|
// * If FieldSelectors is left empty, all fields will be returned.
|
|
message SubscribeRoutingStatsRequest {
|
|
repeated string FieldSelectors = 1;
|
|
}
|
|
|
|
// TestRouteRequest manually tests a routing result according to the routing
|
|
// context message.
|
|
// * RoutingContext is the routing message without outbound information.
|
|
// * FieldSelectors selects the fields to return in the routing result. All
|
|
// fields are returned if left empty.
|
|
// * PublishResult broadcasts the routing result to routing statistics channel
|
|
// if set true.
|
|
message TestRouteRequest {
|
|
RoutingContext RoutingContext = 1;
|
|
repeated string FieldSelectors = 2;
|
|
bool PublishResult = 3;
|
|
}
|
|
|
|
message PrincipleTargetInfo {
|
|
repeated string tag = 1;
|
|
}
|
|
|
|
message OverrideInfo {
|
|
string target = 2;
|
|
}
|
|
|
|
message BalancerMsg {
|
|
OverrideInfo override = 5;
|
|
PrincipleTargetInfo principle_target = 6;
|
|
}
|
|
|
|
message GetBalancerInfoRequest {
|
|
string tag = 1;
|
|
}
|
|
|
|
message GetBalancerInfoResponse {
|
|
BalancerMsg balancer = 1;
|
|
}
|
|
|
|
message OverrideBalancerTargetRequest {
|
|
string balancerTag = 1;
|
|
string target = 2;
|
|
}
|
|
|
|
message OverrideBalancerTargetResponse {}
|
|
|
|
service RoutingService {
|
|
rpc SubscribeRoutingStats(SubscribeRoutingStatsRequest)
|
|
returns (stream RoutingContext) {}
|
|
rpc TestRoute(TestRouteRequest) returns (RoutingContext) {}
|
|
|
|
rpc GetBalancerInfo(GetBalancerInfoRequest) returns (GetBalancerInfoResponse){}
|
|
rpc OverrideBalancerTarget(OverrideBalancerTargetRequest) returns (OverrideBalancerTargetResponse) {}
|
|
}
|
|
|
|
message Config {}
|