grpcservice

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2026 License: AGPL-3.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	GrpcService_Communicate_FullMethodName               = "/x.grpcservice.GrpcService/Communicate"
	GrpcService_AddInbound_FullMethodName                = "/x.grpcservice.GrpcService/AddInbound"
	GrpcService_RemoveInbound_FullMethodName             = "/x.grpcservice.GrpcService/RemoveInbound"
	GrpcService_GetStatsStream_FullMethodName            = "/x.grpcservice.GrpcService/GetStatsStream"
	GrpcService_SetOutboundHandlerSpeed_FullMethodName   = "/x.grpcservice.GrpcService/SetOutboundHandlerSpeed"
	GrpcService_UserLogStream_FullMethodName             = "/x.grpcservice.GrpcService/UserLogStream"
	GrpcService_ResetUserLogging_FullMethodName          = "/x.grpcservice.GrpcService/ResetUserLogging"
	GrpcService_ChangeOutbound_FullMethodName            = "/x.grpcservice.GrpcService/ChangeOutbound"
	GrpcService_CurrentOutbound_FullMethodName           = "/x.grpcservice.GrpcService/CurrentOutbound"
	GrpcService_ChangeRoutingMode_FullMethodName         = "/x.grpcservice.GrpcService/ChangeRoutingMode"
	GrpcService_ChangeSelector_FullMethodName            = "/x.grpcservice.GrpcService/ChangeSelector"
	GrpcService_UpdateSelectorBalancer_FullMethodName    = "/x.grpcservice.GrpcService/UpdateSelectorBalancer"
	GrpcService_UpdateSelectorFilter_FullMethodName      = "/x.grpcservice.GrpcService/UpdateSelectorFilter"
	GrpcService_NotifyHandlerChange_FullMethodName       = "/x.grpcservice.GrpcService/NotifyHandlerChange"
	GrpcService_SwitchFakeDns_FullMethodName             = "/x.grpcservice.GrpcService/SwitchFakeDns"
	GrpcService_UpdateGeo_FullMethodName                 = "/x.grpcservice.GrpcService/UpdateGeo"
	GrpcService_AddGeoDomain_FullMethodName              = "/x.grpcservice.GrpcService/AddGeoDomain"
	GrpcService_RemoveGeoDomain_FullMethodName           = "/x.grpcservice.GrpcService/RemoveGeoDomain"
	GrpcService_ReplaceGeoDomains_FullMethodName         = "/x.grpcservice.GrpcService/ReplaceGeoDomains"
	GrpcService_ReplaceGeoIPs_FullMethodName             = "/x.grpcservice.GrpcService/ReplaceGeoIPs"
	GrpcService_UpdateRouter_FullMethodName              = "/x.grpcservice.GrpcService/UpdateRouter"
	GrpcService_SetSubscriptionInterval_FullMethodName   = "/x.grpcservice.GrpcService/SetSubscriptionInterval"
	GrpcService_SetAutoSubscriptionUpdate_FullMethodName = "/x.grpcservice.GrpcService/SetAutoSubscriptionUpdate"
	GrpcService_RttTest_FullMethodName                   = "/x.grpcservice.GrpcService/RttTest"
)
View Source 
const DirectHandlerTag = "direct"
View Source 
const DnsHandlerTag = "dns"

Variables

View Source 
var File_app_grpcservice_grpc_proto protoreflect.FileDescriptor
View Source 
var GrpcService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "x.grpcservice.GrpcService",
	HandlerType: (*GrpcServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddInbound",
			Handler:    _GrpcService_AddInbound_Handler,
		},
		{
			MethodName: "RemoveInbound",
			Handler:    _GrpcService_RemoveInbound_Handler,
		},
		{
			MethodName: "SetOutboundHandlerSpeed",
			Handler:    _GrpcService_SetOutboundHandlerSpeed_Handler,
		},
		{
			MethodName: "ResetUserLogging",
			Handler:    _GrpcService_ResetUserLogging_Handler,
		},
		{
			MethodName: "ChangeOutbound",
			Handler:    _GrpcService_ChangeOutbound_Handler,
		},
		{
			MethodName: "CurrentOutbound",
			Handler:    _GrpcService_CurrentOutbound_Handler,
		},
		{
			MethodName: "ChangeRoutingMode",
			Handler:    _GrpcService_ChangeRoutingMode_Handler,
		},
		{
			MethodName: "ChangeSelector",
			Handler:    _GrpcService_ChangeSelector_Handler,
		},
		{
			MethodName: "UpdateSelectorBalancer",
			Handler:    _GrpcService_UpdateSelectorBalancer_Handler,
		},
		{
			MethodName: "UpdateSelectorFilter",
			Handler:    _GrpcService_UpdateSelectorFilter_Handler,
		},
		{
			MethodName: "NotifyHandlerChange",
			Handler:    _GrpcService_NotifyHandlerChange_Handler,
		},
		{
			MethodName: "SwitchFakeDns",
			Handler:    _GrpcService_SwitchFakeDns_Handler,
		},
		{
			MethodName: "UpdateGeo",
			Handler:    _GrpcService_UpdateGeo_Handler,
		},
		{
			MethodName: "AddGeoDomain",
			Handler:    _GrpcService_AddGeoDomain_Handler,
		},
		{
			MethodName: "RemoveGeoDomain",
			Handler:    _GrpcService_RemoveGeoDomain_Handler,
		},
		{
			MethodName: "ReplaceGeoDomains",
			Handler:    _GrpcService_ReplaceGeoDomains_Handler,
		},
		{
			MethodName: "ReplaceGeoIPs",
			Handler:    _GrpcService_ReplaceGeoIPs_Handler,
		},
		{
			MethodName: "UpdateRouter",
			Handler:    _GrpcService_UpdateRouter_Handler,
		},
		{
			MethodName: "SetSubscriptionInterval",
			Handler:    _GrpcService_SetSubscriptionInterval_Handler,
		},
		{
			MethodName: "SetAutoSubscriptionUpdate",
			Handler:    _GrpcService_SetAutoSubscriptionUpdate_Handler,
		},
		{
			MethodName: "RttTest",
			Handler:    _GrpcService_RttTest_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Communicate",
			Handler:       _GrpcService_Communicate_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetStatsStream",
			Handler:       _GrpcService_GetStatsStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UserLogStream",
			Handler:       _GrpcService_UserLogStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "app/grpcservice/grpc.proto",
}

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

