@@ -335,20 +335,20 @@ def __init__(self, **kwargs):
335
335
self ._config = config
336
336
self ._context = _ClientContext ()
337
337
client_id = HazelcastClient ._CLIENT_ID .get_and_increment ()
338
- self .name = self ._create_client_name (client_id )
338
+ self ._name = self ._create_client_name (client_id )
339
339
self ._reactor = AsyncoreReactor ()
340
340
self ._serialization_service = SerializationServiceV1 (config )
341
341
self ._near_cache_manager = NearCacheManager (config , self ._serialization_service )
342
342
self ._internal_lifecycle_service = _InternalLifecycleService (config )
343
- self .lifecycle_service = LifecycleService (self ._internal_lifecycle_service )
343
+ self ._lifecycle_service = LifecycleService (self ._internal_lifecycle_service )
344
344
self ._invocation_service = InvocationService (self , config , self ._reactor )
345
345
self ._address_provider = self ._create_address_provider ()
346
346
self ._internal_partition_service = _InternalPartitionService (self )
347
- self .partition_service = PartitionService (
347
+ self ._partition_service = PartitionService (
348
348
self ._internal_partition_service , self ._serialization_service
349
349
)
350
350
self ._internal_cluster_service = _InternalClusterService (self , config )
351
- self .cluster_service = ClusterService (self ._internal_cluster_service )
351
+ self ._cluster_service = ClusterService (self ._internal_cluster_service )
352
352
self ._connection_manager = ConnectionManager (
353
353
self ,
354
354
config ,
@@ -365,7 +365,7 @@ def __init__(self, **kwargs):
365
365
self , config , self ._connection_manager , self ._invocation_service
366
366
)
367
367
self ._proxy_manager = ProxyManager (self ._context )
368
- self .cp_subsystem = CPSubsystem (self ._context )
368
+ self ._cp_subsystem = CPSubsystem (self ._context )
369
369
self ._proxy_session_manager = ProxySessionManager (self ._context )
370
370
self ._transaction_manager = TransactionManager (self ._context )
371
371
self ._lock_reference_id_generator = AtomicInteger (1 )
@@ -404,7 +404,7 @@ def _init_context(self):
404
404
self ._proxy_manager ,
405
405
self ._near_cache_manager ,
406
406
self ._lock_reference_id_generator ,
407
- self .name ,
407
+ self ._name ,
408
408
self ._proxy_session_manager ,
409
409
self ._reactor ,
410
410
)
@@ -425,7 +425,7 @@ def _start(self):
425
425
426
426
self ._listener_service .start ()
427
427
self ._invocation_service .add_backup_listener ()
428
- self ._load_balancer .init (self .cluster_service )
428
+ self ._load_balancer .init (self ._cluster_service )
429
429
self ._statistics .start ()
430
430
except :
431
431
self .shutdown ()
@@ -667,6 +667,39 @@ def shutdown(self):
667
667
self ._reactor .shutdown ()
668
668
self ._internal_lifecycle_service .fire_lifecycle_event (LifecycleState .SHUTDOWN )
669
669
670
+ @property
671
+ def name (self ):
672
+ """str: Name of the client."""
673
+ return self ._name
674
+
675
+ @property
676
+ def lifecycle_service (self ):
677
+ """LifecycleService: Lifecycle service allows you to check if the
678
+ client is running and add and remove lifecycle listeners.
679
+ """
680
+ return self ._lifecycle_service
681
+
682
+ @property
683
+ def partition_service (self ):
684
+ """PartitionService: Partition service allows you to get partition
685
+ count, introspect the partition owners, and partition ids of keys.
686
+ """
687
+ return self ._partition_service
688
+
689
+ @property
690
+ def cluster_service (self ):
691
+ """ClusterService: Cluster service allows you to get the list of
692
+ the cluster members and add and remove membership listeners.
693
+ """
694
+ return self ._cluster_service
695
+
696
+ @property
697
+ def cp_subsystem (self ):
698
+ """CPSubsystem: CP Subsystem offers set of in-memory linearizable
699
+ data structures.
700
+ """
701
+ return self ._cp_subsystem
702
+
670
703
def _create_address_provider (self ):
671
704
config = self ._config
672
705
cluster_members = config .cluster_members
0 commit comments