Versions in this module Expand all Collapse all v1 v1.0.0 Dec 9, 2024 Changes in this version + const RoutingService_GetBalancerInfo_FullMethodName + const RoutingService_OverrideBalancerTarget_FullMethodName + 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 BalancerMsg struct + Override *OverrideInfo + PrincipleTarget *PrincipleTargetInfo + func (*BalancerMsg) Descriptor() ([]byte, []int) + func (*BalancerMsg) ProtoMessage() + func (x *BalancerMsg) GetOverride() *OverrideInfo + func (x *BalancerMsg) GetPrincipleTarget() *PrincipleTargetInfo + func (x *BalancerMsg) ProtoReflect() protoreflect.Message + func (x *BalancerMsg) Reset() + func (x *BalancerMsg) String() string + 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 GetBalancerInfoRequest struct + Tag string + func (*GetBalancerInfoRequest) Descriptor() ([]byte, []int) + func (*GetBalancerInfoRequest) ProtoMessage() + func (x *GetBalancerInfoRequest) GetTag() string + func (x *GetBalancerInfoRequest) ProtoReflect() protoreflect.Message + func (x *GetBalancerInfoRequest) Reset() + func (x *GetBalancerInfoRequest) String() string + type GetBalancerInfoResponse struct + Balancer *BalancerMsg + func (*GetBalancerInfoResponse) Descriptor() ([]byte, []int) + func (*GetBalancerInfoResponse) ProtoMessage() + func (x *GetBalancerInfoResponse) GetBalancer() *BalancerMsg + func (x *GetBalancerInfoResponse) ProtoReflect() protoreflect.Message + func (x *GetBalancerInfoResponse) Reset() + func (x *GetBalancerInfoResponse) String() string + type OverrideBalancerTargetRequest struct + BalancerTag string + Target string + func (*OverrideBalancerTargetRequest) Descriptor() ([]byte, []int) + func (*OverrideBalancerTargetRequest) ProtoMessage() + func (x *OverrideBalancerTargetRequest) GetBalancerTag() string + func (x *OverrideBalancerTargetRequest) GetTarget() string + func (x *OverrideBalancerTargetRequest) ProtoReflect() protoreflect.Message + func (x *OverrideBalancerTargetRequest) Reset() + func (x *OverrideBalancerTargetRequest) String() string + type OverrideBalancerTargetResponse struct + func (*OverrideBalancerTargetResponse) Descriptor() ([]byte, []int) + func (*OverrideBalancerTargetResponse) ProtoMessage() + func (x *OverrideBalancerTargetResponse) ProtoReflect() protoreflect.Message + func (x *OverrideBalancerTargetResponse) Reset() + func (x *OverrideBalancerTargetResponse) String() string + type OverrideInfo struct + Target string + func (*OverrideInfo) Descriptor() ([]byte, []int) + func (*OverrideInfo) ProtoMessage() + func (x *OverrideInfo) GetTarget() string + func (x *OverrideInfo) ProtoReflect() protoreflect.Message + func (x *OverrideInfo) Reset() + func (x *OverrideInfo) String() string + type PrincipleTargetInfo struct + Tag []string + func (*PrincipleTargetInfo) Descriptor() ([]byte, []int) + func (*PrincipleTargetInfo) ProtoMessage() + func (x *PrincipleTargetInfo) GetTag() []string + func (x *PrincipleTargetInfo) ProtoReflect() protoreflect.Message + func (x *PrincipleTargetInfo) Reset() + func (x *PrincipleTargetInfo) 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 + GetBalancerInfo func(ctx context.Context, in *GetBalancerInfoRequest, opts ...grpc.CallOption) (*GetBalancerInfoResponse, error) + OverrideBalancerTarget func(ctx context.Context, in *OverrideBalancerTargetRequest, ...) (*OverrideBalancerTargetResponse, error) + 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 + GetBalancerInfo func(context.Context, *GetBalancerInfoRequest) (*GetBalancerInfoResponse, error) + OverrideBalancerTarget func(context.Context, *OverrideBalancerTargetRequest) (*OverrideBalancerTargetResponse, error) + 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) GetBalancerInfo(context.Context, *GetBalancerInfoRequest) (*GetBalancerInfoResponse, error) + func (UnimplementedRoutingServiceServer) OverrideBalancerTarget(context.Context, *OverrideBalancerTargetRequest) (*OverrideBalancerTargetResponse, error) + func (UnimplementedRoutingServiceServer) SubscribeRoutingStats(*SubscribeRoutingStatsRequest, RoutingService_SubscribeRoutingStatsServer) error + func (UnimplementedRoutingServiceServer) TestRoute(context.Context, *TestRouteRequest) (*RoutingContext, error) + type UnsafeRoutingServiceServer interface
Go to main page