Module utils

Structs

• FragmentDesc
• PartialActorLocation
• PartialActorSplits
• PartialFragmentStateTables
• PartialObject
• PartialUserPrivilege

Functions

• build_relation_group_for_delete 🔒
  Build a relation group for notifying the deletion of the given objects.
• check_connection_name_duplicate
  check_connection_name_duplicate checks whether the connection name is already used in the target namespace.
• check_database_name_duplicate
  check_database_name_duplicate checks whether the database name is already used in the cluster.
• check_function_signature_duplicate
  check_function_signature_duplicate checks whether the function name and its signature is already used in the target namespace.
• check_relation_name_duplicate
  check_relation_name_duplicate checks whether the relation name is already used in the target namespace.
• check_schema_name_duplicate
  check_schema_name_duplicate checks whether the schema name is already used in the target database.
• check_secret_name_duplicate
• check_sink_into_table_cycle
  Check if create a sink with given dependent objects into the target table will cause a cycle, return true if it will.
• check_subscription_name_duplicate
• check_user_name_duplicate
  check_user_name_duplicate checks whether the user is already existed in the cluster.
• construct_obj_dependency_query
  This function will construct a query using recursive cte to find all objects[(id, obj_type)] that are used by the given object.
• construct_privilege_dependency_query
  construct_privilege_dependency_query constructs a query to find all privileges that are dependent on the given one.
• construct_sink_cycle_check_query
  This function will construct a query using recursive cte to find if dependent objects are already relying on the target table.
• ensure_object_id
  ensure_object_id ensures the existence of target object in the cluster.
• ensure_object_not_refer
  ensure_object_not_refer ensures that object are not used by any other ones except indexes.
• ensure_privileges_not_referred
  ensure_privileges_not_referred ensures that the privileges are not granted to any other users.
• ensure_schema_empty
  ensure_schema_empty ensures that the schema is empty, used by DROP SCHEMA.
• ensure_user_id
  ensure_user_id ensures the existence of target user in the cluster.
• extract_external_table_name_from_definition
• extract_grant_obj_id
• find_stream_source
  Find the external stream source info inside the stream node, if any.
• get_actor_dispatchers
• get_fragment_actor_ids
  get_fragment_actor_ids returns the fragment actor ids of the given fragments.
• get_fragment_ids_by_jobs
• get_fragment_mappings
  get_fragment_mappings returns the fragment vnode mappings of the given job.
• get_index_state_tables_by_table_id
• get_internal_tables_by_id
• get_object_owner
  get_object_owner returns the owner of the given object.
• get_referring_objects
  List all objects that are using the given one.
• get_referring_objects_cascade
  List all objects that are using the given one in a cascade way. It runs a recursive CTE to find all the dependencies.
• get_referring_privileges_cascade
• get_user_privilege
  get_user_privilege returns the privileges of the given user.
• list_user_info_by_ids
  list_user_info_by_ids lists all users’ info by their ids.
• rebuild_fragment_mapping_from_actors
• rename_relation
  rename_relation renames the target relation and its definition, it commits the changes to the transaction and returns the updated relations and the old name.
• rename_relation_refer
  rename_relation_refer updates the definition of relations that refer to the target one, it commits the changes to the transaction and returns all the updated relations.
• resolve_source_register_info_for_jobs
  Resolve fragment list that are subscribing to sources and actor lists.