Versions in this module Expand all Collapse all v1 v1.8.4 Aug 21, 2023 Changes in this version + const RoutingService_SubscribeRoutingStats_FullMethodName + const RoutingService_TestRoute_FullMethodName + var File_app_router_command_command_proto protoreflect.FileDescriptor + var RoutingService_ServiceDesc = grpc.ServiceDesc + func AsProtobufMessage(fieldSelectors []string) func(routing.Route) *RoutingContext + func AsRoutingContext(r *RoutingContext) routing.Context + func AsRoutingRoute(r *RoutingContext) routing.Route + func RegisterRoutingServiceServer(s grpc.ServiceRegistrar, srv RoutingServiceServer) + type Config struct + func (*Config) Descriptor() ([]byte, []int) + func (*Config) ProtoMessage() + func (x *Config) ProtoReflect() protoreflect.Message + func (x *Config) Reset() + func (x *Config) String() string + type RoutingContext struct + Attributes map[string]string + InboundTag string + Network net.Network + OutboundGroupTags []string + OutboundTag string + Protocol string + SourceIPs [][]byte + SourcePort uint32 + TargetDomain string + TargetIPs [][]byte + TargetPort uint32 + User string + func (*RoutingContext) Descriptor() ([]byte, []int) + func (*RoutingContext) ProtoMessage() + func (x *RoutingContext) GetAttributes() map[string]string + func (x *RoutingContext) GetInboundTag() string + func (x *RoutingContext) GetNetwork() net.Network + func (x *RoutingContext) GetOutboundGroupTags() []string + func (x *RoutingContext) GetOutboundTag() string + func (x *RoutingContext) GetProtocol() string + func (x *RoutingContext) GetSourceIPs() [][]byte + func (x *RoutingContext) GetSourcePort() uint32 + func (x *RoutingContext) GetTargetDomain() string + func (x *RoutingContext) GetTargetIPs() [][]byte + func (x *RoutingContext) GetTargetPort() uint32 + func (x *RoutingContext) GetUser() string + func (x *RoutingContext) ProtoReflect() protoreflect.Message + func (x *RoutingContext) Reset() + func (x *RoutingContext) String() string + type RoutingServiceClient interface + SubscribeRoutingStats func(ctx context.Context, in *SubscribeRoutingStatsRequest, opts ...grpc.CallOption) (RoutingService_SubscribeRoutingStatsClient, error) + TestRoute func(ctx context.Context, in *TestRouteRequest, opts ...grpc.CallOption) (*RoutingContext, error) + func NewRoutingServiceClient(cc grpc.ClientConnInterface) RoutingServiceClient + type RoutingServiceServer interface + SubscribeRoutingStats func(*SubscribeRoutingStatsRequest, RoutingService_SubscribeRoutingStatsServer) error + TestRoute func(context.Context, *TestRouteRequest) (*RoutingContext, error) + func NewRoutingServer(router routing.Router, routingStats stats.Channel) RoutingServiceServer + type RoutingService_SubscribeRoutingStatsClient interface + Recv func() (*RoutingContext, error) + type RoutingService_SubscribeRoutingStatsServer interface + Send func(*RoutingContext) error + type SubscribeRoutingStatsRequest struct + FieldSelectors []string + func (*SubscribeRoutingStatsRequest) Descriptor() ([]byte, []int) + func (*SubscribeRoutingStatsRequest) ProtoMessage() + func (x *SubscribeRoutingStatsRequest) GetFieldSelectors() []string + func (x *SubscribeRoutingStatsRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRoutingStatsRequest) Reset() + func (x *SubscribeRoutingStatsRequest) String() string + type TestRouteRequest struct + FieldSelectors []string + PublishResult bool + RoutingContext *RoutingContext + func (*TestRouteRequest) Descriptor() ([]byte, []int) + func (*TestRouteRequest) ProtoMessage() + func (x *TestRouteRequest) GetFieldSelectors() []string + func (x *TestRouteRequest) GetPublishResult() bool + func (x *TestRouteRequest) GetRoutingContext() *RoutingContext + func (x *TestRouteRequest) ProtoReflect() protoreflect.Message + func (x *TestRouteRequest) Reset() + func (x *TestRouteRequest) String() string + type UnimplementedRoutingServiceServer struct + func (UnimplementedRoutingServiceServer) SubscribeRoutingStats(*SubscribeRoutingStatsRequest, RoutingService_SubscribeRoutingStatsServer) error + func (UnimplementedRoutingServiceServer) TestRoute(context.Context, *TestRouteRequest) (*RoutingContext, error) + type UnsafeRoutingServiceServer interface