clientgrpc

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 24, 2025 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClientService_Communicate_FullMethodName               = "/x.clientgrpc.ClientService/Communicate"
	ClientService_AddInbound_FullMethodName                = "/x.clientgrpc.ClientService/AddInbound"
	ClientService_RemoveInbound_FullMethodName             = "/x.clientgrpc.ClientService/RemoveInbound"
	ClientService_GetStatsStream_FullMethodName            = "/x.clientgrpc.ClientService/GetStatsStream"
	ClientService_SetOutboundHandlerSpeed_FullMethodName   = "/x.clientgrpc.ClientService/SetOutboundHandlerSpeed"
	ClientService_UserLogStream_FullMethodName             = "/x.clientgrpc.ClientService/UserLogStream"
	ClientService_ToggleUserLog_FullMethodName             = "/x.clientgrpc.ClientService/ToggleUserLog"
	ClientService_ToggleLogAppId_FullMethodName            = "/x.clientgrpc.ClientService/ToggleLogAppId"
	ClientService_ChangeOutbound_FullMethodName            = "/x.clientgrpc.ClientService/ChangeOutbound"
	ClientService_CurrentOutbound_FullMethodName           = "/x.clientgrpc.ClientService/CurrentOutbound"
	ClientService_ChangeRoutingMode_FullMethodName         = "/x.clientgrpc.ClientService/ChangeRoutingMode"
	ClientService_ChangeSelector_FullMethodName            = "/x.clientgrpc.ClientService/ChangeSelector"
	ClientService_UpdateSelectorBalancer_FullMethodName    = "/x.clientgrpc.ClientService/UpdateSelectorBalancer"
	ClientService_UpdateSelectorFilter_FullMethodName      = "/x.clientgrpc.ClientService/UpdateSelectorFilter"
	ClientService_NotifyHandlerChange_FullMethodName       = "/x.clientgrpc.ClientService/NotifyHandlerChange"
	ClientService_SwitchFakeDns_FullMethodName             = "/x.clientgrpc.ClientService/SwitchFakeDns"
	ClientService_UpdateGeo_FullMethodName                 = "/x.clientgrpc.ClientService/UpdateGeo"
	ClientService_AddGeoDomain_FullMethodName              = "/x.clientgrpc.ClientService/AddGeoDomain"
	ClientService_RemoveGeoDomain_FullMethodName           = "/x.clientgrpc.ClientService/RemoveGeoDomain"
	ClientService_ReplaceGeoDomains_FullMethodName         = "/x.clientgrpc.ClientService/ReplaceGeoDomains"
	ClientService_ReplaceGeoIPs_FullMethodName             = "/x.clientgrpc.ClientService/ReplaceGeoIPs"
	ClientService_UpdateRouter_FullMethodName              = "/x.clientgrpc.ClientService/UpdateRouter"
	ClientService_SetSubscriptionInterval_FullMethodName   = "/x.clientgrpc.ClientService/SetSubscriptionInterval"
	ClientService_SetAutoSubscriptionUpdate_FullMethodName = "/x.clientgrpc.ClientService/SetAutoSubscriptionUpdate"
	ClientService_RttTest_FullMethodName                   = "/x.clientgrpc.ClientService/RttTest"
)

Variables

View Source 
var ClientService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "x.clientgrpc.ClientService",
	HandlerType: (*ClientServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddInbound",
			Handler:    _ClientService_AddInbound_Handler,
		},
		{
			MethodName: "RemoveInbound",
			Handler:    _ClientService_RemoveInbound_Handler,
		},
		{
			MethodName: "SetOutboundHandlerSpeed",
			Handler:    _ClientService_SetOutboundHandlerSpeed_Handler,
		},
		{
			MethodName: "ToggleUserLog",
			Handler:    _ClientService_ToggleUserLog_Handler,
		},
		{
			MethodName: "ToggleLogAppId",
			Handler:    _ClientService_ToggleLogAppId_Handler,
		},
		{
			MethodName: "ChangeOutbound",
			Handler:    _ClientService_ChangeOutbound_Handler,
		},
		{
			MethodName: "CurrentOutbound",
			Handler:    _ClientService_CurrentOutbound_Handler,
		},
		{
			MethodName: "ChangeRoutingMode",
			Handler:    _ClientService_ChangeRoutingMode_Handler,
		},
		{
			MethodName: "ChangeSelector",
			Handler:    _ClientService_ChangeSelector_Handler,
		},
		{
			MethodName: "UpdateSelectorBalancer",
			Handler:    _ClientService_UpdateSelectorBalancer_Handler,
		},
		{
			MethodName: "UpdateSelectorFilter",
			Handler:    _ClientService_UpdateSelectorFilter_Handler,
		},
		{
			MethodName: "NotifyHandlerChange",
			Handler:    _ClientService_NotifyHandlerChange_Handler,
		},
		{
			MethodName: "SwitchFakeDns",
			Handler:    _ClientService_SwitchFakeDns_Handler,
		},
		{
			MethodName: "UpdateGeo",
			Handler:    _ClientService_UpdateGeo_Handler,
		},
		{
			MethodName: "AddGeoDomain",
			Handler:    _ClientService_AddGeoDomain_Handler,
		},
		{
			MethodName: "RemoveGeoDomain",
			Handler:    _ClientService_RemoveGeoDomain_Handler,
		},
		{
			MethodName: "ReplaceGeoDomains",
			Handler:    _ClientService_ReplaceGeoDomains_Handler,
		},
		{
			MethodName: "ReplaceGeoIPs",
			Handler:    _ClientService_ReplaceGeoIPs_Handler,
		},
		{
			MethodName: "UpdateRouter",
			Handler:    _ClientService_UpdateRouter_Handler,
		},
		{
			MethodName: "SetSubscriptionInterval",
			Handler:    _ClientService_SetSubscriptionInterval_Handler,
		},
		{
			MethodName: "SetAutoSubscriptionUpdate",
			Handler:    _ClientService_SetAutoSubscriptionUpdate_Handler,
		},
		{
			MethodName: "RttTest",
			Handler:    _ClientService_RttTest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Communicate",
			Handler:       _ClientService_Communicate_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetStatsStream",
			Handler:       _ClientService_GetStatsStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UserLogStream",
			Handler:       _ClientService_UserLogStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "app/clientgrpc/grpc.proto",
}

ClientService_ServiceDesc is the grpc.ServiceDesc for ClientService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_app_clientgrpc_grpc_proto protoreflect.FileDescriptor

Functions

func RegisterClientServiceServer 

func RegisterClientServiceServer(s grpc.ServiceRegistrar, srv ClientServiceServer)

Types

type AddGeoDomainRequest 

type AddGeoDomainRequest struct {
	DomainSetName string      `protobuf:"bytes,1,opt,name=domain_set_name,json=domainSetName,proto3" json:"domain_set_name,omitempty"`
	Domain        *geo.Domain `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*AddGeoDomainRequest) Descriptor deprecated 

func (*AddGeoDomainRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddGeoDomainRequest.ProtoReflect.Descriptor instead.

func (*AddGeoDomainRequest) GetDomain 

func (x *AddGeoDomainRequest) GetDomain() *geo.Domain

func (*AddGeoDomainRequest) GetDomainSetName 

func (x *AddGeoDomainRequest) GetDomainSetName() string

func (*AddGeoDomainRequest) ProtoMessage 

func (*AddGeoDomainRequest) ProtoMessage()

func (*AddGeoDomainRequest) ProtoReflect 

func (x *AddGeoDomainRequest) ProtoReflect() protoreflect.Message

func (*AddGeoDomainRequest) Reset 

func (x *AddGeoDomainRequest) Reset()

func (*AddGeoDomainRequest) String 

func (x *AddGeoDomainRequest) String() string

type AddInboundRequest 

type AddInboundRequest struct {
	HandlerConfig *configs.ProxyInboundConfig `protobuf:"bytes,1,opt,name=handler_config,json=handlerConfig,proto3" json:"handler_config,omitempty"`
	// contains filtered or unexported fields
}

inbound

func (*AddInboundRequest) Descriptor deprecated 

func (*AddInboundRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddInboundRequest.ProtoReflect.Descriptor instead.

func (*AddInboundRequest) GetHandlerConfig 

func (x *AddInboundRequest) GetHandlerConfig() *configs.ProxyInboundConfig

func (*AddInboundRequest) ProtoMessage 

func (*AddInboundRequest) ProtoMessage()

func (*AddInboundRequest) ProtoReflect 

func (x *AddInboundRequest) ProtoReflect() protoreflect.Message

func (*AddInboundRequest) Reset 

func (x *AddInboundRequest) Reset()

func (*AddInboundRequest) String 

func (x *AddInboundRequest) String() string

type AddInboundResponse 

type AddInboundResponse struct {
	// contains filtered or unexported fields
}

func (*AddInboundResponse) Descriptor deprecated 

func (*AddInboundResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddInboundResponse.ProtoReflect.Descriptor instead.

func (*AddInboundResponse) ProtoMessage 

func (*AddInboundResponse) ProtoMessage()

func (*AddInboundResponse) ProtoReflect 

func (x *AddInboundResponse) ProtoReflect() protoreflect.Message

func (*AddInboundResponse) Reset 

func (x *AddInboundResponse) Reset()

func (*AddInboundResponse) String 

func (x *AddInboundResponse) String() string

type ChangeOutboundRequest 

type ChangeOutboundRequest struct {

	// handlers to be added
	Handlers []*configs.HandlerConfig `protobuf:"bytes,1,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// handlers to be removed
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// delete all proxy outbound handlers
	DeleteAll bool `protobuf:"varint,3,opt,name=delete_all,json=deleteAll,proto3" json:"delete_all,omitempty"`
	// contains filtered or unexported fields
}

