/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/avro/serializer/ |
H A D | message_serializer.py | 107 schema_id = self.registry_client.register(subject, schema) 108 if not schema_id: 130 if schema_id not in self.id_to_writers: 134 schema = self.registry_client.get_by_id(schema_id) 143 writer = self.id_to_writers[schema_id] 146 outf.write(struct.pack('>bI', MAGIC_BYTE, schema_id)) 155 if schema_id in self.id_to_decoder_func: 156 return self.id_to_decoder_func[schema_id] 186 return self.id_to_decoder_func[schema_id] 206 self.id_to_decoder_func[schema_id] = decoder [all …]
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/avro/ |
H A D | mock_schema_registry_client.py | 73 if schema_id in self.id_to_schema: 74 schema = self.id_to_schema[schema_id] 76 self.id_to_schema[schema_id] = schema 79 subject, schema, schema_id) 100 schema_id = schemas_to_id.get(avro_schema, -1) 101 if schema_id != -1: 102 return schema_id 106 schema_id = self._get_next_id(avro_schema) 110 return schema_id 112 def get_by_id(self, schema_id): argument [all …]
|
H A D | test_mock_client.py | 37 schema_id = client.register('test', parsed) 38 self.assertTrue(schema_id > 0) 44 schema_id = client.register('test', parsed) 45 self.assertTrue(schema_id > 0) 49 self.assertEqual(schema_id, dupe_id) 56 schema_id = client.register(subject, parsed) 57 self.assertTrue(schema_id > 0) 62 self.assertEqual(schema_id, dupe_id) 85 schema_id = client.register(subject, parsed) 88 self.assertLatest(latest, schema_id, parsed, version) [all …]
|
H A D | test_message_serializer.py | 39 def assertMessageIsSame(self, message, expected, schema_id): argument 44 self.assertEqual(sid, schema_id) 53 schema_id = self.client.register(subject, basic) 57 message = self.ms.encode_record_with_schema_id(schema_id, record) 58 self.assertMessageIsSame(message, record, schema_id) 62 self.assertNotEqual(adv_schema_id, schema_id) 72 schema_id = self.client.register(subject, basic) 76 self.assertMessageIsSame(message, record, schema_id)
|
H A D | test_cached_client.py | 44 schema_id = client.register('test', parsed) 45 self.assertTrue(schema_id > 0) 51 schema_id = client.register('test', parsed) 52 self.assertTrue(schema_id > 0) 56 self.assertEqual(schema_id, dupe_id) 63 schema_id = client.register(subject, parsed) 64 self.assertTrue(schema_id > 0) 69 self.assertEqual(schema_id, dupe_id) 97 fetched = client.get_by_id(schema_id) 148 schema_id = c.register('test', parsed) [all …]
|
H A D | mock_registry.py | 98 schema_id = int(groups[0]) 99 schema = self.registry.get_by_id(schema_id) 133 schema_id = self.registry.register(subject, avro_schema) 134 return (200, {'id': schema_id}) 144 schema_id = self.registry.get_id_for_schema(subject, avro_schema) 149 "id": schema_id, 156 schema_id, avro_schema, version = self.registry.get_latest_schema(subject) 157 if schema_id is None: 162 "id": schema_id,
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/avro/ |
H A D | cached_schema_registry_client.py | 181 if schema_id in self.id_to_schema: 211 if schema_id is not None: 212 return schema_id 228 schema_id = result['id'] 231 return schema_id 250 def get_by_id(self, schema_id): argument 258 if schema_id in self.id_to_schema: 308 schema_id = result['id'] 310 if schema_id in self.id_to_schema: 320 return (schema_id, schema, version) [all …]
|
/dports/math/polymake/polymake-4.5/apps/common/rules/ |
H A D | db_templates.rules | 42 # String schema_id id of the associated schema doc 43 schema_id => undef, 50 # String schema_id id 51 schema_id => undef, 66 if ( defined($options->{schema_id}) ) { 67 $info->{schema} = $options->{schema_id}; 125 my $schema_id = $options->{schema_id} // "schema.".$version; 143 print "successfully updated schema for $self->{collection} with schema_id $schema_id\n" 145 …red when trying to update the schema for $self->{collection} with schema_id $schema_id:\n$output\n… 152 print "successfully saved schema for $self->{collection} with schema_id $schema_id\n"; [all …]
|
/dports/x11-toolkits/libdazzle/libdazzle-3.42.0/src/prefs/ |
H A D | dzl-preferences.c | 74 const gchar *schema_id, in dzl_preferences_add_switch() argument 86 g_return_val_if_fail (schema_id != NULL, 0); in dzl_preferences_add_switch() 97 const gchar *schema_id, in dzl_preferences_add_spin_button() argument 108 g_return_val_if_fail (schema_id != NULL, 0); in dzl_preferences_add_spin_button() 164 const gchar *schema_id, in dzl_preferences_add_radio() argument 176 g_return_val_if_fail (schema_id != NULL, 0); in dzl_preferences_add_radio() 187 const gchar *schema_id, in dzl_preferences_add_font_button() argument 196 g_return_val_if_fail (schema_id != NULL, 0); in dzl_preferences_add_font_button() 200 …return DZL_PREFERENCES_GET_IFACE (self)->add_font_button (self, page_name, group_name, schema_id, … in dzl_preferences_add_font_button() 207 const gchar *schema_id, in dzl_preferences_add_file_chooser() argument [all …]
|
H A D | dzl-preferences.h | 58 const gchar *schema_id, 69 const gchar *schema_id, 77 const gchar *schema_id, 88 const gchar *schema_id, 98 const gchar *schema_id, 145 const gchar *schema_id, 157 const gchar *schema_id, 169 const gchar *schema_id, 187 const gchar *schema_id, 196 const gchar *schema_id,
|
/dports/security/gnutls/gnutls-3.6.16/lib/x509/ |
H A D | pkcs7_int.h | 38 typedef enum schema_id { enum 54 } schema_id; typedef 69 const struct pkcs_cipher_schema_st *_gnutls_pkcs_schema_get(schema_id schema); 89 _gnutls_pkcs_raw_decrypt_data(schema_id schema, ASN1_TYPE pkcs8_asn, 108 _gnutls_read_pkcs_schema_params(schema_id * schema, const char *password, 114 _gnutls_pkcs_write_schema_params(schema_id schema, ASN1_TYPE pkcs8_asn, 120 _gnutls_pkcs_generate_key(schema_id schema, 126 int _gnutls_pkcs7_encrypt_data(schema_id schema,
|
/dports/chinese/librime/librime-1.7.3/src/rime/ |
H A D | schema.cc | 18 Schema::Schema(const string& schema_id) in Schema() argument 19 : schema_id_(schema_id) { in Schema() 21 Config::Require("config")->Create(schema_id.substr(1)) : in Schema() 22 Config::Require("schema")->Create(schema_id)); in Schema() 39 Config* SchemaComponent::Create(const string& schema_id) { in Create() argument 40 return config_component_->Create(schema_id + ".schema"); in Create()
|
H A D | schema.h | 18 explicit Schema(const string& schema_id); 19 Schema(const string& schema_id, Config* config) in Schema() argument 20 : schema_id_(schema_id), config_(config) {} in Schema() 22 const string& schema_id() const { return schema_id_; } in schema_id() function 51 Config* Create(const string& schema_id) override;
|
/dports/devel/gnome-builder/gnome-builder-41.3/src/libide/core/ |
H A D | ide-settings.c | 54 gchar *schema_id; member 116 g_assert (schema_id != NULL); in ide_settings_set_schema_id() 118 if (!ide_str_equal0 (schema_id, self->schema_id)) in ide_settings_set_schema_id() 120 g_free (self->schema_id); in ide_settings_set_schema_id() 121 self->schema_id = g_strdup (schema_id); in ide_settings_set_schema_id() 138 if (self->schema_id == NULL) in ide_settings_constructed() 209 g_clear_pointer (&self->schema_id, g_free); in ide_settings_finalize() 335 const gchar *schema_id, in ide_settings_new() argument 344 g_assert (schema_id != NULL); in ide_settings_new() 351 "schema-id", schema_id, in ide_settings_new() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/policy/tools/ |
H A D | schema_validator.py | 356 for schema_id, expected_properties \ 363 for schema_id, expected_properties \ 483 schema_id = id(schema) 484 if schema_id not in self.expected_properties: 486 self.expected_pattern_properties[schema_id] = set( 488 self.expected_additional_properties[schema_id] = ( 490 self.used_properties[schema_id] = set() 491 self.used_pattern_properties[schema_id] = set() 492 self.used_additional_properties[schema_id] = False 500 self.used_properties[schema_id].add(property_key) [all …]
|
/dports/devel/py-twilio/twilio-7.4.0/twilio/rest/events/v1/ |
H A D | event_type.py | 36 def stream(self, schema_id=values.unset, limit=None, page_size=None): argument 56 page = self.page(schema_id=schema_id, page_size=limits['page_size'], ) 60 def list(self, schema_id=values.unset, limit=None, page_size=None): argument 77 return list(self.stream(schema_id=schema_id, limit=limit, page_size=page_size, )) 79 def page(self, schema_id=values.unset, page_token=values.unset, argument 94 'SchemaId': schema_id, 285 def schema_id(self): member in EventTypeInstance
|
/dports/devel/libserdes/libserdes-6.0.2/src/ |
H A D | framing.c | 40 int32_t schema_id; in serdes_framing_cp1_write() local 49 schema_id = htonl(ss->ss_id); in serdes_framing_cp1_write() 50 memcpy(payload+1, &schema_id, 4); in serdes_framing_cp1_write() 130 int schema_id = -1; in serdes_framing_read() local 136 r = serdes_framing_cp1_read(payloadp, sizep, &schema_id, in serdes_framing_read() 156 if (!(schema = serdes_schema_get(sd, NULL, schema_id, in serdes_framing_read()
|
/dports/www/py-quilt3/quilt3-3.6.0/quilt3/workflows/ |
H A D | __init__.py | 135 def get_pk_for_schema_id(self, schema_id: str) -> util.PhysicalKey: 137 if schema_id not in schemas: 139 schema_url = schemas[schema_id]['url'] 156 def make_validator_from_schema(self, schema_id): argument 157 if schema_id in self.loaded_schemas_by_id: 158 return self.loaded_schemas_by_id[schema_id][0] 160 schema_pk = self.get_pk_for_schema_id(schema_id) 162 self.loaded_schemas_by_id[schema_id] = self.loaded_schemas[str(schema_pk)] 163 return self.loaded_schemas_by_id[schema_id][0] 220 schema_id: str(x[1]) [all …]
|
/dports/x11-toolkits/libdazzle/libdazzle-3.42.0/src/actions/ |
H A D | dzl-settings-flag-action.c | 32 gchar *schema_id; member 68 dzl_settings_flag_action_new (const gchar *schema_id, in dzl_settings_flag_action_new() argument 73 "schema-id", schema_id, in dzl_settings_flag_action_new() 84 g_clear_pointer (&self->schema_id, g_free); in dzl_settings_flag_action_finalize() 102 g_value_set_boolean (value, self->schema_id != NULL); in dzl_settings_flag_action_get_property() 106 g_value_set_string (value, self->schema_id); in dzl_settings_flag_action_get_property() 142 g_free (self->schema_id); in dzl_settings_flag_action_set_property() 143 self->schema_id = g_value_dup_string (value); in dzl_settings_flag_action_set_property() 211 self->settings = g_settings_new (self->schema_id); in dzl_settings_flag_action_get_settings() 266 return self->schema_id && self->schema_key && self->flag_nick; in dzl_settings_flag_action_get_enabled()
|
/dports/deskutils/maliit-keyboard/keyboard-2.1.0/src/3rdparty/QGSettings/ |
H A D | qgsettings.cpp | 27 QByteArray schema_id; member 44 QGSettings::QGSettings(const QByteArray &schema_id, const QByteArray &path, QObject *parent): in QGSettings() argument 48 priv->schema_id = schema_id; in QGSettings() 52 priv->settings = g_settings_new(priv->schema_id.constData()); in QGSettings() 54 … priv->settings = g_settings_new_with_path(priv->schema_id.constData(), priv->path.constData()); in QGSettings() 156 bool QGSettings::isSchemaInstalled(const QByteArray &schema_id) in isSchemaInstalled() argument 159 GSettingsSchema *schema = g_settings_schema_source_lookup (source, schema_id.constData(), TRUE); in isSchemaInstalled()
|
/dports/chinese/librime/librime-1.7.3/src/rime/lever/ |
H A D | switcher_settings.cc | 38 for (const string& schema_id : selection_) { in Select() local 40 item->Set("schema", New<ConfigValue>(schema_id)); in Select() 64 if (!config.GetString("schema/schema_id", &info.schema_id)) in GetAvailableSchemasFromDirectory() 71 if (other.schema_id == info.schema_id) { in GetAvailableSchemasFromDirectory() 111 const string& schema_id(schema_property->str()); in GetSelectedSchemasFromConfig() local 112 selection_.push_back(schema_id); in GetSelectedSchemasFromConfig()
|
/dports/chinese/librime/librime-1.7.3/src/rime/gear/ |
H A D | schema_list_translator.cc | 23 SwitcherCommand(schema->schema_id()) { in SchemaSelection() 35 if (keyword_ != engine->schema()->schema_id()) { in Apply() 112 [this, current_schema, user_config, now](const string& schema_id) { in LoadSchemaList() argument 113 if (current_schema && schema_id == current_schema->schema_id()) in LoadSchemaList() 115 Schema schema(schema_id); in LoadSchemaList() 119 user_config->GetInt("var/schema_access_time/" + schema_id, in LoadSchemaList()
|
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/modules/network/aci/ |
H A D | mso_schema_template_deploy.py | 118 schema_id = mso.lookup_schema(schema) 121 schemaId=schema_id, 127 path = 'execute/schema/{0}/template/{1}'.format(schema_id, template) 129 path = 'status/schema/{0}/template/{1}'.format(schema_id, template) 131 path = 'execute/schema/{0}/template/{1}'.format(schema_id, template)
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/sql/dd/impl/tables/ |
H A D | triggers.cc | 129 Object_key *Triggers::create_key_by_schema_id(Object_id schema_id) { in create_key_by_schema_id() argument 131 Parent_id_range_key(INDEX_UK_SCHEMA_ID_NAME, FIELD_SCHEMA_ID, schema_id); in create_key_by_schema_id() 145 Object_key *Triggers::create_key_by_trigger_name(Object_id schema_id, in create_key_by_trigger_name() argument 148 FIELD_SCHEMA_ID, schema_id, FIELD_NAME, trigger_name, name_collation()); in create_key_by_trigger_name() 159 bool Triggers::get_trigger_table_id(THD *thd, Object_id schema_id, in get_trigger_table_id() argument 172 create_key_by_trigger_name(schema_id, trigger_name.c_str())); in get_trigger_table_id()
|
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/cisco/mso/plugins/modules/ |
H A D | mso_schema_template_deploy.py | 118 schema_id = mso.lookup_schema(schema) 121 schemaId=schema_id, 127 path = 'execute/schema/{0}/template/{1}'.format(schema_id, template) 129 path = 'status/schema/{0}/template/{1}'.format(schema_id, template) 131 path = 'execute/schema/{0}/template/{1}'.format(schema_id, template)
|