rpc

package

v0.2.2 Latest Latest Go to latest Published: Feb 6, 2026 License: GPL-3.0 Imports: 21 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) 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)

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