Functions

func GetAllProxyhandlers 

func GetAllProxyhandlers(om i.OutboundManager) []i.Outbound

return all handlers except direct and dns

func RegisterGrpcServiceServer added in v1.1.0 

func RegisterGrpcServiceServer(s grpc.ServiceRegistrar, srv GrpcServiceServer)

func ReplaceHandlers 

func ReplaceHandlers(om i.OutboundManager, handlers ...i.Outbound)

replace all proxy handlers with new ones

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 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 GrpcService 

type GrpcService struct {
	Client *client.Client

	Done *done.Instance

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

	OnExit func()

	UpdateLantency bool

	UnimplementedGrpcServiceServer
	// contains filtered or unexported fields
}

func NewGrpcService 

func NewGrpcService(grpcConfig *GrpcServiceConfig) (*GrpcService, error)

func (*GrpcService) AddGeoDomain 

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

func (*GrpcService) AddInbound 

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

func (*GrpcService) ChangeOutbound 

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

func (*GrpcService) ChangeRoutingMode 

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

func (*GrpcService) ChangeSelector 

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

func (*GrpcService) Close 

func (s *GrpcService) Close() error

func (*GrpcService) Communicate 

func (s *GrpcService) Communicate(in *CommunicateRequest, stream GrpcService_CommunicateServer) error

func (*GrpcService) CurrentOutbound 

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

func (*GrpcService) DisableFakeDns 

func (d *GrpcService) DisableFakeDns() error

func (*GrpcService) EnableFakeDns 

func (d *GrpcService) EnableFakeDns() error

func (*GrpcService) GetStatsStream 

func (s *GrpcService) GetStatsStream(in *GetStatsRequest,
	stream GrpcService_GetStatsStreamServer) error

func (*GrpcService) IPv6Result 

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

func (*GrpcService) NotifyHandlerChange 

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

func (*GrpcService) OnSelectedHandlersChanged 

func (s *GrpcService) OnSelectedHandlersChanged(selector string, handlers []string)

func (*GrpcService) OnSubscriptionUpdated 

func (s *GrpcService) OnSubscriptionUpdated()

TODO: Lock?

func (*GrpcService) PingResult 

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

func (*GrpcService) RemoveGeoDomain 

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

func (*GrpcService) RemoveInbound 

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

func (*GrpcService) ReplaceGeoDomains 

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

func (*GrpcService) ReplaceGeoIPs 

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

func (*GrpcService) ResetUserLogging added in v1.1.0 

func (s *GrpcService) ResetUserLogging(ctx context.Context, in *ResetUserLoggingRequest) (*ResetUserLoggingResponse, error)

func (*GrpcService) RttTest 

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

func (*GrpcService) SetAutoSubscriptionUpdate 

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

func (*GrpcService) SetOutboundHandlerSpeed 

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

func (*GrpcService) SetSubscriptionInterval 

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

func (*GrpcService) SpeedResult 

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

func (*GrpcService) Start 

func (s *GrpcService) Start() error

func (*GrpcService) SwitchFakeDns 

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

should not be called concurrently

func (*GrpcService) UpdateGeo 

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

TODO: more efficient

func (*GrpcService) UpdateRouter 

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

func (*GrpcService) UpdateSelectorBalancer 

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

func (*GrpcService) UpdateSelectorFilter 

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

func (*GrpcService) UsableResult 

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

func (*GrpcService) UserLogStream 

func (s *GrpcService) UserLogStream(in *UserLogStreamRequest, stream GrpcService_UserLogStreamServer) error

type GrpcServiceClient added in v1.1.0 

type GrpcServiceClient 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)
	ResetUserLogging(ctx context.Context, in *ResetUserLoggingRequest, opts ...grpc.CallOption) (*ResetUserLoggingResponse, 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)
}

