cloudvision.Connector package

Subpackages

• cloudvision.Connector.auth package
  • Submodules
  • cloudvision.Connector.auth.cert module
    • cert_from_pem()
    • create_csr()
    • gen_csr_der()
    • key_from_pem()
    • load_cert()
    • load_key()
    • load_key_cert_pair()
  • Module contents
• cloudvision.Connector.codec package
  • Submodules
  • cloudvision.Connector.codec.custom_types module
    • Float32
    • FrozenDict
      • FrozenDict.copy()
      • FrozenDict.dict_cls
    • Path
    • Wildcard
  • cloudvision.Connector.codec.decoder module
    • Decoder
      • Decoder.decode()
      • Decoder.decode_array()
      • Decoder.decode_map()
  • cloudvision.Connector.codec.encoder module
    • Encoder
      • Encoder.encode()
      • Encoder.encode_array()
      • Encoder.encode_map()
      • Encoder.encode_string()
  • Module contents
    • Decoder
      • Decoder.decode()
      • Decoder.decode_array()
      • Decoder.decode_map()
    • Encoder
      • Encoder.encode()
      • Encoder.encode_array()
      • Encoder.encode_map()
      • Encoder.encode_string()
    • Float32
    • FrozenDict
      • FrozenDict.copy()
      • FrozenDict.dict_cls
    • Path
    • Wildcard
• cloudvision.Connector.core package
  • Submodules
  • cloudvision.Connector.core.utils module
    • get_dict()
  • Module contents
• cloudvision.Connector.gen package
  • Submodules
  • cloudvision.Connector.gen.ca_pb2 module
  • cloudvision.Connector.gen.ca_pb2_grpc module
    • CertificateAuthority
      • CertificateAuthority.Enroll()
      • CertificateAuthority.Reenroll()
    • CertificateAuthorityServicer
      • CertificateAuthorityServicer.Enroll()
      • CertificateAuthorityServicer.Reenroll()
    • CertificateAuthorityStub
    • add_CertificateAuthorityServicer_to_server()
  • cloudvision.Connector.gen.notification_pb2 module
  • cloudvision.Connector.gen.notification_pb2_grpc module
  • cloudvision.Connector.gen.router_pb2 module
  • cloudvision.Connector.gen.router_pb2_grpc module
    • Alpha
      • Alpha.DeleteCustomSchema()
      • Alpha.Search()
      • Alpha.SearchSubscribe()
      • Alpha.SearchWithAggregation()
      • Alpha.SearchWithAggregationStream()
      • Alpha.SetCustomSchema()
    • AlphaServicer
      • AlphaServicer.DeleteCustomSchema()
      • AlphaServicer.Search()
      • AlphaServicer.SearchSubscribe()
      • AlphaServicer.SearchWithAggregation()
      • AlphaServicer.SearchWithAggregationStream()
      • AlphaServicer.SetCustomSchema()
    • AlphaStub
    • Auth
      • Auth.CreateDataset()
      • Auth.CreateSession()
      • Auth.GetPermissionSet()
      • Auth.SetPassword()
      • Auth.SetPermission()
    • AuthServicer
      • AuthServicer.CreateDataset()
      • AuthServicer.CreateSession()
      • AuthServicer.GetPermissionSet()
      • AuthServicer.SetPassword()
      • AuthServicer.SetPermission()
    • AuthStub
    • Cluster
      • Cluster.ClusterInfo()
    • ClusterServicer
      • ClusterServicer.ClusterInfo()
    • ClusterStub
    • Querier
      • Querier.SQL()
    • QuerierServicer
      • QuerierServicer.SQL()
    • QuerierStub
    • RouterV1
      • RouterV1.Get()
      • RouterV1.GetAndSubscribe()
      • RouterV1.GetDatasets()
      • RouterV1.Publish()
      • RouterV1.Subscribe()
    • RouterV1Servicer
      • RouterV1Servicer.Get()
      • RouterV1Servicer.GetAndSubscribe()
      • RouterV1Servicer.GetDatasets()
      • RouterV1Servicer.Publish()
      • RouterV1Servicer.Subscribe()
    • RouterV1Stub
    • Search
      • Search.DeleteCustomSchema()
      • Search.Search()
      • Search.SearchSubscribe()
      • Search.SearchWithAggregation()
      • Search.SearchWithAggregationStream()
      • Search.SetCustomSchema()
    • SearchServicer
      • SearchServicer.DeleteCustomSchema()
      • SearchServicer.Search()
      • SearchServicer.SearchSubscribe()
      • SearchServicer.SearchWithAggregation()
      • SearchServicer.SearchWithAggregationStream()
      • SearchServicer.SetCustomSchema()
    • SearchStub
    • add_AlphaServicer_to_server()
    • add_AuthServicer_to_server()
    • add_ClusterServicer_to_server()
    • add_QuerierServicer_to_server()
    • add_RouterV1Servicer_to_server()
    • add_SearchServicer_to_server()
  • cloudvision.Connector.gen.sharding_pb2 module
  • cloudvision.Connector.gen.sharding_pb2_grpc module
  • Module contents
• cloudvision.Connector.grpc_client package
  • Submodules
  • cloudvision.Connector.grpc_client.grpcClient module
    • GRPCClient
      • GRPCClient.AUTH_KEY_PATH
      • GRPCClient.DEFAULT_CHANNEL_OPTIONS
      • GRPCClient.GRPC_RETRY_POLICY_JSON
      • GRPCClient.close()
      • GRPCClient.create_custom_schema_index_request()
      • GRPCClient.create_dataset()
      • GRPCClient.decode_batch()
      • GRPCClient.decode_notification()
      • GRPCClient.get()
      • GRPCClient.get_datasets()
      • GRPCClient.publish()
      • GRPCClient.reenroll()
      • GRPCClient.search()
      • GRPCClient.set_custom_schema()
      • GRPCClient.subscribe()
    • create_notification()
    • create_query()
    • to_pbts()
  • cloudvision.Connector.grpc_client.grpcConnectionPool module
    • PooledGRPCClient
      • PooledGRPCClient.get()
      • PooledGRPCClient.publish()
      • PooledGRPCClient.subscribe()
  • Module contents
    • GRPCClient
      • GRPCClient.AUTH_KEY_PATH
      • GRPCClient.DEFAULT_CHANNEL_OPTIONS
      • GRPCClient.GRPC_RETRY_POLICY_JSON
      • GRPCClient.close()
      • GRPCClient.create_custom_schema_index_request()
      • GRPCClient.create_dataset()
      • GRPCClient.decode_batch()
      • GRPCClient.decode_notification()
      • GRPCClient.get()
      • GRPCClient.get_datasets()
      • GRPCClient.publish()
      • GRPCClient.reenroll()
      • GRPCClient.search()
      • GRPCClient.set_custom_schema()
      • GRPCClient.subscribe()
    • PooledGRPCClient
      • PooledGRPCClient.get()
      • PooledGRPCClient.publish()
      • PooledGRPCClient.subscribe()
    • create_notification()
    • create_query()
• cloudvision.Connector.protobuf package
  • Module contents

Module contents

cloudvision.Connector.process_notifs(stream, paths={}, keys={}, nominalKeys=None)

process_notifs consume the batch coming from stream and return them as a hierarchy of dataset, path, and keys. Allowing for faster access of a given time serie.

cloudvision.Connector.sort_dict(resDict)

sort_dict orders every timeseries in a hierarchy of dataset by its timestamps.