outbound

func (*ChangeOutboundRequest) Descriptor deprecated 

func (*ChangeOutboundRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangeOutboundRequest.ProtoReflect.Descriptor instead.

func (*ChangeOutboundRequest) GetDeleteAll 

func (x *ChangeOutboundRequest) GetDeleteAll() bool

func (*ChangeOutboundRequest) GetHandlers 

func (x *ChangeOutboundRequest) GetHandlers() []*configs.HandlerConfig

func (*ChangeOutboundRequest) GetTags 

func (x *ChangeOutboundRequest) GetTags() []string

func (*ChangeOutboundRequest) ProtoMessage 

func (*ChangeOutboundRequest) ProtoMessage()

func (*ChangeOutboundRequest) ProtoReflect 

func (x *ChangeOutboundRequest) ProtoReflect() protoreflect.Message

func (*ChangeOutboundRequest) Reset 

func (x *ChangeOutboundRequest) Reset()

func (*ChangeOutboundRequest) String 

func (x *ChangeOutboundRequest) String() string

type ChangeOutboundResponse 

type ChangeOutboundResponse struct {
	// contains filtered or unexported fields
}

func (*ChangeOutboundResponse) Descriptor deprecated 

func (*ChangeOutboundResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangeOutboundResponse.ProtoReflect.Descriptor instead.

func (*ChangeOutboundResponse) ProtoMessage 

func (*ChangeOutboundResponse) ProtoMessage()

func (*ChangeOutboundResponse) ProtoReflect 

func (x *ChangeOutboundResponse) ProtoReflect() protoreflect.Message

func (*ChangeOutboundResponse) Reset 

func (x *ChangeOutboundResponse) Reset()

func (*ChangeOutboundResponse) String 

func (x *ChangeOutboundResponse) String() string

type ChangeRoutingModeRequest 

type ChangeRoutingModeRequest struct {
	RouterConfig *configs.RouterConfig `protobuf:"bytes,1,opt,name=router_config,json=routerConfig,proto3" json:"router_config,omitempty"`
	GeoConfig    *configs.GeoConfig    `protobuf:"bytes,2,opt,name=geo_config,json=geoConfig,proto3" json:"geo_config,omitempty"`
	// contains filtered or unexported fields
}

routing

func (*ChangeRoutingModeRequest) Descriptor deprecated 

func (*ChangeRoutingModeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangeRoutingModeRequest.ProtoReflect.Descriptor instead.

func (*ChangeRoutingModeRequest) GetGeoConfig 

func (x *ChangeRoutingModeRequest) GetGeoConfig() *configs.GeoConfig

func (*ChangeRoutingModeRequest) GetRouterConfig 

func (x *ChangeRoutingModeRequest) GetRouterConfig() *configs.RouterConfig

func (*ChangeRoutingModeRequest) ProtoMessage 

func (*ChangeRoutingModeRequest) ProtoMessage()

func (*ChangeRoutingModeRequest) ProtoReflect 

func (x *ChangeRoutingModeRequest) ProtoReflect() protoreflect.Message

func (*ChangeRoutingModeRequest) Reset 

func (x *ChangeRoutingModeRequest) Reset()

func (*ChangeRoutingModeRequest) String 

func (x *ChangeRoutingModeRequest) String() string

type ChangeRoutingModeResponse 

type ChangeRoutingModeResponse struct {
	// contains filtered or unexported fields
}

func (*ChangeRoutingModeResponse) Descriptor deprecated 

func (*ChangeRoutingModeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangeRoutingModeResponse.ProtoReflect.Descriptor instead.

func (*ChangeRoutingModeResponse) ProtoMessage 

func (*ChangeRoutingModeResponse) ProtoMessage()

func (*ChangeRoutingModeResponse) ProtoReflect 

func (x *ChangeRoutingModeResponse) ProtoReflect() protoreflect.Message

func (*ChangeRoutingModeResponse) Reset 

func (x *ChangeRoutingModeResponse) Reset()

func (*ChangeRoutingModeResponse) String 

func (x *ChangeRoutingModeResponse) String() string

type ChangeSelectorRequest 

type ChangeSelectorRequest struct {
	SelectorsToAdd   []*configs.SelectorConfig `protobuf:"bytes,1,rep,name=selectors_to_add,json=selectorsToAdd,proto3" json:"selectors_to_add,omitempty"`
	SelectorToRemove string                    `protobuf:"bytes,2,opt,name=selector_to_remove,json=selectorToRemove,proto3" json:"selector_to_remove,omitempty"`
	DeleteAll        bool                      `protobuf:"varint,3,opt,name=delete_all,json=deleteAll,proto3" json:"delete_all,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeSelectorRequest) Descriptor deprecated 

func (*ChangeSelectorRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChangeSelectorRequest.ProtoReflect.Descriptor instead.

func (*ChangeSelectorRequest) GetDeleteAll 

func (x *ChangeSelectorRequest) GetDeleteAll() bool

func (*ChangeSelectorRequest) GetSelectorToRemove 

func (x *ChangeSelectorRequest) GetSelectorToRemove() string

func (*ChangeSelectorRequest) GetSelectorsToAdd 

func (x *ChangeSelectorRequest) GetSelectorsToAdd() []*configs.SelectorConfig

func (*ChangeSelectorRequest) ProtoMessage 

func (*ChangeSelectorRequest) ProtoMessage()

func (*ChangeSelectorRequest) ProtoReflect 

func (x *ChangeSelectorRequest) ProtoReflect() protoreflect.Message

func (*ChangeSelectorRequest) Reset 

func (x *ChangeSelectorRequest) Reset()

func (*ChangeSelectorRequest) String 

func (x *ChangeSelectorRequest) String() string

type ChangeSelectorResponse 

type ChangeSelectorResponse struct {
	// contains filtered or unexported fields
}

func (*ChangeSelectorResponse) Descriptor deprecated 

func (*ChangeSelectorResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChangeSelectorResponse.ProtoReflect.Descriptor instead.

func (*ChangeSelectorResponse) ProtoMessage 

func (*ChangeSelectorResponse) ProtoMessage()

func (*ChangeSelectorResponse) ProtoReflect 

func (x *ChangeSelectorResponse) ProtoReflect() protoreflect.Message

func (*ChangeSelectorResponse) Reset 

func (x *ChangeSelectorResponse) Reset()

func (*ChangeSelectorResponse) String 

func (x *ChangeSelectorResponse) String() string

type ClientGrpc 

type ClientGrpc struct {
	Client *client.Client

	Done       *done.Instance
	GrpcConfig *configs.GrpcConfig

	// if runningInService, when flutter side disconnect(meaning the app exits), call OnExit after 2 seconds
	RunningInService bool

	OnExit func()

	UpdateLantency bool

	UnimplementedClientServiceServer
	// contains filtered or unexported fields
}

func (*ClientGrpc) AddGeoDomain 

func (s *ClientGrpc) AddGeoDomain(ctx context.Context, in *AddGeoDomainRequest) (*Receipt, error)

func (*ClientGrpc) AddInbound 

func (s *ClientGrpc) AddInbound(ctx context.Context, req *AddInboundRequest) (*AddInboundResponse, error)

func (*ClientGrpc) ChangeOutbound 

func (s *ClientGrpc) ChangeOutbound(ctx context.Context, in *ChangeOutboundRequest) (*ChangeOutboundResponse, error)

func (*ClientGrpc) ChangeRoutingMode 

func (s *ClientGrpc) ChangeRoutingMode(ctx context.Context, in *ChangeRoutingModeRequest) (*ChangeRoutingModeResponse, error)

func (*ClientGrpc) ChangeSelector 

func (s *ClientGrpc) ChangeSelector(ctx context.Context, in *ChangeSelectorRequest) (*ChangeSelectorResponse, error)

func (*ClientGrpc) Close 

func (s *ClientGrpc) Close() error

func (*ClientGrpc) Communicate 

func (s *ClientGrpc) Communicate(in *CommunicateRequest, stream ClientService_CommunicateServer) error

func (*ClientGrpc) CurrentOutbound 

func (s *ClientGrpc) CurrentOutbound(ctx context.Context, in *CurrentOutboundRequest) (*CurrentOutboundResponse, error)

func (*ClientGrpc) DisableFakeDns 

func (d *ClientGrpc) DisableFakeDns() error

func (*ClientGrpc) EnableFakeDns 

func (d *ClientGrpc) EnableFakeDns() error

func (*ClientGrpc) GetStatsStream 

func (s *ClientGrpc) GetStatsStream(in *GetStatsRequest,
	stream ClientService_GetStatsStreamServer) error

func (*ClientGrpc) IPv6Result 

func (s *ClientGrpc) IPv6Result(tag string, ok bool)

func (*ClientGrpc) NotifyHandlerChange 

func (s *ClientGrpc) NotifyHandlerChange(context.Context, *HandlerChangeNotify) (*HandlerChangeNotifyResponse, error)

func (*ClientGrpc) OnHandlerBeingUsedUpdated 

func (s *ClientGrpc) OnHandlerBeingUsedUpdated(selector string, handlers []string)

func (*ClientGrpc) OnSubscriptionUpdated 

func (s *ClientGrpc) OnSubscriptionUpdated()

TODO: Lock?

func (*ClientGrpc) PingResult 

func (s *ClientGrpc) PingResult(tag string, ping int)

func (*ClientGrpc) RemoveGeoDomain 

func (s *ClientGrpc) RemoveGeoDomain(ctx context.Context, in *RemoveGeoDomainRequest) (*Receipt, error)

func (*ClientGrpc) RemoveInbound 

func (s *ClientGrpc) RemoveInbound(ctx context.Context, in *RemoveInboundRequest) (*RemoveInboundResponse, error)

func (*ClientGrpc) ReplaceGeoDomains 

func (s *ClientGrpc) ReplaceGeoDomains(ctx context.Context, in *ReplaceDomainSetRequest) (*Receipt, error)

func (*ClientGrpc) ReplaceGeoIPs 

func (s *ClientGrpc) ReplaceGeoIPs(ctx context.Context, in *ReplaceIPSetRequest) (*Receipt, error)

func (*ClientGrpc) RttTest 

func (s *ClientGrpc) RttTest(ctx context.Context, req *RttTestRequest) (*RttTestResponse, error)

func (*ClientGrpc) SetAutoSubscriptionUpdate 

func (s *ClientGrpc) SetAutoSubscriptionUpdate(ctx context.Context, req *SetAutoSubscriptionUpdateRequest) (*Receipt, error)

func (*ClientGrpc) SetOutboundHandlerSpeed 

func (s *ClientGrpc) SetOutboundHandlerSpeed(ctx context.Context, in *SetOutboundHandlerSpeedRequest) (*SetOutboundHandlerSpeedResponse, error)

func (*ClientGrpc) SetSubscriptionInterval 

func (s *ClientGrpc) SetSubscriptionInterval(ctx context.Context, req *SetSubscriptionIntervalRequest) (*SetSubscriptionIntervalResponse, error)

func (*ClientGrpc) SpeedResult 

func (s *ClientGrpc) SpeedResult(tag string, speed int64)

func (*ClientGrpc) Start 

func (s *ClientGrpc) Start() error

func (*ClientGrpc) SwitchFakeDns 

func (s *ClientGrpc) SwitchFakeDns(ctx context.Context, in *SwitchFakeDnsRequest) (*SwitchFakeDnsResponse, error)

should not be called concurrently

func (*ClientGrpc) ToggleLogAppId 

func (s *ClientGrpc) ToggleLogAppId(ctx context.Context, in *ToggleLogAppIdRequest) (*ToggleLogAppIdResponse, error)

func (*ClientGrpc) ToggleUserLog 

func (s *ClientGrpc) ToggleUserLog(ctx context.Context, in *ToggleUserLogRequest) (*ToggleUserLogResponse, error)

func (*ClientGrpc) UpdateGeo 

func (s *ClientGrpc) UpdateGeo(ctx context.Context, in *UpdateGeoRequest) (*UpdateGeoResponse, error)

TODO: more efficient

func (*ClientGrpc) UpdateRouter 

func (s *ClientGrpc) UpdateRouter(ctx context.Context, in *UpdateRouterRequest) (*UpdateRouterResponse, error)

func (*ClientGrpc) UpdateSelectorBalancer 

func (s *ClientGrpc) UpdateSelectorBalancer(ctx context.Context, in *UpdateSelectorBalancerRequest) (*Receipt, error)

func (*ClientGrpc) UpdateSelectorFilter 

func (s *ClientGrpc) UpdateSelectorFilter(ctx context.Context, in *UpdateSelectorFilterRequest) (*Receipt, error)

func (*ClientGrpc) UsableResult 

func (s *ClientGrpc) UsableResult(tag string, ok bool)

func (*ClientGrpc) UserLogStream 

func (s *ClientGrpc) UserLogStream(in *UserLogStreamRequest, stream ClientService_UserLogStreamServer) error

type ClientServiceClient 

type ClientServiceClient interface {
	// server to client
	Communicate(ctx context.Context, in *CommunicateRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CommunicateMessage], error)
	// inbound
	AddInbound(ctx context.Context, in *AddInboundRequest, opts ...grpc.CallOption) (*AddInboundResponse, error)
	RemoveInbound(ctx context.Context, in *RemoveInboundRequest, opts ...grpc.CallOption) (*RemoveInboundResponse, error)
	// stats
	GetStatsStream(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StatsResponse], error)
	SetOutboundHandlerSpeed(ctx context.Context, in *SetOutboundHandlerSpeedRequest, opts ...grpc.CallOption) (*SetOutboundHandlerSpeedResponse, error)
	// log
	// rpc ChangeLogLevel(ChangeLogLevelRequest) returns (ChangeLogLevelResponse);
	// rpc LogStream(LogStreamRequest) returns (stream LogMessage);
	UserLogStream(ctx context.Context, in *UserLogStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[userlogger.UserLogMessage], error)
	ToggleUserLog(ctx context.Context, in *ToggleUserLogRequest, opts ...grpc.CallOption) (*ToggleUserLogResponse, error)
	ToggleLogAppId(ctx context.Context, in *ToggleLogAppIdRequest, opts ...grpc.CallOption) (*ToggleLogAppIdResponse, error)
	// outbound
	ChangeOutbound(ctx context.Context, in *ChangeOutboundRequest, opts ...grpc.CallOption) (*ChangeOutboundResponse, error)
	CurrentOutbound(ctx context.Context, in *CurrentOutboundRequest, opts ...grpc.CallOption) (*CurrentOutboundResponse, error)
	// routing
	ChangeRoutingMode(ctx context.Context, in *ChangeRoutingModeRequest, opts ...grpc.CallOption) (*ChangeRoutingModeResponse, error)
	ChangeSelector(ctx context.Context, in *ChangeSelectorRequest, opts ...grpc.CallOption) (*ChangeSelectorResponse, error)
	UpdateSelectorBalancer(ctx context.Context, in *UpdateSelectorBalancerRequest, opts ...grpc.CallOption) (*Receipt, error)
	UpdateSelectorFilter(ctx context.Context, in *UpdateSelectorFilterRequest, opts ...grpc.CallOption) (*Receipt, error)
	NotifyHandlerChange(ctx context.Context, in *HandlerChangeNotify, opts ...grpc.CallOption) (*HandlerChangeNotifyResponse, error)
	// fake dns
	SwitchFakeDns(ctx context.Context, in *SwitchFakeDnsRequest, opts ...grpc.CallOption) (*SwitchFakeDnsResponse, error)
	// geo
	UpdateGeo(ctx context.Context, in *UpdateGeoRequest, opts ...grpc.CallOption) (*UpdateGeoResponse, error)
	AddGeoDomain(ctx context.Context, in *AddGeoDomainRequest, opts ...grpc.CallOption) (*Receipt, error)
	RemoveGeoDomain(ctx context.Context, in *RemoveGeoDomainRequest, opts ...grpc.CallOption) (*Receipt, error)
	ReplaceGeoDomains(ctx context.Context, in *ReplaceDomainSetRequest, opts ...grpc.CallOption) (*Receipt, error)
	ReplaceGeoIPs(ctx context.Context, in *ReplaceIPSetRequest, opts ...grpc.CallOption) (*Receipt, error)
	// app id
	UpdateRouter(ctx context.Context, in *UpdateRouterRequest, opts ...grpc.CallOption) (*UpdateRouterResponse, error)
	// subscription
	SetSubscriptionInterval(ctx context.Context, in *SetSubscriptionIntervalRequest, opts ...grpc.CallOption) (*SetSubscriptionIntervalResponse, error)
	SetAutoSubscriptionUpdate(ctx context.Context, in *SetAutoSubscriptionUpdateRequest, opts ...grpc.CallOption) (*Receipt, error)
	RttTest(ctx context.Context, in *RttTestRequest, opts ...grpc.CallOption) (*RttTestResponse, error)
}

ClientServiceClient is the client API for ClientService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClientServiceClient 

func NewClientServiceClient(cc grpc.ClientConnInterface) ClientServiceClient

type ClientServiceServer 

type ClientServiceServer interface {
	// server to client
	Communicate(*CommunicateRequest, grpc.ServerStreamingServer[CommunicateMessage]) error
	// inbound
	AddInbound(context.Context, *AddInboundRequest) (*AddInboundResponse, error)
	RemoveInbound(context.Context, *RemoveInboundRequest) (*RemoveInboundResponse, error)
	// stats
	GetStatsStream(*GetStatsRequest, grpc.ServerStreamingServer[StatsResponse]) error
	SetOutboundHandlerSpeed(context.Context, *SetOutboundHandlerSpeedRequest) (*SetOutboundHandlerSpeedResponse, error)
	// log
	// rpc ChangeLogLevel(ChangeLogLevelRequest) returns (ChangeLogLevelResponse);
	// rpc LogStream(LogStreamRequest) returns (stream LogMessage);
	UserLogStream(*UserLogStreamRequest, grpc.ServerStreamingServer[userlogger.UserLogMessage]) error
	ToggleUserLog(context.Context, *ToggleUserLogRequest) (*ToggleUserLogResponse, error)
	ToggleLogAppId(context.Context, *ToggleLogAppIdRequest) (*ToggleLogAppIdResponse, error)
	// outbound
	ChangeOutbound(context.Context, *ChangeOutboundRequest) (*ChangeOutboundResponse, error)
	CurrentOutbound(context.Context, *CurrentOutboundRequest) (*CurrentOutboundResponse, error)
	// routing
	ChangeRoutingMode(context.Context, *ChangeRoutingModeRequest) (*ChangeRoutingModeResponse, error)
	ChangeSelector(context.Context, *ChangeSelectorRequest) (*ChangeSelectorResponse, error)
	UpdateSelectorBalancer(context.Context, *UpdateSelectorBalancerRequest) (*Receipt, error)
	UpdateSelectorFilter(context.Context, *UpdateSelectorFilterRequest) (*Receipt, error)
	NotifyHandlerChange(context.Context, *HandlerChangeNotify) (*HandlerChangeNotifyResponse, error)
	// fake dns
	SwitchFakeDns(context.Context, *SwitchFakeDnsRequest) (*SwitchFakeDnsResponse, error)
	// geo
	UpdateGeo(context.Context, *UpdateGeoRequest) (*UpdateGeoResponse, error)
	AddGeoDomain(context.Context, *AddGeoDomainRequest) (*Receipt, error)
	RemoveGeoDomain(context.Context, *RemoveGeoDomainRequest) (*Receipt, error)
	ReplaceGeoDomains(context.Context, *ReplaceDomainSetRequest) (*Receipt, error)
	ReplaceGeoIPs(context.Context, *ReplaceIPSetRequest) (*Receipt, error)
	// app id
	UpdateRouter(context.Context, *UpdateRouterRequest) (*UpdateRouterResponse, error)
	// subscription
	SetSubscriptionInterval(context.Context, *SetSubscriptionIntervalRequest) (*SetSubscriptionIntervalResponse, error)
	SetAutoSubscriptionUpdate(context.Context, *SetAutoSubscriptionUpdateRequest) (*Receipt, error)
	RttTest(context.Context, *RttTestRequest) (*RttTestResponse, error)
	// contains filtered or unexported methods
}

ClientServiceServer is the server API for ClientService service. All implementations must embed UnimplementedClientServiceServer for forward compatibility.

type ClientService_CommunicateClient 

type ClientService_CommunicateClient = grpc.ServerStreamingClient[CommunicateMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ClientService_CommunicateServer 

type ClientService_CommunicateServer = grpc.ServerStreamingServer[CommunicateMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ClientService_GetStatsStreamClient 

type ClientService_GetStatsStreamClient = grpc.ServerStreamingClient[StatsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ClientService_GetStatsStreamServer 

type ClientService_GetStatsStreamServer = grpc.ServerStreamingServer[StatsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ClientService_UserLogStreamClient 

type ClientService_UserLogStreamClient = grpc.ServerStreamingClient[userlogger.UserLogMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ClientService_UserLogStreamServer 

type ClientService_UserLogStreamServer = grpc.ServerStreamingServer[userlogger.UserLogMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CommunicateMessage 

type CommunicateMessage struct {

	// Types that are valid to be assigned to Message:
	//
	//	*CommunicateMessage_HandlerError
	//	*CommunicateMessage_SubscriptionUpdate
	//	*CommunicateMessage_HandlerBeingUsed
	//	*CommunicateMessage_HandlerUpdated
	Message isCommunicateMessage_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*CommunicateMessage) Descriptor deprecated 

func (*CommunicateMessage) Descriptor() ([]byte, []int)

Deprecated: Use CommunicateMessage.ProtoReflect.Descriptor instead.

func (*CommunicateMessage) GetHandlerBeingUsed 

func (x *CommunicateMessage) GetHandlerBeingUsed() *HandlerBeingUsed

func (*CommunicateMessage) GetHandlerError 

func (x *CommunicateMessage) GetHandlerError() *HandlerError

func (*CommunicateMessage) GetHandlerUpdated 

func (x *CommunicateMessage) GetHandlerUpdated() *HandlerUpdated

func (*CommunicateMessage) GetMessage 

func (x *CommunicateMessage) GetMessage() isCommunicateMessage_Message

func (*CommunicateMessage) GetSubscriptionUpdate 

func (x *CommunicateMessage) GetSubscriptionUpdate() *SubscriptionUpdated

func (*CommunicateMessage) ProtoMessage 

func (*CommunicateMessage) ProtoMessage()

func (*CommunicateMessage) ProtoReflect 

func (x *CommunicateMessage) ProtoReflect() protoreflect.Message

func (*CommunicateMessage) Reset 

func (x *CommunicateMessage) Reset()

func (*CommunicateMessage) String 

func (x *CommunicateMessage) String() string

type CommunicateMessage_HandlerBeingUsed 

type CommunicateMessage_HandlerBeingUsed struct {
	HandlerBeingUsed *HandlerBeingUsed `protobuf:"bytes,3,opt,name=handler_being_used,json=handlerBeingUsed,proto3,oneof"`
}

type CommunicateMessage_HandlerError 

type CommunicateMessage_HandlerError struct {
	HandlerError *HandlerError `protobuf:"bytes,1,opt,name=handler_error,json=handlerError,proto3,oneof"`
}

type CommunicateMessage_HandlerUpdated 

type CommunicateMessage_HandlerUpdated struct {
	HandlerUpdated *HandlerUpdated `protobuf:"bytes,4,opt,name=handler_updated,json=handlerUpdated,proto3,oneof"`
}

type CommunicateMessage_SubscriptionUpdate 

type CommunicateMessage_SubscriptionUpdate struct {
	SubscriptionUpdate *SubscriptionUpdated `protobuf:"bytes,2,opt,name=subscription_update,json=subscriptionUpdate,proto3,oneof"`
}

type CommunicateRequest 

type CommunicateRequest struct {
	// contains filtered or unexported fields
}

func (*CommunicateRequest) Descriptor deprecated 

func (*CommunicateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommunicateRequest.ProtoReflect.Descriptor instead.

func (*CommunicateRequest) ProtoMessage 

func (*CommunicateRequest) ProtoMessage()

func (*CommunicateRequest) ProtoReflect 

func (x *CommunicateRequest) ProtoReflect() protoreflect.Message

func (*CommunicateRequest) Reset 

func (x *CommunicateRequest) Reset()

func (*CommunicateRequest) String 

func (x *CommunicateRequest) String() string

type CurrentOutboundRequest 

type CurrentOutboundRequest struct {
	// contains filtered or unexported fields
}

func (*CurrentOutboundRequest) Descriptor deprecated 

func (*CurrentOutboundRequest) Descriptor() ([]byte, []int)

Deprecated: Use CurrentOutboundRequest.ProtoReflect.Descriptor instead.

func (*CurrentOutboundRequest) ProtoMessage 

func (*CurrentOutboundRequest) ProtoMessage()

func (*CurrentOutboundRequest) ProtoReflect 

func (x *CurrentOutboundRequest) ProtoReflect() protoreflect.Message

func (*CurrentOutboundRequest) Reset 

func (x *CurrentOutboundRequest) Reset()

func (*CurrentOutboundRequest) String 

func (x *CurrentOutboundRequest) String() string

type CurrentOutboundResponse 

type CurrentOutboundResponse struct {
	OutboundTags []string `protobuf:"bytes,1,rep,name=outbound_tags,json=outboundTags,proto3" json:"outbound_tags,omitempty"`
	// contains filtered or unexported fields
}

func (*CurrentOutboundResponse) Descriptor deprecated 

func (*CurrentOutboundResponse) Descriptor() ([]byte, []int)

Deprecated: Use CurrentOutboundResponse.ProtoReflect.Descriptor instead.

func (*CurrentOutboundResponse) GetOutboundTags 

func (x *CurrentOutboundResponse) GetOutboundTags() []string

func (*CurrentOutboundResponse) ProtoMessage 

func (*CurrentOutboundResponse) ProtoMessage()

func (*CurrentOutboundResponse) ProtoReflect 

func (x *CurrentOutboundResponse) ProtoReflect() protoreflect.Message

func (*CurrentOutboundResponse) Reset 

func (x *CurrentOutboundResponse) Reset()

func (*CurrentOutboundResponse) String 

func (x *CurrentOutboundResponse) String() string

type GetStatsRequest 

type GetStatsRequest struct {
	Interval uint32 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatsRequest) Descriptor deprecated 

func (*GetStatsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatsRequest.ProtoReflect.Descriptor instead.

func (*GetStatsRequest) GetInterval 

func (x *GetStatsRequest) GetInterval() uint32

func (*GetStatsRequest) ProtoMessage 

func (*GetStatsRequest) ProtoMessage()

func (*GetStatsRequest) ProtoReflect 

func (x *GetStatsRequest) ProtoReflect() protoreflect.Message

func (*GetStatsRequest) Reset 

func (x *GetStatsRequest) Reset()

func (*GetStatsRequest) String 

func (x *GetStatsRequest) String() string

type HandlerBeingUsed 

type HandlerBeingUsed struct {
	Tag4 string `protobuf:"bytes,1,opt,name=tag4,proto3" json:"tag4,omitempty"`
	Tag6 string `protobuf:"bytes,2,opt,name=tag6,proto3" json:"tag6,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerBeingUsed) Descriptor deprecated 

func (*HandlerBeingUsed) Descriptor() ([]byte, []int)

Deprecated: Use HandlerBeingUsed.ProtoReflect.Descriptor instead.

func (*HandlerBeingUsed) GetTag4 

func (x *HandlerBeingUsed) GetTag4() string

func (*HandlerBeingUsed) GetTag6 

func (x *HandlerBeingUsed) GetTag6() string

func (*HandlerBeingUsed) ProtoMessage 

func (*HandlerBeingUsed) ProtoMessage()

func (*HandlerBeingUsed) ProtoReflect 

func (x *HandlerBeingUsed) ProtoReflect() protoreflect.Message

func (*HandlerBeingUsed) Reset 

func (x *HandlerBeingUsed) Reset()

func (*HandlerBeingUsed) String 

func (x *HandlerBeingUsed) String() string

type HandlerChangeNotify 

type HandlerChangeNotify struct {
	// contains filtered or unexported fields
}

func (*HandlerChangeNotify) Descriptor deprecated 

func (*HandlerChangeNotify) Descriptor() ([]byte, []int)

Deprecated: Use HandlerChangeNotify.ProtoReflect.Descriptor instead.

func (*HandlerChangeNotify) ProtoMessage 

func (*HandlerChangeNotify) ProtoMessage()

func (*HandlerChangeNotify) ProtoReflect 

func (x *HandlerChangeNotify) ProtoReflect() protoreflect.Message

func (*HandlerChangeNotify) Reset 

func (x *HandlerChangeNotify) Reset()

func (*HandlerChangeNotify) String 

func (x *HandlerChangeNotify) String() string

type HandlerChangeNotifyResponse 

type HandlerChangeNotifyResponse struct {
	// contains filtered or unexported fields
}

func (*HandlerChangeNotifyResponse) Descriptor deprecated 

func (*HandlerChangeNotifyResponse) Descriptor() ([]byte, []int)

Deprecated: Use HandlerChangeNotifyResponse.ProtoReflect.Descriptor instead.

func (*HandlerChangeNotifyResponse) ProtoMessage 

func (*HandlerChangeNotifyResponse) ProtoMessage()

func (*HandlerChangeNotifyResponse) ProtoReflect 

func (x *HandlerChangeNotifyResponse) ProtoReflect() protoreflect.Message

func (*HandlerChangeNotifyResponse) Reset 

func (x *HandlerChangeNotifyResponse) Reset()

func (*HandlerChangeNotifyResponse) String 

func (x *HandlerChangeNotifyResponse) String() string

type HandlerError 

type HandlerError struct {
	Tag   string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerError) Descriptor deprecated 

func (*HandlerError) Descriptor() ([]byte, []int)

Deprecated: Use HandlerError.ProtoReflect.Descriptor instead.

func (*HandlerError) GetError 

func (x *HandlerError) GetError() string

func (*HandlerError) GetTag 

func (x *HandlerError) GetTag() string

func (*HandlerError) ProtoMessage 

func (*HandlerError) ProtoMessage()

func (*HandlerError) ProtoReflect 

func (x *HandlerError) ProtoReflect() protoreflect.Message

func (*HandlerError) Reset 

func (x *HandlerError) Reset()

func (*HandlerError) String 

func (x *HandlerError) String() string

type HandlerUpdated 

type HandlerUpdated struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerUpdated) Descriptor deprecated 

func (*HandlerUpdated) Descriptor() ([]byte, []int)

Deprecated: Use HandlerUpdated.ProtoReflect.Descriptor instead.

func (*HandlerUpdated) GetId 

func (x *HandlerUpdated) GetId() int64

func (*HandlerUpdated) ProtoMessage 

func (*HandlerUpdated) ProtoMessage()

func (*HandlerUpdated) ProtoReflect 

func (x *HandlerUpdated) ProtoReflect() protoreflect.Message

func (*HandlerUpdated) Reset 

func (x *HandlerUpdated) Reset()

func (*HandlerUpdated) String 

func (x *HandlerUpdated) String() string

type OutboundStats 

type OutboundStats struct {
	Up   uint64 `protobuf:"varint,1,opt,name=up,proto3" json:"up,omitempty"`
	Down uint64 `protobuf:"varint,2,opt,name=down,proto3" json:"down,omitempty"`
	// download
	Rate uint64 `protobuf:"varint,3,opt,name=rate,proto3" json:"rate,omitempty"`
	Ping uint64 `protobuf:"varint,4,opt,name=ping,proto3" json:"ping,omitempty"`
	Id   string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*OutboundStats) Descriptor deprecated 

func (*OutboundStats) Descriptor() ([]byte, []int)

Deprecated: Use OutboundStats.ProtoReflect.Descriptor instead.

func (*OutboundStats) GetDown 

func (x *OutboundStats) GetDown() uint64

func (*OutboundStats) GetId 

func (x *OutboundStats) GetId() string

func (*OutboundStats) GetPing 

func (x *OutboundStats) GetPing() uint64

func (*OutboundStats) GetRate 

func (x *OutboundStats) GetRate() uint64

func (*OutboundStats) GetUp 

func (x *OutboundStats) GetUp() uint64

func (*OutboundStats) ProtoMessage 

func (*OutboundStats) ProtoMessage()

func (*OutboundStats) ProtoReflect 

func (x *OutboundStats) ProtoReflect() protoreflect.Message

func (*OutboundStats) Reset 

func (x *OutboundStats) Reset()

func (*OutboundStats) String 

func (x *OutboundStats) String() string

type Receipt 

type Receipt struct {
	// contains filtered or unexported fields
}

func (*Receipt) Descriptor deprecated 

func (*Receipt) Descriptor() ([]byte, []int)

Deprecated: Use Receipt.ProtoReflect.Descriptor instead.

func (*Receipt) ProtoMessage 

func (*Receipt) ProtoMessage()

func (*Receipt) ProtoReflect 

func (x *Receipt) ProtoReflect() protoreflect.Message

func (*Receipt) Reset 

func (x *Receipt) Reset()

func (*Receipt) String 

func (x *Receipt) String() string

type RemoveGeoDomainRequest 

type RemoveGeoDomainRequest struct {
	DomainSetName string      `protobuf:"bytes,1,opt,name=domain_set_name,json=domainSetName,proto3" json:"domain_set_name,omitempty"`
	Domain        *geo.Domain `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveGeoDomainRequest) Descriptor deprecated 

func (*RemoveGeoDomainRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveGeoDomainRequest.ProtoReflect.Descriptor instead.

func (*RemoveGeoDomainRequest) GetDomain 

func (x *RemoveGeoDomainRequest) GetDomain() *geo.Domain

func (*RemoveGeoDomainRequest) GetDomainSetName 

func (x *RemoveGeoDomainRequest) GetDomainSetName() string

func (*RemoveGeoDomainRequest) ProtoMessage 

func (*RemoveGeoDomainRequest) ProtoMessage()

func (*RemoveGeoDomainRequest) ProtoReflect 

func (x *RemoveGeoDomainRequest) ProtoReflect() protoreflect.Message

func (*RemoveGeoDomainRequest) Reset 

func (x *RemoveGeoDomainRequest) Reset()

func (*RemoveGeoDomainRequest) String 

func (x *RemoveGeoDomainRequest) String() string

type RemoveInboundRequest 

type RemoveInboundRequest struct {
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveInboundRequest) Descriptor deprecated 

func (*RemoveInboundRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveInboundRequest.ProtoReflect.Descriptor instead.

func (*RemoveInboundRequest) GetTag 

func (x *RemoveInboundRequest) GetTag() string

func (*RemoveInboundRequest) ProtoMessage 

func (*RemoveInboundRequest) ProtoMessage()

func (*RemoveInboundRequest) ProtoReflect 

func (x *RemoveInboundRequest) ProtoReflect() protoreflect.Message

func (*RemoveInboundRequest) Reset 

func (x *RemoveInboundRequest) Reset()

func (*RemoveInboundRequest) String 

func (x *RemoveInboundRequest) String() string

type RemoveInboundResponse 

type RemoveInboundResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveInboundResponse) Descriptor deprecated 

func (*RemoveInboundResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveInboundResponse.ProtoReflect.Descriptor instead.

func (*RemoveInboundResponse) ProtoMessage 

func (*RemoveInboundResponse) ProtoMessage()

func (*RemoveInboundResponse) ProtoReflect 

func (x *RemoveInboundResponse) ProtoReflect() protoreflect.Message

func (*RemoveInboundResponse) Reset 

func (x *RemoveInboundResponse) Reset()

func (*RemoveInboundResponse) String 

func (x *RemoveInboundResponse) String() string

type ReplaceDomainSetRequest 

type ReplaceDomainSetRequest struct {
	Set *configs.AtomicDomainSetConfig `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceDomainSetRequest) Descriptor deprecated 

func (*ReplaceDomainSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceDomainSetRequest.ProtoReflect.Descriptor instead.

func (*ReplaceDomainSetRequest) GetSet 

func (x *ReplaceDomainSetRequest) GetSet() *configs.AtomicDomainSetConfig

func (*ReplaceDomainSetRequest) ProtoMessage 

func (*ReplaceDomainSetRequest) ProtoMessage()

func (*ReplaceDomainSetRequest) ProtoReflect 

func (x *ReplaceDomainSetRequest) ProtoReflect() protoreflect.Message

func (*ReplaceDomainSetRequest) Reset 

func (x *ReplaceDomainSetRequest) Reset()

func (*ReplaceDomainSetRequest) String 

func (x *ReplaceDomainSetRequest) String() string

type ReplaceIPSetRequest 

type ReplaceIPSetRequest struct {
	Set *configs.AtomicIPSetConfig `protobuf:"bytes,1,opt,name=set,proto3" json:"set,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceIPSetRequest) Descriptor deprecated 

func (*ReplaceIPSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceIPSetRequest.ProtoReflect.Descriptor instead.

func (*ReplaceIPSetRequest) GetSet 

func (x *ReplaceIPSetRequest) GetSet() *configs.AtomicIPSetConfig

func (*ReplaceIPSetRequest) ProtoMessage 

func (*ReplaceIPSetRequest) ProtoMessage()

func (*ReplaceIPSetRequest) ProtoReflect 

func (x *ReplaceIPSetRequest) ProtoReflect() protoreflect.Message

func (*ReplaceIPSetRequest) Reset 

func (x *ReplaceIPSetRequest) Reset()

func (*ReplaceIPSetRequest) String 

func (x *ReplaceIPSetRequest) String() string

type RttTestRequest 

type RttTestRequest struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*RttTestRequest) Descriptor deprecated 

func (*RttTestRequest) Descriptor() ([]byte, []int)

Deprecated: Use RttTestRequest.ProtoReflect.Descriptor instead.

func (*RttTestRequest) GetAddr 

func (x *RttTestRequest) GetAddr() string

func (*RttTestRequest) GetPort 

func (x *RttTestRequest) GetPort() uint32

func (*RttTestRequest) ProtoMessage 

func (*RttTestRequest) ProtoMessage()

func (*RttTestRequest) ProtoReflect 

func (x *RttTestRequest) ProtoReflect() protoreflect.Message

func (*RttTestRequest) Reset 

func (x *RttTestRequest) Reset()

func (*RttTestRequest) String 

func (x *RttTestRequest) String() string

type RttTestResponse 

type RttTestResponse struct {
	Ping uint32 `protobuf:"varint,1,opt,name=ping,proto3" json:"ping,omitempty"`
	// contains filtered or unexported fields
}

func (*RttTestResponse) Descriptor deprecated 

func (*RttTestResponse) Descriptor() ([]byte, []int)

Deprecated: Use RttTestResponse.ProtoReflect.Descriptor instead.

func (*RttTestResponse) GetPing 

func (x *RttTestResponse) GetPing() uint32

func (*RttTestResponse) ProtoMessage 

func (*RttTestResponse) ProtoMessage()

func (*RttTestResponse) ProtoReflect 

func (x *RttTestResponse) ProtoReflect() protoreflect.Message

func (*RttTestResponse) Reset 

func (x *RttTestResponse) Reset()

func (*RttTestResponse) String 

func (x *RttTestResponse) String() string

type SetAutoSubscriptionUpdateRequest 

type SetAutoSubscriptionUpdateRequest struct {
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAutoSubscriptionUpdateRequest) Descriptor deprecated 

func (*SetAutoSubscriptionUpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetAutoSubscriptionUpdateRequest.ProtoReflect.Descriptor instead.

func (*SetAutoSubscriptionUpdateRequest) GetEnable 

func (x *SetAutoSubscriptionUpdateRequest) GetEnable() bool

func (*SetAutoSubscriptionUpdateRequest) ProtoMessage 

func (*SetAutoSubscriptionUpdateRequest) ProtoMessage()

func (*SetAutoSubscriptionUpdateRequest) ProtoReflect 

func (x *SetAutoSubscriptionUpdateRequest) ProtoReflect() protoreflect.Message

func (*SetAutoSubscriptionUpdateRequest) Reset 

func (x *SetAutoSubscriptionUpdateRequest) Reset()

func (*SetAutoSubscriptionUpdateRequest) String 

func (x *SetAutoSubscriptionUpdateRequest) String() string

type SetOutboundHandlerSpeedRequest 

type SetOutboundHandlerSpeedRequest struct {
	Tag   string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Speed int32  `protobuf:"varint,2,opt,name=speed,proto3" json:"speed,omitempty"`
	// contains filtered or unexported fields
}

func (*SetOutboundHandlerSpeedRequest) Descriptor deprecated 

func (*SetOutboundHandlerSpeedRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetOutboundHandlerSpeedRequest.ProtoReflect.Descriptor instead.

func (*SetOutboundHandlerSpeedRequest) GetSpeed 

func (x *SetOutboundHandlerSpeedRequest) GetSpeed() int32

func (*SetOutboundHandlerSpeedRequest) GetTag 

func (x *SetOutboundHandlerSpeedRequest) GetTag() string

func (*SetOutboundHandlerSpeedRequest) ProtoMessage 

func (*SetOutboundHandlerSpeedRequest) ProtoMessage()

func (*SetOutboundHandlerSpeedRequest) ProtoReflect 

func (x *SetOutboundHandlerSpeedRequest) ProtoReflect() protoreflect.Message

func (*SetOutboundHandlerSpeedRequest) Reset 

func (x *SetOutboundHandlerSpeedRequest) Reset()

func (*SetOutboundHandlerSpeedRequest) String 

func (x *SetOutboundHandlerSpeedRequest) String() string

type SetOutboundHandlerSpeedResponse 

type SetOutboundHandlerSpeedResponse struct {
	// contains filtered or unexported fields
}

func (*SetOutboundHandlerSpeedResponse) Descriptor deprecated 

func (*SetOutboundHandlerSpeedResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetOutboundHandlerSpeedResponse.ProtoReflect.Descriptor instead.

func (*SetOutboundHandlerSpeedResponse) ProtoMessage 

func (*SetOutboundHandlerSpeedResponse) ProtoMessage()

func (*SetOutboundHandlerSpeedResponse) ProtoReflect 

func (x *SetOutboundHandlerSpeedResponse) ProtoReflect() protoreflect.Message

func (*SetOutboundHandlerSpeedResponse) Reset 

func (x *SetOutboundHandlerSpeedResponse) Reset()

func (*SetOutboundHandlerSpeedResponse) String 

func (x *SetOutboundHandlerSpeedResponse) String() string

type SetProxyShareRequest 

type SetProxyShareRequest struct {
	Enable     bool   `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	ListenAddr string `protobuf:"bytes,2,opt,name=listen_addr,json=listenAddr,proto3" json:"listen_addr,omitempty"`
	ListenPort uint32 `protobuf:"varint,3,opt,name=listen_port,json=listenPort,proto3" json:"listen_port,omitempty"`
	// contains filtered or unexported fields
}

func (*SetProxyShareRequest) Descriptor deprecated 

func (*SetProxyShareRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetProxyShareRequest.ProtoReflect.Descriptor instead.

func (*SetProxyShareRequest) GetEnable 

func (x *SetProxyShareRequest) GetEnable() bool

func (*SetProxyShareRequest) GetListenAddr 

func (x *SetProxyShareRequest) GetListenAddr() string

func (*SetProxyShareRequest) GetListenPort 

func (x *SetProxyShareRequest) GetListenPort() uint32

func (*SetProxyShareRequest) ProtoMessage 

func (*SetProxyShareRequest) ProtoMessage()

func (*SetProxyShareRequest) ProtoReflect 

func (x *SetProxyShareRequest) ProtoReflect() protoreflect.Message

func (*SetProxyShareRequest) Reset 

func (x *SetProxyShareRequest) Reset()

func (*SetProxyShareRequest) String 

func (x *SetProxyShareRequest) String() string

type SetProxyShareResponse 

type SetProxyShareResponse struct {
	// contains filtered or unexported fields
}

func (*SetProxyShareResponse) Descriptor deprecated 

func (*SetProxyShareResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetProxyShareResponse.ProtoReflect.Descriptor instead.

func (*SetProxyShareResponse) ProtoMessage 

func (*SetProxyShareResponse) ProtoMessage()

func (*SetProxyShareResponse) ProtoReflect 

func (x *SetProxyShareResponse) ProtoReflect() protoreflect.Message

func (*SetProxyShareResponse) Reset 

func (x *SetProxyShareResponse) Reset()

func (*SetProxyShareResponse) String 

func (x *SetProxyShareResponse) String() string

type SetSubscriptionIntervalRequest 

type SetSubscriptionIntervalRequest struct {

	// minus means no auto update
	// minutes
	Interval int32 `protobuf:"varint,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

subscription

func (*SetSubscriptionIntervalRequest) Descriptor deprecated 

func (*SetSubscriptionIntervalRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetSubscriptionIntervalRequest.ProtoReflect.Descriptor instead.

func (*SetSubscriptionIntervalRequest) GetInterval 

func (x *SetSubscriptionIntervalRequest) GetInterval() int32

func (*SetSubscriptionIntervalRequest) ProtoMessage 

func (*SetSubscriptionIntervalRequest) ProtoMessage()

func (*SetSubscriptionIntervalRequest) ProtoReflect 

func (x *SetSubscriptionIntervalRequest) ProtoReflect() protoreflect.Message

func (*SetSubscriptionIntervalRequest) Reset 

func (x *SetSubscriptionIntervalRequest) Reset()

func (*SetSubscriptionIntervalRequest) String 

func (x *SetSubscriptionIntervalRequest) String() string

type SetSubscriptionIntervalResponse 

type SetSubscriptionIntervalResponse struct {
	// contains filtered or unexported fields
}

func (*SetSubscriptionIntervalResponse) Descriptor deprecated 

func (*SetSubscriptionIntervalResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetSubscriptionIntervalResponse.ProtoReflect.Descriptor instead.

func (*SetSubscriptionIntervalResponse) ProtoMessage 

func (*SetSubscriptionIntervalResponse) ProtoMessage()

func (*SetSubscriptionIntervalResponse) ProtoReflect 

func (x *SetSubscriptionIntervalResponse) ProtoReflect() protoreflect.Message

func (*SetSubscriptionIntervalResponse) Reset 

func (x *SetSubscriptionIntervalResponse) Reset()

func (*SetSubscriptionIntervalResponse) String 

func (x *SetSubscriptionIntervalResponse) String() string

type StatsResponse 

type StatsResponse struct {
	Stats       []*OutboundStats `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	Connections int32            `protobuf:"varint,2,opt,name=connections,proto3" json:"connections,omitempty"`
	Memory      uint64           `protobuf:"varint,3,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

func (*StatsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetConnections 

func (x *StatsResponse) GetConnections() int32

func (*StatsResponse) GetMemory 

func (x *StatsResponse) GetMemory() uint64

func (*StatsResponse) GetStats 

func (x *StatsResponse) GetStats() []*OutboundStats

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

func (x *StatsResponse) ProtoReflect() protoreflect.Message

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

type SubscriptionUpdated 

type SubscriptionUpdated struct {
	// contains filtered or unexported fields
}

func (*SubscriptionUpdated) Descriptor deprecated 

func (*SubscriptionUpdated) Descriptor() ([]byte, []int)

Deprecated: Use SubscriptionUpdated.ProtoReflect.Descriptor instead.

func (*SubscriptionUpdated) ProtoMessage 

func (*SubscriptionUpdated) ProtoMessage()

func (*SubscriptionUpdated) ProtoReflect 

func (x *SubscriptionUpdated) ProtoReflect() protoreflect.Message

func (*SubscriptionUpdated) Reset 

func (x *SubscriptionUpdated) Reset()

func (*SubscriptionUpdated) String 

func (x *SubscriptionUpdated) String() string

type SwitchFakeDnsRequest 

type SwitchFakeDnsRequest struct {
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

fake dns

func (*SwitchFakeDnsRequest) Descriptor deprecated 

func (*SwitchFakeDnsRequest) Descriptor() ([]byte, []int)

Deprecated: Use SwitchFakeDnsRequest.ProtoReflect.Descriptor instead.

func (*SwitchFakeDnsRequest) GetEnable 

func (x *SwitchFakeDnsRequest) GetEnable() bool

func (*SwitchFakeDnsRequest) ProtoMessage 

func (*SwitchFakeDnsRequest) ProtoMessage()

func (*SwitchFakeDnsRequest) ProtoReflect 

func (x *SwitchFakeDnsRequest) ProtoReflect() protoreflect.Message

func (*SwitchFakeDnsRequest) Reset 

func (x *SwitchFakeDnsRequest) Reset()

func (*SwitchFakeDnsRequest) String 

func (x *SwitchFakeDnsRequest) String() string

type SwitchFakeDnsResponse 

type SwitchFakeDnsResponse struct {
	// contains filtered or unexported fields
}

func (*SwitchFakeDnsResponse) Descriptor deprecated 

func (*SwitchFakeDnsResponse) Descriptor() ([]byte, []int)

Deprecated: Use SwitchFakeDnsResponse.ProtoReflect.Descriptor instead.

func (*SwitchFakeDnsResponse) ProtoMessage 

func (*SwitchFakeDnsResponse) ProtoMessage()

func (*SwitchFakeDnsResponse) ProtoReflect 

func (x *SwitchFakeDnsResponse) ProtoReflect() protoreflect.Message

func (*SwitchFakeDnsResponse) Reset 

func (x *SwitchFakeDnsResponse) Reset()

func (*SwitchFakeDnsResponse) String 

func (x *SwitchFakeDnsResponse) String() string

type ToggleLogAppIdRequest 

type ToggleLogAppIdRequest struct {
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleLogAppIdRequest) Descriptor deprecated 

func (*ToggleLogAppIdRequest) Descriptor() ([]byte, []int)

Deprecated: Use ToggleLogAppIdRequest.ProtoReflect.Descriptor instead.

func (*ToggleLogAppIdRequest) GetEnable 

func (x *ToggleLogAppIdRequest) GetEnable() bool

func (*ToggleLogAppIdRequest) ProtoMessage 

func (*ToggleLogAppIdRequest) ProtoMessage()

func (*ToggleLogAppIdRequest) ProtoReflect 

func (x *ToggleLogAppIdRequest) ProtoReflect() protoreflect.Message

func (*ToggleLogAppIdRequest) Reset 

func (x *ToggleLogAppIdRequest) Reset()

func (*ToggleLogAppIdRequest) String 

func (x *ToggleLogAppIdRequest) String() string

type ToggleLogAppIdResponse 

type ToggleLogAppIdResponse struct {
	// contains filtered or unexported fields
}

func (*ToggleLogAppIdResponse) Descriptor deprecated 

func (*ToggleLogAppIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use ToggleLogAppIdResponse.ProtoReflect.Descriptor instead.

func (*ToggleLogAppIdResponse) ProtoMessage 

func (*ToggleLogAppIdResponse) ProtoMessage()

func (*ToggleLogAppIdResponse) ProtoReflect 

func (x *ToggleLogAppIdResponse) ProtoReflect() protoreflect.Message

func (*ToggleLogAppIdResponse) Reset 

func (x *ToggleLogAppIdResponse) Reset()

func (*ToggleLogAppIdResponse) String 

func (x *ToggleLogAppIdResponse) String() string

type ToggleUserLogRequest 

type ToggleUserLogRequest struct {
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleUserLogRequest) Descriptor deprecated 

func (*ToggleUserLogRequest) Descriptor() ([]byte, []int)

Deprecated: Use ToggleUserLogRequest.ProtoReflect.Descriptor instead.

func (*ToggleUserLogRequest) GetEnable 

func (x *ToggleUserLogRequest) GetEnable() bool

func (*ToggleUserLogRequest) ProtoMessage 

func (*ToggleUserLogRequest) ProtoMessage()

func (*ToggleUserLogRequest) ProtoReflect 

func (x *ToggleUserLogRequest) ProtoReflect() protoreflect.Message

func (*ToggleUserLogRequest) Reset 

func (x *ToggleUserLogRequest) Reset()

func (*ToggleUserLogRequest) String 

func (x *ToggleUserLogRequest) String() string

type ToggleUserLogResponse 

type ToggleUserLogResponse struct {
	// contains filtered or unexported fields
}

func (*ToggleUserLogResponse) Descriptor deprecated 

func (*ToggleUserLogResponse) Descriptor() ([]byte, []int)

Deprecated: Use ToggleUserLogResponse.ProtoReflect.Descriptor instead.

func (*ToggleUserLogResponse) ProtoMessage 

func (*ToggleUserLogResponse) ProtoMessage()

func (*ToggleUserLogResponse) ProtoReflect 

func (x *ToggleUserLogResponse) ProtoReflect() protoreflect.Message

func (*ToggleUserLogResponse) Reset 

func (x *ToggleUserLogResponse) Reset()

func (*ToggleUserLogResponse) String 

func (x *ToggleUserLogResponse) String() string

type UnimplementedClientServiceServer 

type UnimplementedClientServiceServer struct{}

UnimplementedClientServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedClientServiceServer) AddGeoDomain 

func (UnimplementedClientServiceServer) AddGeoDomain(context.Context, *AddGeoDomainRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) AddInbound 

func (UnimplementedClientServiceServer) AddInbound(context.Context, *AddInboundRequest) (*AddInboundResponse, error)

func (UnimplementedClientServiceServer) ChangeOutbound 

func (UnimplementedClientServiceServer) ChangeOutbound(context.Context, *ChangeOutboundRequest) (*ChangeOutboundResponse, error)

func (UnimplementedClientServiceServer) ChangeRoutingMode 

func (UnimplementedClientServiceServer) ChangeRoutingMode(context.Context, *ChangeRoutingModeRequest) (*ChangeRoutingModeResponse, error)

func (UnimplementedClientServiceServer) ChangeSelector 

func (UnimplementedClientServiceServer) ChangeSelector(context.Context, *ChangeSelectorRequest) (*ChangeSelectorResponse, error)

func (UnimplementedClientServiceServer) Communicate 

func (UnimplementedClientServiceServer) Communicate(*CommunicateRequest, grpc.ServerStreamingServer[CommunicateMessage]) error

func (UnimplementedClientServiceServer) CurrentOutbound 

func (UnimplementedClientServiceServer) CurrentOutbound(context.Context, *CurrentOutboundRequest) (*CurrentOutboundResponse, error)

func (UnimplementedClientServiceServer) GetStatsStream 

func (UnimplementedClientServiceServer) GetStatsStream(*GetStatsRequest, grpc.ServerStreamingServer[StatsResponse]) error

func (UnimplementedClientServiceServer) NotifyHandlerChange 

func (UnimplementedClientServiceServer) NotifyHandlerChange(context.Context, *HandlerChangeNotify) (*HandlerChangeNotifyResponse, error)

func (UnimplementedClientServiceServer) RemoveGeoDomain 

func (UnimplementedClientServiceServer) RemoveGeoDomain(context.Context, *RemoveGeoDomainRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) RemoveInbound 

func (UnimplementedClientServiceServer) RemoveInbound(context.Context, *RemoveInboundRequest) (*RemoveInboundResponse, error)

func (UnimplementedClientServiceServer) ReplaceGeoDomains 

func (UnimplementedClientServiceServer) ReplaceGeoDomains(context.Context, *ReplaceDomainSetRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) ReplaceGeoIPs 

func (UnimplementedClientServiceServer) ReplaceGeoIPs(context.Context, *ReplaceIPSetRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) RttTest 

func (UnimplementedClientServiceServer) RttTest(context.Context, *RttTestRequest) (*RttTestResponse, error)

func (UnimplementedClientServiceServer) SetAutoSubscriptionUpdate 

func (UnimplementedClientServiceServer) SetAutoSubscriptionUpdate(context.Context, *SetAutoSubscriptionUpdateRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) SetOutboundHandlerSpeed 

func (UnimplementedClientServiceServer) SetOutboundHandlerSpeed(context.Context, *SetOutboundHandlerSpeedRequest) (*SetOutboundHandlerSpeedResponse, error)

func (UnimplementedClientServiceServer) SetSubscriptionInterval 

func (UnimplementedClientServiceServer) SetSubscriptionInterval(context.Context, *SetSubscriptionIntervalRequest) (*SetSubscriptionIntervalResponse, error)

func (UnimplementedClientServiceServer) SwitchFakeDns 

func (UnimplementedClientServiceServer) SwitchFakeDns(context.Context, *SwitchFakeDnsRequest) (*SwitchFakeDnsResponse, error)

func (UnimplementedClientServiceServer) ToggleLogAppId 

func (UnimplementedClientServiceServer) ToggleLogAppId(context.Context, *ToggleLogAppIdRequest) (*ToggleLogAppIdResponse, error)

func (UnimplementedClientServiceServer) ToggleUserLog 

func (UnimplementedClientServiceServer) ToggleUserLog(context.Context, *ToggleUserLogRequest) (*ToggleUserLogResponse, error)

func (UnimplementedClientServiceServer) UpdateGeo 

func (UnimplementedClientServiceServer) UpdateGeo(context.Context, *UpdateGeoRequest) (*UpdateGeoResponse, error)

func (UnimplementedClientServiceServer) UpdateRouter 

func (UnimplementedClientServiceServer) UpdateRouter(context.Context, *UpdateRouterRequest) (*UpdateRouterResponse, error)

func (UnimplementedClientServiceServer) UpdateSelectorBalancer 

func (UnimplementedClientServiceServer) UpdateSelectorBalancer(context.Context, *UpdateSelectorBalancerRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) UpdateSelectorFilter 

func (UnimplementedClientServiceServer) UpdateSelectorFilter(context.Context, *UpdateSelectorFilterRequest) (*Receipt, error)

func (UnimplementedClientServiceServer) UserLogStream 

func (UnimplementedClientServiceServer) UserLogStream(*UserLogStreamRequest, grpc.ServerStreamingServer[userlogger.UserLogMessage]) error

type UnsafeClientServiceServer 

type UnsafeClientServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClientServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientServiceServer will result in compilation errors.

type UpdateGeoRequest 

type UpdateGeoRequest struct {
	Geo *configs.GeoConfig `protobuf:"bytes,1,opt,name=geo,proto3" json:"geo,omitempty"`
	// contains filtered or unexported fields
}

geo

func (*UpdateGeoRequest) Descriptor deprecated 

func (*UpdateGeoRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateGeoRequest.ProtoReflect.Descriptor instead.

func (*UpdateGeoRequest) GetGeo 

func (x *UpdateGeoRequest) GetGeo() *configs.GeoConfig

func (*UpdateGeoRequest) ProtoMessage 

func (*UpdateGeoRequest) ProtoMessage()

func (*UpdateGeoRequest) ProtoReflect 

func (x *UpdateGeoRequest) ProtoReflect() protoreflect.Message

func (*UpdateGeoRequest) Reset 

func (x *UpdateGeoRequest) Reset()

func (*UpdateGeoRequest) String 

func (x *UpdateGeoRequest) String() string

type UpdateGeoResponse 

type UpdateGeoResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateGeoResponse) Descriptor deprecated 

func (*UpdateGeoResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateGeoResponse.ProtoReflect.Descriptor instead.

func (*UpdateGeoResponse) ProtoMessage 

func (*UpdateGeoResponse) ProtoMessage()

func (*UpdateGeoResponse) ProtoReflect 

func (x *UpdateGeoResponse) ProtoReflect() protoreflect.Message

func (*UpdateGeoResponse) Reset 

func (x *UpdateGeoResponse) Reset()

func (*UpdateGeoResponse) String 

func (x *UpdateGeoResponse) String() string

type UpdateRouterRequest 

type UpdateRouterRequest struct {
	RouterConfig *configs.RouterConfig `protobuf:"bytes,1,opt,name=router_config,json=routerConfig,proto3" json:"router_config,omitempty"`
	// contains filtered or unexported fields
}

app id

func (*UpdateRouterRequest) Descriptor deprecated 

func (*UpdateRouterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateRouterRequest.ProtoReflect.Descriptor instead.

func (*UpdateRouterRequest) GetRouterConfig 

func (x *UpdateRouterRequest) GetRouterConfig() *configs.RouterConfig

func (*UpdateRouterRequest) ProtoMessage 

func (*UpdateRouterRequest) ProtoMessage()

func (*UpdateRouterRequest) ProtoReflect 

func (x *UpdateRouterRequest) ProtoReflect() protoreflect.Message

func (*UpdateRouterRequest) Reset 

func (x *UpdateRouterRequest) Reset()

func (*UpdateRouterRequest) String 

func (x *UpdateRouterRequest) String() string

type UpdateRouterResponse 

type UpdateRouterResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateRouterResponse) Descriptor deprecated 

func (*UpdateRouterResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateRouterResponse.ProtoReflect.Descriptor instead.

func (*UpdateRouterResponse) ProtoMessage 

func (*UpdateRouterResponse) ProtoMessage()

func (*UpdateRouterResponse) ProtoReflect 

func (x *UpdateRouterResponse) ProtoReflect() protoreflect.Message

func (*UpdateRouterResponse) Reset 

func (x *UpdateRouterResponse) Reset()

func (*UpdateRouterResponse) String 

func (x *UpdateRouterResponse) String() string

type UpdateSelectorBalancerRequest 

type UpdateSelectorBalancerRequest struct {
	Tag             string                                 `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	BalanceStrategy configs.SelectorConfig_BalanceStrategy `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateSelectorBalancerRequest) Descriptor deprecated 

func (*UpdateSelectorBalancerRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSelectorBalancerRequest.ProtoReflect.Descriptor instead.

func (*UpdateSelectorBalancerRequest) GetBalanceStrategy 

func (x *UpdateSelectorBalancerRequest) GetBalanceStrategy() configs.SelectorConfig_BalanceStrategy

func (*UpdateSelectorBalancerRequest) GetTag 

func (x *UpdateSelectorBalancerRequest) GetTag() string

func (*UpdateSelectorBalancerRequest) ProtoMessage 

func (*UpdateSelectorBalancerRequest) ProtoMessage()

func (*UpdateSelectorBalancerRequest) ProtoReflect 

func (x *UpdateSelectorBalancerRequest) ProtoReflect() protoreflect.Message

func (*UpdateSelectorBalancerRequest) Reset 

func (x *UpdateSelectorBalancerRequest) Reset()

func (*UpdateSelectorBalancerRequest) String 

func (x *UpdateSelectorBalancerRequest) String() string

type UpdateSelectorFilterRequest 

type UpdateSelectorFilterRequest struct {
	Tag          string                         `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Filter       *configs.SelectorConfig_Filter `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	SelectFromOm bool                           `protobuf:"varint,3,opt,name=select_from_om,json=selectFromOm,proto3" json:"select_from_om,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSelectorFilterRequest) Descriptor deprecated 

func (*UpdateSelectorFilterRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSelectorFilterRequest.ProtoReflect.Descriptor instead.

func (*UpdateSelectorFilterRequest) GetFilter 

func (x *UpdateSelectorFilterRequest) GetFilter() *configs.SelectorConfig_Filter

func (*UpdateSelectorFilterRequest) GetSelectFromOm 

func (x *UpdateSelectorFilterRequest) GetSelectFromOm() bool

func (*UpdateSelectorFilterRequest) GetTag 

func (x *UpdateSelectorFilterRequest) GetTag() string

func (*UpdateSelectorFilterRequest) ProtoMessage 

func (*UpdateSelectorFilterRequest) ProtoMessage()

func (*UpdateSelectorFilterRequest) ProtoReflect 

func (x *UpdateSelectorFilterRequest) ProtoReflect() protoreflect.Message

func (*UpdateSelectorFilterRequest) Reset 

func (x *UpdateSelectorFilterRequest) Reset()

func (*UpdateSelectorFilterRequest) String 

func (x *UpdateSelectorFilterRequest) String() string

type UserLogStreamRequest 

type UserLogStreamRequest struct {
	// contains filtered or unexported fields
}

log message ChangeLogLevelRequest { x.Level level = 1; } message ChangeLogLevelResponse {} message LogStreamRequest {} message LogMessage { string message = 1; }

func (*UserLogStreamRequest) Descriptor deprecated 

func (*UserLogStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UserLogStreamRequest.ProtoReflect.Descriptor instead.

func (*UserLogStreamRequest) ProtoMessage 

func (*UserLogStreamRequest) ProtoMessage()

func (*UserLogStreamRequest) ProtoReflect 

func (x *UserLogStreamRequest) ProtoReflect() protoreflect.Message

func (*UserLogStreamRequest) Reset 

func (x *UserLogStreamRequest) Reset()

func (*UserLogStreamRequest) String 

func (x *UserLogStreamRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.