GrpcServiceClient is the client API for GrpcService 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 NewGrpcServiceClient added in v1.1.0 

func NewGrpcServiceClient(cc grpc.ClientConnInterface) GrpcServiceClient

type GrpcServiceConfig 

type GrpcServiceConfig struct {
	Client         *client.Client
	GrpcServer     *grpc.Server
	UpdateLantency bool
}

type GrpcServiceServer added in v1.1.0 

type GrpcServiceServer 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
	ResetUserLogging(context.Context, *ResetUserLoggingRequest) (*ResetUserLoggingResponse, 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
}

GrpcServiceServer is the server API for GrpcService service. All implementations must embed UnimplementedGrpcServiceServer for forward compatibility.

type GrpcService_CommunicateClient added in v1.1.0 

type GrpcService_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 GrpcService_CommunicateServer added in v1.1.0 

type GrpcService_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 GrpcService_GetStatsStreamClient added in v1.1.0 

type GrpcService_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 GrpcService_GetStatsStreamServer added in v1.1.0 

type GrpcService_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 GrpcService_UserLogStreamClient added in v1.1.0 

type GrpcService_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 GrpcService_UserLogStreamServer added in v1.1.0 

type GrpcService_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 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"`
	// seconds
	Interval float32 `protobuf:"fixed32,6,opt,name=interval,proto3" json:"interval,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) GetInterval 

func (x *OutboundStats) GetInterval() float32

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 ResetUserLoggingRequest added in v1.1.0 

type ResetUserLoggingRequest struct {
	Enable        bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	AppId         bool `protobuf:"varint,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	SessionEnd    bool `protobuf:"varint,3,opt,name=session_end,json=sessionEnd,proto3" json:"session_end,omitempty"`
	RealtimeUsage bool `protobuf:"varint,4,opt,name=realtime_usage,json=realtimeUsage,proto3" json:"realtime_usage,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetUserLoggingRequest) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use ResetUserLoggingRequest.ProtoReflect.Descriptor instead.

func (*ResetUserLoggingRequest) GetAppId added in v1.1.0 

func (x *ResetUserLoggingRequest) GetAppId() bool

func (*ResetUserLoggingRequest) GetEnable added in v1.1.0 

func (x *ResetUserLoggingRequest) GetEnable() bool

func (*ResetUserLoggingRequest) GetRealtimeUsage added in v1.1.0 

func (x *ResetUserLoggingRequest) GetRealtimeUsage() bool

func (*ResetUserLoggingRequest) GetSessionEnd added in v1.1.0 

func (x *ResetUserLoggingRequest) GetSessionEnd() bool

func (*ResetUserLoggingRequest) ProtoMessage added in v1.1.0 

func (*ResetUserLoggingRequest) ProtoMessage()

func (*ResetUserLoggingRequest) ProtoReflect added in v1.1.0 

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

func (*ResetUserLoggingRequest) Reset added in v1.1.0 

func (x *ResetUserLoggingRequest) Reset()

func (*ResetUserLoggingRequest) String added in v1.1.0 

func (x *ResetUserLoggingRequest) String() string

type ResetUserLoggingResponse added in v1.1.0 

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

func (*ResetUserLoggingResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use ResetUserLoggingResponse.ProtoReflect.Descriptor instead.

func (*ResetUserLoggingResponse) ProtoMessage added in v1.1.0 

func (*ResetUserLoggingResponse) ProtoMessage()

func (*ResetUserLoggingResponse) ProtoReflect added in v1.1.0 

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

func (*ResetUserLoggingResponse) Reset added in v1.1.0 

func (x *ResetUserLoggingResponse) Reset()

func (*ResetUserLoggingResponse) String added in v1.1.0 

func (x *ResetUserLoggingResponse) 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 UnimplementedGrpcServiceServer added in v1.1.0 

type UnimplementedGrpcServiceServer struct{}

UnimplementedGrpcServiceServer 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 (UnimplementedGrpcServiceServer) AddGeoDomain added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) AddInbound added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ChangeOutbound added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ChangeRoutingMode added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ChangeSelector added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) Communicate added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) CurrentOutbound added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) GetStatsStream added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) NotifyHandlerChange added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) RemoveGeoDomain added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) RemoveInbound added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ReplaceGeoDomains added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ReplaceGeoIPs added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) ResetUserLogging added in v1.1.0 

func (UnimplementedGrpcServiceServer) ResetUserLogging(context.Context, *ResetUserLoggingRequest) (*ResetUserLoggingResponse, error)

func (UnimplementedGrpcServiceServer) RttTest added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) SetAutoSubscriptionUpdate added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) SetOutboundHandlerSpeed added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) SetSubscriptionInterval added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) SwitchFakeDns added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) UpdateGeo added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) UpdateRouter added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) UpdateSelectorBalancer added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) UpdateSelectorFilter added in v1.1.0 

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

func (UnimplementedGrpcServiceServer) UserLogStream added in v1.1.0 

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

type UnsafeGrpcServiceServer added in v1.1.0 

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

UnsafeGrpcServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GrpcServiceServer 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.