rpc

package

v0.0.13 Latest Latest Go to latest Published: Sep 4, 2025 License: GPL-3.0 Imports: 19 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(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

func LoggingStreamInterceptor() grpc.StreamServerInterceptor

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

type Service struct {
	common.UnimplementedNodeServiceServer
	controller.Controller
}

func New() *Service

func (s *Service) GetBackendStats(ctx context.Context, _ *common.Empty) (*common.BackendStatsResponse, 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) GetStats(ctx context.Context, request *common.StatRequest) (*common.StatResponse, error)

func (s *Service) GetSystemStats(_ 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) Start(ctx context.Context, detail *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)