rpc

package

v0.5.4 Latest Latest Go to latest Published: Aug 29, 2026 License: GPL-3.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func CheckBackendMiddleware(s *Service) grpc.UnaryServerInterceptor

func CheckBackendStreamMiddleware(s *Service) grpc.StreamServerInterceptor

func ConditionalMiddleware(s *Service) grpc.UnaryServerInterceptor

func ConditionalStreamMiddleware(s *Service) grpc.StreamServerInterceptor

func LoggingInterceptor(s *Service) grpc.UnaryServerInterceptor

func LoggingStreamInterceptor(s *Service) grpc.StreamServerInterceptor

func StartGRPCListener(tlsConfig *tls.Config, addr string, cfg *config.Config) (func(ctx context.Context) error, controller.Service, error)

type Service struct {
	common.UnimplementedNodeServiceServer
	controller.Controller
}

func New(cfg *config.Config) *Service

func (s *Service) AddRoutingRule(ctx context.Context, request *common.AddRoutingRuleRequest) (*common.Empty, error)

func (s *Service) GetBackendStats(ctx context.Context, _ *common.Empty) (*common.BackendStatsResponse, error)

func (s *Service) GetBalancerInfo(ctx context.Context, request *common.BalancerInfoRequest) (*common.BalancerInfoResponse, error)

func (s *Service) GetBaseInfo(_ context.Context, _ *common.Empty) (*common.BaseInfoResponse, error)

func (s *Service) GetLogs(_ *common.Empty, stream common.NodeService_GetLogsServer) error

func (s *Service) GetOutboundsLatency(ctx context.Context, request *common.LatencyRequest) (*common.LatencyResponse, error)

func (s *Service) GetStats(ctx context.Context, request *common.StatRequest) (*common.StatResponse, error)

func (s *Service) GetSystemStats(ctx context.Context, _ *common.Empty) (*common.SystemStatsResponse, error)

func (s *Service) GetUserOnlineIpListStats(ctx context.Context, request *common.StatRequest) (*common.StatsOnlineIpListResponse, error)

func (s *Service) GetUserOnlineStats(ctx context.Context, request *common.StatRequest) (*common.OnlineStatResponse, error)

func (s *Service) ListRoutingRules(ctx context.Context, _ *common.Empty) (*common.RoutingRulesResponse, error)

func (s *Service) OverrideBalancerTarget(ctx context.Context, request *common.OverrideBalancerTargetRequest) (*common.Empty, error)

func (s *Service) RemoveRoutingRule(ctx context.Context, request *common.RemoveRoutingRuleRequest) (*common.Empty, error)

func (s *Service) Start(ctx context.Context, data *common.Backend) (*common.BaseInfoResponse, error)

func (s *Service) Stop(_ context.Context, _ *common.Empty) (*common.Empty, error)

func (s *Service) SyncUser(stream grpc.ClientStreamingServer[common.User, common.Empty]) error

func (s *Service) SyncUsers(ctx context.Context, users *common.Users) (*common.Empty, error)

func (s *Service) SyncUsersChunked(stream grpc.ClientStreamingServer[common.UsersChunk, common.Empty]) error

func (s *Service) TestRoute(ctx context.Context, request *common.TestRouteRequest) (*common.RouteResult, error)