http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/node-filter.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/node-filter.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/node-filter.jade new file mode 100644 index 0000000..ee28c87 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/node-filter.jade @@ -0,0 +1,108 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'nodeFilter' +-var model = 'backupItem' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label(id='nodeFilter-title') Node filter + ignite-form-field-tooltip.tipLabel + | Determines on what nodes the cache should be started + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + -var nodeFilter = model + '.nodeFilter'; + -var nodeFilterKind = nodeFilter + '.kind'; + + +dropdown('Node filter:', nodeFilterKind, '"nodeFilter"', 'true', 'Not set', + '[\ + {value: "IGFS", label: "IGFS nodes"},\ + {value: "OnNodes", label: "Specified nodes"},\ + {value: "Custom", label: "Custom"},\ + {value: undefined, label: "Not set"}\ + ]', + 'Node filter variant' + ) + .settings-row(ng-show=nodeFilterKind) + div(ng-show='#{nodeFilterKind} === "IGFS"') + -var igfsNodeFilter = nodeFilter + '.IGFS' + -var required = nodeFilterKind + ' === "IGFS"' + + //(lbl, model, name, enabled, required, placeholder, options, tip) + +dropdown-required-empty('IGFS:', igfsNodeFilter + '.igfs', '"igfsNodeFilter"', 'true', required, + 'Choose IGFS', 'No IGFS configured', 'igfss', 'Select IGFS to filter nodes') + div(ng-show='#{nodeFilterKind} === "Custom"') + -var customNodeFilter = nodeFilter + '.Custom' + -var required = nodeFilterKind + ' === "Custom"' + + +java-class('Class name:', customNodeFilter + '.className', '"customNodeFilter"', + 'true', required, 'Class name of custom node filter implementation') + div(ng-show='#{nodeFilterKind} === "OnNodes"') + -var nodeSetFilter = nodeFilter + '.OnNodes.nodeIds' + + +ignite-form-group(ng-form=form ng-model=nodeSetFilter) + -var uniqueTip = 'Such node ID already exists!' + + ignite-form-field-label + | Node IDs + ignite-form-group-tooltip + | Set of node IDs to deploy cache + ignite-form-group-add(ng-click='group.add = [{}]') + | Add new node ID + + .group-content(ng-if='#{nodeSetFilter}.length') + -var model = 'obj.model'; + -var name = '"edit" + $index' + -var valid = form + '[' + name + '].$valid' + -var save = nodeSetFilter + '[$index] = ' + model + + div(ng-repeat='model in #{nodeSetFilter} track by $index' ng-init='obj = {}') + label.col-xs-12.col-sm-12.col-md-12 + .indexField + | {{ $index+1 }}) + +table-remove-button(nodeSetFilter, 'Remove node ID') + + span(ng-hide='field.edit') + a.labelFormField(ng-click='field.edit = true; #{model} = model;') {{ model }} + span(ng-if='field.edit' ng-init='#{field} = model') + +table-uuid-field(name, model, nodeSetFilter, valid, save, false, true) + +table-save-button(valid, save, false) + +unique-feedback(name, uniqueTip) + +uuid-feedback(name) + + .group-content(ng-repeat='field in group.add') + -var model = 'new'; + -var name = '"new"' + -var valid = form + '[' + name + '].$valid' + -var save = nodeSetFilter + '.push(' + model + ')' + + div + label.col-xs-12.col-sm-12.col-md-12 + +table-uuid-field(name, model, nodeSetFilter, valid, save, true, true) + +table-save-button(valid, save, true) + +unique-feedback(name, uniqueTip) + +uuid-feedback(name) + .group-content-empty(id='nodeSetFilter' ng-if='!(#{nodeSetFilter}.length) && !group.add.length') + | Not defined + + .col-sm-6 + +preview-xml-java(model, 'cacheNodeFilter', 'igfss')
http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/query.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/query.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/query.jade new file mode 100644 index 0000000..c83114b --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/query.jade @@ -0,0 +1,95 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'query' +-var model = 'backupItem' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Queries & Indexing + ignite-form-field-tooltip.tipLabel + | Cache queries settings + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +text('SQL schema name:', model + '.sqlSchema', '"sqlSchema"', 'false', 'Input schema name', 'Schema name for cache according to SQL ANSI-99') + .settings-row + +number('On-heap cache for off-heap indexes:', model + '.sqlOnheapRowCacheSize', '"sqlOnheapRowCacheSize"', 'true', '10240', '1', + 'Number of SQL rows which will be cached onheap to avoid deserialization on each SQL index access') + .settings-row + +number('Long query timeout:', model + '.longQueryWarningTimeout', '"longQueryWarningTimeout"', 'true', '3000', '0', + 'Timeout in milliseconds after which long query warning will be printed') + .settings-row + -var form = 'querySqlFunctionClasses'; + -var sqlFunctionClasses = model + '.sqlFunctionClasses'; + + +ignite-form-group(ng-form=form ng-model=sqlFunctionClasses) + ignite-form-field-label + | SQL functions + ignite-form-group-tooltip + | Collections of classes with user-defined functions for SQL queries + ignite-form-group-add(ng-click='group.add = [{}]') + | Add new user-defined functions for SQL queries + + -var uniqueTip = 'SQL function with such class name already exists!' + + .group-content(ng-if='#{sqlFunctionClasses}.length') + -var model = 'obj.model'; + -var name = '"edit" + $index' + -var valid = form + '[' + name + '].$valid' + -var save = sqlFunctionClasses + '[$index] = ' + model + + div(ng-repeat='model in #{sqlFunctionClasses} track by $index' ng-init='obj = {}') + label.col-xs-12.col-sm-12.col-md-12 + .indexField + | {{ $index+1 }}) + +table-remove-button(sqlFunctionClasses, 'Remove user-defined function') + + span(ng-hide='field.edit') + a.labelFormField(ng-click='field.edit = true; #{model} = model;') {{ model }} + span(ng-if='field.edit') + +table-java-class-field('SQL function', name, model, sqlFunctionClasses, valid, save, false) + +table-save-button(valid, save, false) + +unique-feedback(name, uniqueTip) + + .group-content(ng-repeat='field in group.add') + -var model = 'new'; + -var name = '"new"' + -var valid = form + '[' + name + '].$valid' + -var save = sqlFunctionClasses + '.push(' + model + ')' + + div + label.col-xs-12.col-sm-12.col-md-12 + +table-java-class-field('SQL function', name, model, sqlFunctionClasses, valid, save, true) + +table-save-button(valid, save, true) + +unique-feedback(name, uniqueTip) + + .group-content-empty(ng-if='!(#{sqlFunctionClasses}.length) && !group.add.length') + | Not defined + .settings-row + +checkbox('Snapshotable index', model + '.snapshotableIndex', '"snapshotableIndex"', + 'Flag indicating whether SQL indexes should support snapshots') + .settings-row + +checkbox('Escape table and filed names', model + '.sqlEscapeAll', '"sqlEscapeAll"', + 'If set then all the SQL table and field names will be escaped with double quotes<br/>\ + This enforces case sensitivity for field names and also allows having special characters in table and field names') + .col-sm-6 + +preview-xml-java(model, 'cacheQuery', 'domains') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/rebalance.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/rebalance.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/rebalance.jade new file mode 100644 index 0000000..6cf2d33 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/rebalance.jade @@ -0,0 +1,65 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'rebalance' +-var model = 'backupItem' + +.panel.panel-default(ng-form=form novalidate ng-hide='#{model}.cacheMode === "LOCAL"') + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Rebalance + ignite-form-field-tooltip.tipLabel + | Cache rebalance settings + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +dropdown('Mode:', model + '.rebalanceMode', '"rebalanceMode"', 'true', 'ASYNC', + '[\ + {value: "SYNC", label: "SYNC"},\ + {value: "ASYNC", label: "ASYNC"},\ + {value: "NONE", label: "NONE"}\ + ]', + 'Rebalance modes\ + <ul>\ + <li>Synchronous - in this mode distributed caches will not start until all necessary data is loaded from other available grid nodes</li>\ + <li>Asynchronous - in this mode distributed caches will start immediately and will load all necessary data from other available grid nodes in the background</li>\ + <li>None - in this mode no rebalancing will take place which means that caches will be either loaded on demand from persistent store whenever data is accessed, or will be populated explicitly</li>\ + </ul>') + .settings-row + +number('Batch size:', model + '.rebalanceBatchSize', '"rebalanceBatchSize"', 'true', '512 * 1024', '1', + 'Size (in bytes) to be loaded within a single rebalance message<br/>\ + Rebalancing algorithm will split total data set on every node into multiple batches prior to sending data') + .settings-row + +number('Batches prefetch count:', model + '.rebalanceBatchesPrefetchCount', '"rebalanceBatchesPrefetchCount"', 'true', '2', '1', + 'Number of batches generated by supply node at rebalancing start') + .settings-row + +number('Order:', model + '.rebalanceOrder', '"rebalanceOrder"', 'true', '0', Number.MIN_SAFE_INTEGER, + 'If cache rebalance order is positive, rebalancing for this cache will be started only when rebalancing for all caches with smaller rebalance order (except caches with rebalance order 0) will be completed') + .settings-row + +number('Delay:', model + '.rebalanceDelay', '"rebalanceDelay"', 'true', '0', '0', + 'Delay in milliseconds upon a node joining or leaving topology (or crash) after which rebalancing should be started automatically') + .settings-row + +number('Timeout:', model + '.rebalanceTimeout', '"rebalanceTimeout"', 'true', '10000', '0', + 'Rebalance timeout in milliseconds') + .settings-row + +number('Throttle:', model + '.rebalanceThrottle', '"rebalanceThrottle"', 'true', '0', '0', + 'Time in milliseconds to wait between rebalance messages to avoid overloading of CPU or network') + .col-sm-6 + +preview-xml-java(model, 'cacheRebalance') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/server-near-cache.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/server-near-cache.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/server-near-cache.jade new file mode 100644 index 0000000..74f500b --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/server-near-cache.jade @@ -0,0 +1,51 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'serverNearCache' +-var model = 'backupItem' + +.panel.panel-default(ng-form=form novalidate ng-show='#{model}.cacheMode === "PARTITIONED"') + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Server near cache + ignite-form-field-tooltip.tipLabel + | Near cache settings#[br] + | Near cache is a small local cache that stores most recently or most frequently accessed data#[br] + | Should be used in case when it is impossible to send computations to remote nodes + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + -var enabled = model + '.nearCacheEnabled' + -var nearCfg = model + '.nearConfiguration' + + .settings-row + +checkbox('Enabled', enabled, '"nearCacheEnabled"', 'Flag indicating whether to configure near cache') + .settings-row + +number('Start size:', nearCfg + '.nearStartSize', '"nearStartSize"', enabled, '375000', '0', + 'Initial cache size for near cache which will be used to pre-create internal hash table after start') + .settings-row + +evictionPolicy(model + '.nearConfiguration.nearEvictionPolicy', '"nearCacheEvictionPolicy"', enabled, 'false', + 'Near cache eviction policy\ + <ul>\ + <li>Least Recently Used (LRU) - Eviction policy based on LRU algorithm and supports batch eviction</li>\ + <li>First In First Out (FIFO) - Eviction policy based on FIFO algorithm and supports batch eviction</li>\ + <li>SORTED - Eviction policy which will select the minimum cache entry for eviction</li>\ + </ul>') + .col-sm-6 + +preview-xml-java(model, 'cacheServerNearCache') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/statistics.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/statistics.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/statistics.jade new file mode 100644 index 0000000..027a2bd --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/statistics.jade @@ -0,0 +1,39 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'statistics' +-var model = 'backupItem' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Statistics + ignite-form-field-tooltip.tipLabel + | Cache statistics and management settings + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +checkbox('Statistics enabled', model + '.statisticsEnabled', '"statisticsEnabled"', 'Flag indicating whether statistics gathering is enabled on this cache') + .settings-row + +checkbox('Management enabled', model + '.managementEnabled', '"managementEnabled"', + 'Flag indicating whether management is enabled on this cache<br/>\ + If enabled the CacheMXBean for each cache is registered in the platform MBean server') + .col-sm-6 + +preview-xml-java(model, 'cacheStatistics') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/caches/store.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/caches/store.jade b/modules/web-console/frontend/app/modules/states/configuration/caches/store.jade new file mode 100644 index 0000000..84752d6 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/caches/store.jade @@ -0,0 +1,244 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'store' +-var model = 'backupItem' + +mixin hibernateField(name, model, items, valid, save, newItem) + -var reset = newItem ? 'group.add = []' : 'field.edit = false' + + -var resetOnEnter = newItem ? '(stopblur = true) && (group.add = [{}])' : '(field.edit = false)' + -var onEnter = valid + ' && (' + save + '); ' + valid + ' && ' + resetOnEnter + ';' + + -var resetOnBlur = newItem ? '!stopblur && (group.add = [])' : 'field.edit = false' + -var onBlur = valid + ' && ( ' + save + '); ' + resetOnBlur + ';' + + if block + block + + .input-tip + +ignite-form-field-input(name, model, false, 'true', 'key=value')( + data-ignite-property-unique=items + data-ignite-property-value-specified + data-ignite-form-field-input-autofocus='true' + + ng-blur=onBlur + ignite-on-enter=onEnter + ignite-on-escape=onEscape + ) + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Store + ignite-form-field-tooltip.tipLabel + | Cache store settings + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + -var storeFactory = model + '.cacheStoreFactory'; + -var storeFactoryKind = storeFactory + '.kind'; + + +dropdown('Store factory:', storeFactoryKind, '"cacheStoreFactory"', 'true', 'Not set', + '[\ + {value: "CacheJdbcPojoStoreFactory", label: "JDBC POJO store factory"},\ + {value: "CacheJdbcBlobStoreFactory", label: "JDBC BLOB store factory"},\ + {value: "CacheHibernateBlobStoreFactory", label: "Hibernate BLOB store factory"},\ + {value: undefined, label: "Not set"}\ + ]', + 'Factory for persistent storage for cache data\ + <ul>\ + <li>JDBC POJO store factory - Objects are stored in underlying database by using java beans mapping description via reflection backed by JDBC</li>\ + <li>JDBC BLOB store factory - Objects are stored in underlying database in BLOB format backed by JDBC</li>\ + <li>Hibernate BLOB store factory - Objects are stored in underlying database in BLOB format backed by Hibernate</li>\ + </ul>' + ) + span(ng-show=storeFactoryKind ng-init='__.expanded = true') + a.customize(ng-show='__.expanded' ng-click='__.expanded = false') Hide settings + a.customize(ng-hide='__.expanded' ng-click='__.expanded = true') Show settings + .panel-details(ng-show='__.expanded') + div(ng-show='#{storeFactoryKind} === "CacheJdbcPojoStoreFactory"') + -var pojoStoreFactory = storeFactory + '.CacheJdbcPojoStoreFactory' + -var required = storeFactoryKind + ' === "CacheJdbcPojoStoreFactory"' + + .details-row + +text('Data source bean name:', pojoStoreFactory + '.dataSourceBean', + '"pojoDataSourceBean"', required, 'Input bean name', + 'Name of the data source bean in Spring context') + .details-row + +dialect('Dialect:', pojoStoreFactory + '.dialect', '"pojoDialect"', required, + 'Dialect of SQL implemented by a particular RDBMS:', 'Generic JDBC dialect', + 'Choose JDBC dialect') + div(ng-show='#{storeFactoryKind} === "CacheJdbcBlobStoreFactory"') + -var blobStoreFactory = storeFactory + '.CacheJdbcBlobStoreFactory' + -var blobStoreFactoryVia = blobStoreFactory + '.connectVia' + + .details-row + +dropdown('Connect via:', blobStoreFactoryVia, '"connectVia"', 'true', 'Choose connection method', + '[\ + {value: "URL", label: "URL"},\ + {value: "DataSource", label: "Data source"}\ + ]', + 'You can connect to database via:\ + <ul>\ + <li>JDBC URL, for example: jdbc:h2:mem:myDatabase</li>\ + <li>Configured data source</li>\ + </ul>') + div(ng-show='#{blobStoreFactoryVia} === "URL"') + -var required = storeFactoryKind + ' === "CacheJdbcBlobStoreFactory" && ' + blobStoreFactoryVia + ' === "URL"' + + .details-row + +text('Connection URL:', blobStoreFactory + '.connectionUrl', '"connectionUrl"', required, 'Input URL', + 'URL for database access, for example: jdbc:h2:mem:myDatabase') + .details-row + +text('User:', blobStoreFactory + '.user', '"user"', required, 'Input user name', 'User name for database access') + .details-row + label Note, password will be generated as stub + div(ng-show='#{blobStoreFactoryVia} !== "URL"') + -var required = storeFactoryKind + ' === "CacheJdbcBlobStoreFactory" && ' + blobStoreFactoryVia + '!== "URL"' + + .details-row + +text('Data source bean name:', blobStoreFactory + '.dataSourceBean', '"blobDataSourceBean"', required, 'Input bean name', + 'Name of the data source bean in Spring context') + .details-row + +dialect('Database:', blobStoreFactory + '.dialect', '"blobDialect"', required, 'Supported databases:', 'Generic database', 'Choose database') + .details-row + +checkbox('Init schema', blobStoreFactory + '.initSchema', '"initSchema"', + 'Flag indicating whether DB schema should be initialized by Ignite (default behaviour) or was explicitly created by user') + .details-row + +text('Create query:', blobStoreFactory + '.createTableQuery', '"createTableQuery"', 'false', 'SQL for table creation', + 'Query for table creation in underlying database<br/>\ + Default value: create table if not exists ENTRIES (key binary primary key, val binary)') + .details-row + +text('Load query:', blobStoreFactory + '.loadQuery', '"loadQuery"', 'false', 'SQL for load entry', + 'Query for entry load from underlying database<br/>\ + Default value: select * from ENTRIES where key=?') + .details-row + +text('Insert query:', blobStoreFactory + '.insertQuery', '"insertQuery"', 'false', 'SQL for insert entry', + 'Query for insert entry into underlying database<br/>\ + Default value: insert into ENTRIES (key, val) values (?, ?)') + .details-row + +text('Update query:', blobStoreFactory + '.updateQuery', '"updateQuery"', 'false', 'SQL for update entry', + 'Query for update entry in underlying database<br/>\ + Default value: update ENTRIES set val=? where key=?') + .details-row + +text('Delete query:', blobStoreFactory + '.deleteQuery', '"deleteQuery"', 'false', 'SQL for delete entry', + 'Query for delete entry from underlying database<br/>\ + Default value: delete from ENTRIES where key=?') + + div(ng-show='#{storeFactoryKind} === "CacheHibernateBlobStoreFactory"') + -var hibernateStoreFactory = storeFactory + '.CacheHibernateBlobStoreFactory' + -var hibernateProperties = hibernateStoreFactory + '.hibernateProperties' + + .details-row + +ignite-form-group(ng-form=form ng-model=hibernateProperties) + ignite-form-field-label + | Hibernate properties + ignite-form-group-tooltip + | List of Hibernate properties#[br] + | For example: connection.url=jdbc:h2:mem:exampleDb + ignite-form-group-add(ng-click='group.add = [{}]') + | Add new Hibernate property + + -var tipUnique = 'Property with such key already exists!' + -var tipPropertySpecified = 'Property should be present in format key=value!' + + .group-content(ng-if='#{hibernateProperties}.length') + -var model = 'obj.model'; + -var name = '"edit" + $index' + -var valid = form + '[' + name + '].$valid' + -var save = hibernateProperties + '[$index] = ' + model + + div(ng-repeat='model in #{hibernateProperties} track by $index' ng-init='obj = {}') + label.col-xs-12.col-sm-12.col-md-12 + .indexField + | {{ $index+1 }}) + +table-remove-button(hibernateProperties, 'Remove Hibernate property') + + span(ng-hide='field.edit') + a.labelFormField(ng-click='field.edit = true; #{model} = model;') {{ model }} + span(ng-if='field.edit') + +hibernateField(name, model, hibernateProperties, valid, save, false) + +table-save-button(valid, save, false) + +form-field-feedback(name, 'ignitePropertyUnique', tipUnique) + +form-field-feedback(name, 'ignitePropertyValueSpecified', tipPropertySpecified) + + .group-content(ng-repeat='field in group.add') + -var model = 'new'; + -var name = '"new"' + -var valid = form + '[' + name + '].$valid' + -var save = hibernateProperties + '.push(' + model + ')' + + div + label.col-xs-12.col-sm-12.col-md-12 + +hibernateField(name, model, hibernateProperties, valid, save, true) + +table-save-button(valid, save, true) + +form-field-feedback(name, 'ignitePropertyUnique', tipUnique) + +form-field-feedback(name, 'ignitePropertyValueSpecified', tipPropertySpecified) + .group-content-empty(ng-if='!(#{hibernateProperties}.length) && !group.add.length') + | Not defined + + .settings-row + +checkbox('Keep binary in store', model + '.storeKeepBinary', '"storeKeepBinary"', + 'Flag indicating that CacheStore implementation is working with binary objects instead of Java objects') + .settings-row + +checkbox('Load previous value', model + '.loadPreviousValue', '"loadPreviousValue"', + 'Flag indicating whether value should be loaded from store if it is not in the cache for following cache operations: \ + <ul> \ + <li>IgniteCache.putIfAbsent()</li> \ + <li>IgniteCache.replace()</li> \ + <li>IgniteCache.remove()</li> \ + <li>IgniteCache.getAndPut()</li> \ + <li>IgniteCache.getAndRemove()</li> \ + <li>IgniteCache.getAndReplace()</li> \ + <li> IgniteCache.getAndPutIfAbsent()</li>\ + </ul>') + .settings-row + +checkbox('Read-through', model + '.readThrough', '"readThrough"', 'Flag indicating whether read-through caching should be used') + .settings-row + +checkbox('Write-through', model + '.writeThrough', '"writeThrough"', 'Flag indicating whether write-through caching should be used') + .settings-row + +ignite-form-group + ignite-form-field-label + | Write-behind + ignite-form-group-tooltip + | Cache write-behind settings#[br] + | Write-behind is a special mode when updates to cache accumulated and then asynchronously flushed to persistent store as a bulk operation + .group-content + -var enabled = model + '.writeBehindEnabled' + + .details-row + +checkbox('Enabled', enabled, '"writeBehindEnabled"', 'Flag indicating whether Ignite should use write-behind behaviour for the cache store') + .details-row + +number('Batch size:', model + '.writeBehindBatchSize', '"writeBehindBatchSize"', enabled, '512', '1', + 'Maximum batch size for write-behind cache store operations<br/>\ + Store operations(get or remove) are combined in a batch of this size to be passed to cache store') + .details-row + +number('Flush size:', model + '.writeBehindFlushSize', '"writeBehindFlushSize"', enabled, '10240', '0', + 'Maximum size of the write-behind cache<br/>\ + If cache size exceeds this value, all cached items are flushed to the cache store and write cache is cleared') + .details-row + +number('Flush frequency:', model + '.writeBehindFlushFrequency', '"writeBehindFlushFrequency"', enabled, '5000', '0', + 'Frequency with which write-behind cache is flushed to the cache store in milliseconds') + .details-row + +number('Flush threads count:', model + '.writeBehindFlushThreadCount', '"writeBehindFlushThreadCount"', enabled, '1', '1', + 'Number of threads that will perform cache flushing') + .col-sm-6 + +preview-xml-java(model, 'cacheStore', 'domains') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/atomic.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/atomic.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/atomic.jade new file mode 100644 index 0000000..c4ef88e --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/atomic.jade @@ -0,0 +1,53 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'atomics' +-var model = 'backupItem.atomicConfiguration' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle='' ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Atomic configuration + ignite-form-field-tooltip.tipLabel + | Configuration for atomic data structures#[br] + | Atomics are distributed across the cluster, essentially enabling performing atomic operations (such as increment-and-get or compare-and-set) with the same globally-visible value + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target='' id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +dropdown('Cache mode:', model + '.cacheMode', '"cacheMode"', 'true', 'PARTITIONED', + '[\ + {value: "LOCAL", label: "LOCAL"},\ + {value: "REPLICATED", label: "REPLICATED"},\ + {value: "PARTITIONED", label: "PARTITIONED"}\ + ]', + 'Cache modes:\ + <ul>\ + <li>Partitioned - in this mode the overall key set will be divided into partitions and all partitions will be split equally between participating nodes</li>\ + <li>Replicated - in this mode all the keys are distributed to all participating nodes</li>\ + <li>Local - in this mode caches residing on different grid nodes will not know about each other</li>\ + </ul>') + .settings-row + +number('Sequence reserve:', model + '.atomicSequenceReserveSize', '"atomicSequenceReserveSize"', 'true', '1000', '0', + 'Default number of sequence values reserved for IgniteAtomicSequence instances<br/>\ + After a certain number has been reserved, consequent increments of sequence will happen locally, without communication with other nodes, until the next reservation has to be made') + .settings-row(ng-show='!(#{model}.cacheMode && #{model}.cacheMode != "PARTITIONED")') + +number('Backups:', model + '.backups', '"backups"', 'true', '0', '0', 'Number of backup nodes') + .col-sm-6 + +preview-xml-java(model, 'clusterAtomics') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/attributes.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/attributes.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/attributes.jade new file mode 100644 index 0000000..29e7a79 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/attributes.jade @@ -0,0 +1,57 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'attributes' +-var model = 'backupItem' +-var userAttributes = model + '.attributes' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label User attributes + ignite-form-field-tooltip.tipLabel + | Configuration for Ignite user attributes + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +ignite-form-group(ng-model='#{userAttributes}' ng-form='#{form}') + ignite-form-field-label + | User attributes + ignite-form-group-tooltip + | User-defined attributes to add to node + ignite-form-group-add(ng-click='tableNewItem(attributesTbl)') + | Add user attribute + .group-content-empty(ng-if='!((#{userAttributes} && #{userAttributes}.length > 0) || tableNewItemActive(attributesTbl))') + | Not defined + .group-content(ng-show='(#{userAttributes} && #{userAttributes}.length > 0) || tableNewItemActive(attributesTbl)') + table.links-edit(id='attributes' st-table=userAttributes) + tbody + tr(ng-repeat='item in #{userAttributes}') + td.col-sm-12(ng-show='!tableEditing(attributesTbl, $index)') + a.labelFormField(ng-click='tableStartEdit(backupItem, attributesTbl, $index)') {{item.name}} = {{item.value}} + +btn-remove('tableRemove(backupItem, attributesTbl, $index)', '"Remove attribute"') + td.col-sm-12(ng-show='tableEditing(attributesTbl, $index)') + +table-pair-edit('attributesTbl', 'cur', 'Attribute name', 'Attribute value', false, false, '{{::attributesTbl.focusId + $index}}', '$index', '=') + tfoot(ng-show='tableNewItemActive(attributesTbl)') + tr + td.col-sm-12 + +table-pair-edit('attributesTbl', 'new', 'Attribute name', 'Attribute value', false, false, '{{::attributesTbl.focusId + $index}}', '-1', '=') + .col-sm-6 + +preview-xml-java(model, 'clusterUserAttributes') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/binary.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/binary.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/binary.jade new file mode 100644 index 0000000..c63e2d9 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/binary.jade @@ -0,0 +1,77 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'binary' +-var model = 'backupItem.binaryConfiguration' +-var types = model + '.typeConfigurations' + +//- Mixin for java name field with enabled condition. +mixin binary-types-java-class(lbl, model, name, enabled, required, remove, autofocus, tip) + +java-class(lbl, model, name, enabled, required, tip) + if (remove) + +table-remove-button(types, 'Remove type configuration') + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Binary configuration + ignite-form-field-tooltip.tipLabel + | Configuration of specific binary types + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +java-class('ID mapper:', model + '.idMapper', '"idMapper"', 'true', 'false', + 'Maps given from BinaryNameMapper type and filed name to ID that will be used by Ignite in internals<br/>\ + Ignite never writes full strings for field or type names. Instead, for performance reasons, Ignite writes integer hash codes for type/class and field names. It has been tested that hash code conflicts for the type/class names or the field names within the same type are virtually non - existent and, to gain performance, it is safe to work with hash codes. For the cases when hash codes for different types or fields actually do collide <b>BinaryIdMapper</b> allows to override the automatically generated hash code IDs for the type and field names') + .settings-row + +java-class('Name mapper:', model + '.nameMapper', '"nameMapper"', 'true', 'false', 'Maps type/class and field names to different names') + .settings-row + +java-class('Serializer:', model + '.serializer', '"serializer"', 'true', 'false', 'Class with custom serialization logic for binary objects') + .settings-row + -var form = 'binaryTypeConfigurations'; + + +ignite-form-group() + ignite-form-field-label + | Type configurations + ignite-form-group-tooltip + | Configuration properties for binary types + ignite-form-group-add(ng-click='#{types}.push({})') + | Add new type configuration. + .group-content-empty(ng-if='!#{types}.length') + | Not defined + .group-content(ng-repeat='model in #{types} track by $index') + hr(ng-if='$index !== 0') + .settings-row + +binary-types-java-class('Type name:', 'model.typeName', '"typeName" + $index', 'true', 'true', true, 'true', 'Type name') + .settings-row + +binary-types-java-class('ID mapper:', 'model.idMapper', '"idMapper" + $index', 'true', 'false', false, 'false', + 'Maps given from BinaryNameMapper type and filed name to ID that will be used by Ignite in internals<br/>\ + Ignite never writes full strings for field or type/class names. Instead, for performance reasons, Ignite writes integer hash codes for type/class and field names. It has been tested that hash code conflicts for the type/class names or the field names within the same type are virtually non - existent and, to gain performance, it is safe to work with hash codes. For the cases when hash codes for different types or fields actually do collide <b>BinaryIdMapper</b> allows to override the automatically generated hash code IDs for the type and field names') + .settings-row + +binary-types-java-class('Name mapper:', 'model.nameMapper', '"nameMapper" + $index', 'true', 'false', false, 'false', 'Maps type/class and field names to different names') + .settings-row + +binary-types-java-class('Serializer:', 'model.serializer', '"serializer" + $index', 'true', 'false', false, 'false', 'Class with custom serialization logic for binary object') + .settings-row + +checkbox('Enum', 'model.enum', 'enum', 'Flag indicating that this type is the enum') + + .settings-row + +checkbox('Compact footer', model + '.compactFooter', '"compactFooter"', 'When enabled, Ignite will not write fields metadata when serializing objects(this will increase serialization performance), because internally #[b BinaryMarshaller] already distribute metadata inside cluster') + .col-sm-6 + +preview-xml-java(model, 'clusterBinary') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/cache-key-cfg.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/cache-key-cfg.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/cache-key-cfg.jade new file mode 100644 index 0000000..a078bf1 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/cache-key-cfg.jade @@ -0,0 +1,53 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'cacheKeyCfg' +-var model = 'backupItem.cacheKeyConfiguration' +-var items = model; + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Cache key configuration + ignite-form-field-tooltip.tipLabel + | Cache key configuration allows to collocate objects in a partitioned cache based on field in cache key without explicit usage of annotations on user classes. + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + -var form = form + 'TypeConfigurations' + + +ignite-form-group(ng-form=form ng-model=model) + ignite-form-field-label + | Cache key configuration + ignite-form-group-tooltip + | Cache key configuration + ignite-form-group-add(ng-click='#{model}.push({})') + | Add new cache key configuration + .group-content-empty(ng-if='!#{model}.length') + | Not defined + .group-content(ng-repeat='model in #{model} track by $index') + hr(ng-if='$index !== 0') + .settings-row + +java-class('Type name:', 'model.typeName', '"cacheKeyTypeName" + $index', 'true', 'true', 'Type name') + +table-remove-button(items, 'Remove cache key configuration') + .settings-row + +text('Affinity key field name:', 'model.affinityKeyFieldName', '"affinityKeyFieldName" + $index', true, 'Enter field name', 'Affinity key field name') + .col-sm-6 + +preview-xml-java(model, 'clusterCacheKeyConfiguration') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision.jade new file mode 100644 index 0000000..491e4f1 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision.jade @@ -0,0 +1,62 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'collision' +-var model = 'backupItem.collision' +-var modelCollisionKind = model + '.kind'; + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Collision configuration + ignite-form-field-tooltip.tipLabel + | Configuration Collision SPI allows to regulate how grid jobs get executed when they arrive on a destination node for execution + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +dropdown('CollisionSpi:', modelCollisionKind, '"collisionKind"', 'true', '', + '[\ + {value: "JobStealing", label: "Job stealing"},\ + {value: "FifoQueue", label: "FIFO queue"},\ + {value: "PriorityQueue", label: "Priority queue"},\ + {value: "Custom", label: "Custom"},\ + {value: "Noop", label: "Default"}\ + ]', + 'Regulate how grid jobs get executed when they arrive on a destination node for execution\ + <ul>\ + <li>Job stealing - supports job stealing from over-utilized nodes to under-utilized nodes</li>\ + <li>FIFO queue - jobs are ordered as they arrived</li>\ + <li>Priority queue - jobs are first ordered by their priority</li>\ + <li>Custom - custom CollisionSpi implementation</li>\ + <li>Default - jobs are activated immediately on arrival to mapped node</li>\ + </ul>') + .settings-row(ng-show='#{modelCollisionKind} !== "Noop"') + .panel-details + div(ng-show='#{modelCollisionKind} === "JobStealing"') + include ./collision/job-stealing.jade + div(ng-show='#{modelCollisionKind} === "FifoQueue"') + include ./collision/fifo-queue.jade + div(ng-show='#{modelCollisionKind} === "PriorityQueue"') + include ./collision/priority-queue.jade + div(ng-show='#{modelCollisionKind} === "Custom"') + include ./collision/custom.jade + .col-sm-6 + -var model = 'backupItem.collision' + +preview-xml-java(model, 'clusterCollision') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/custom.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/custom.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/custom.jade new file mode 100644 index 0000000..9238917 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/custom.jade @@ -0,0 +1,24 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../../app/helpers/jade/mixins.jade + +-var model = 'backupItem.collision.Custom' +-var required = 'backupItem.collision.kind === "Custom"' + +div + .details-row + +java-class('Class:', model + '.class', '"collisionCustom"', 'true', required, 'CollisionSpi implementation class') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/fifo-queue.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/fifo-queue.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/fifo-queue.jade new file mode 100644 index 0000000..f16363d --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/fifo-queue.jade @@ -0,0 +1,27 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../../app/helpers/jade/mixins.jade + +-var model = 'backupItem.collision.FifoQueue' + +div + .details-row + +number('Parallel jobs number:', model + '.parallelJobsNumber', '"fifoParallelJobsNumber"', 'true', 'availableProcessors * 2', '1', + 'Number of jobs that can be executed in parallel') + .details-row + +number('Wait jobs number:', model + '.waitingJobsNumber', '"fifoWaitingJobsNumber"', 'true', 'Integer.MAX_VALUE', '0', + 'Maximum number of jobs that are allowed to wait in waiting queue') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/job-stealing.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/job-stealing.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/job-stealing.jade new file mode 100644 index 0000000..3e6d428 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/job-stealing.jade @@ -0,0 +1,63 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../../app/helpers/jade/mixins.jade + +-var model = 'backupItem.collision.JobStealing' +-var stealingAttributes = model + '.stealingAttributes' + +div + .details-row + +number('Active jobs threshold:', model + '.activeJobsThreshold', '"jsActiveJobsThreshold"', 'true', '95', '0', + 'Number of jobs that can be executed in parallel') + .details-row + +number('Wait jobs threshold:', model + '.waitJobsThreshold', '"jsWaitJobsThreshold"', 'true', '0', '0', + 'Job count threshold at which this node will start stealing jobs from other nodes') + .details-row + +number('Message expire time:', model + '.messageExpireTime', '"jsMessageExpireTime"', 'true', '1000', '1', + 'Message expire time in ms') + .details-row + +number('Maximum stealing attempts:', model + '.maximumStealingAttempts', '"jsMaximumStealingAttempts"', 'true', '5', '1', + 'Maximum number of attempts to steal job by another node') + .details-row + +checkbox('Stealing enabled', model + '.stealingEnabled', '"jsStealingEnabled"', + 'Node should attempt to steal jobs from other nodes') + .details-row + +java-class('External listener:', model + '.externalCollisionListener', '"jsExternalCollisionListener"', 'true', 'false', + 'Listener to be set for notification of external collision events') + .details-row + +ignite-form-group(ng-model='#{stealingAttributes}' ng-form='#{form}') + ignite-form-field-label + | Stealing attributes + ignite-form-group-tooltip + | Configuration parameter to enable stealing to/from only nodes that have these attributes set + ignite-form-group-add(ng-click='tableNewItem(stealingAttributesTbl)') + | Add stealing attribute + .group-content-empty(ng-if='!((#{stealingAttributes} && #{stealingAttributes}.length > 0) || tableNewItemActive(stealingAttributesTbl))') + | Not defined + .group-content(ng-show='(#{stealingAttributes} && #{stealingAttributes}.length > 0) || tableNewItemActive(stealingAttributesTbl)') + table.links-edit(id='attributes' st-table=stealingAttributes) + tbody + tr(ng-repeat='item in #{stealingAttributes} track by $index') + td.col-sm-12(ng-show='!tableEditing(stealingAttributesTbl, $index)') + a.labelFormField(ng-click='tableStartEdit(backupItem, stealingAttributesTbl, $index)') {{item.name}} = {{item.value}} + +btn-remove('tableRemove(backupItem, stealingAttributesTbl, $index)', '"Remove attribute"') + td.col-sm-12(ng-show='tableEditing(stealingAttributesTbl, $index)') + +table-pair-edit('stealingAttributesTbl', 'cur', 'Attribute name', 'Attribute value', false, false, '{{::stealingAttributesTbl.focusId + $index}}', '$index', '=') + tfoot(ng-show='tableNewItemActive(stealingAttributesTbl)') + tr + td.col-sm-12 + +table-pair-edit('stealingAttributesTbl', 'new', 'Attribute name', 'Attribute value', false, false, '{{::stealingAttributesTbl.focusId + $index}}', '-1', '=') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/priority-queue.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/priority-queue.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/priority-queue.jade new file mode 100644 index 0000000..bdd1dac --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/collision/priority-queue.jade @@ -0,0 +1,42 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../../app/helpers/jade/mixins.jade + +-var model = 'backupItem.collision.PriorityQueue' + +div + .details-row + +number('Parallel jobs number:', model + '.parallelJobsNumber', '"priorityParallelJobsNumber"', 'true', 'availableProcessors * 2', '1', + 'Number of jobs that can be executed in parallel') + .details-row + +number('Waiting jobs number:', model + '.waitingJobsNumber', '"priorityWaitingJobsNumber"', 'true', 'Integer.MAX_VALUE', '0', + 'Maximum number of jobs that are allowed to wait in waiting queue') + .details-row + +text('Priority attribute key:', model + '.priorityAttributeKey', '"priorityPriorityAttributeKey"', 'false', 'grid.task.priority', + 'Task priority attribute key') + .details-row + +text('Job priority attribute key:', model + '.jobPriorityAttributeKey', '"priorityJobPriorityAttributeKey"', 'false', 'grid.job.priority', + 'Job priority attribute key') + .details-row + +number('Default priority:', model + '.defaultPriority', '"priorityDefaultPriority"', 'true', '0', '0', + 'Default priority to use if a job does not have priority attribute set') + .details-row + +number('Starvation increment:', model + '.starvationIncrement', '"priorityStarvationIncrement"', 'true', '1', '0', + 'Value to increment job priority by every time a lower priority job gets behind a higher priority job') + .details-row + +checkbox('Starvation prevention enabled', model + '.starvationPreventionEnabled', '"priorityStarvationPreventionEnabled"', + 'Job starvation prevention is enabled') http://git-wip-us.apache.org/repos/asf/ignite/blob/6af6560a/modules/web-console/frontend/app/modules/states/configuration/clusters/communication.jade ---------------------------------------------------------------------- diff --git a/modules/web-console/frontend/app/modules/states/configuration/clusters/communication.jade b/modules/web-console/frontend/app/modules/states/configuration/clusters/communication.jade new file mode 100644 index 0000000..0643555 --- /dev/null +++ b/modules/web-console/frontend/app/modules/states/configuration/clusters/communication.jade @@ -0,0 +1,99 @@ +//- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + +include ../../../../../app/helpers/jade/mixins.jade + +-var form = 'communication' +-var model = 'backupItem' +-var communication = model + '.communication' + +.panel.panel-default(ng-form=form novalidate) + .panel-heading(bs-collapse-toggle ng-click='ui.loadPanel("#{form}")') + ignite-form-panel-chevron + label Communication + ignite-form-field-tooltip.tipLabel + | Configuration of communication with other nodes by TCP/IP + | Provide basic plumbing to send and receive grid messages and is utilized for all distributed grid operations + ignite-form-revert + .panel-collapse(role='tabpanel' bs-collapse-target id=form) + .panel-body(ng-if='ui.isPanelLoaded("#{form}")') + .col-sm-6 + .settings-row + +number('Timeout:', model + '.networkTimeout', '"commNetworkTimeout"', 'true', '5000', '1', 'Maximum timeout in milliseconds for network requests') + .settings-row + +number('Send retry delay:', model + '.networkSendRetryDelay', '"networkSendRetryDelay"', 'true', '1000', '1', 'Interval in milliseconds between message send retries') + .settings-row + +number('Send retry count:', model + '.networkSendRetryCount', '"networkSendRetryCount"', 'true', '3', '1', 'Message send retries count') + .settings-row + +number('Discovery startup delay:', model + '.discoveryStartupDelay', '"discoveryStartupDelay"', 'true', '60000', '1', 'This value is used to expire messages from waiting list whenever node discovery discrepancies happen') + .settings-row + +java-class('Communication listener:', communication + '.listener', '"comListener"', 'true', 'false', 'Listener of communication events') + .settings-row + +text-ip-address('Local IP address:', communication + '.localAddress', '"comLocalAddress"', 'true', '0.0.0.0', + 'Local host address for socket binding<br/>\ + If not specified use all available addres on local host') + .settings-row + +number-min-max('Local port:', communication + '.localPort', '"comLocalPort"', 'true', '47100', '1024', '65535', 'Local port for socket binding') + .settings-row + +number('Local port range:', communication + '.localPortRange', '"comLocalPortRange"', 'true', '100', '1', 'Local port range for local host ports') + .settings-row + +number-min-max('Shared memory port:', communication + '.sharedMemoryPort', '"sharedMemoryPort"', 'true', '48100', '-1', '65535', + 'Local port to accept shared memory connections<br/>\ + If set to #[b -1] shared memory communication will be disabled') + .settings-row + +number('Idle connection timeout:', communication + '.idleConnectionTimeout', '"idleConnectionTimeout"', 'true', '30000', '1', + 'Maximum idle connection timeout upon which a connection to client will be closed') + .settings-row + +number('Connect timeout:', communication + '.connectTimeout', '"connectTimeout"', 'true', '5000', '0', 'Connect timeout used when establishing connection with remote nodes') + .settings-row + +number('Maximum connect timeout:', communication + '.maxConnectTimeout', '"maxConnectTimeout"', 'true', '600000', '0', 'Maximum connect timeout') + .settings-row + +number('Reconnect count:', communication + '.reconnectCount', '"comReconnectCount"', 'true', '10', '1', + 'Maximum number of reconnect attempts used when establishing connection with remote nodes') + .settings-row + +number('Socket send buffer:', communication + '.socketSendBuffer', '"socketSendBuffer"', 'true', '32768', '0', 'Send buffer size for sockets created or accepted by this SPI') + .settings-row + +number('Socket receive buffer:', communication + '.socketReceiveBuffer', '"socketReceiveBuffer"', 'true', '32768', '0', 'Receive buffer size for sockets created or accepted by this SPI') + .settings-row + +number('Slow client queue limit:', communication + '.slowClientQueueLimit', '"slowClientQueueLimit"', 'true', '0', '0', 'Slow client queue limit') + .settings-row + +number('Ack send threshold:', communication + '.ackSendThreshold', '"ackSendThreshold"', 'true', '16', '1', 'Number of received messages per connection to node after which acknowledgment message is sent') + .settings-row + +number('Message queue limit:', communication + '.messageQueueLimit', '"messageQueueLimit"', 'true', '1024', '0', 'Message queue limit for incoming and outgoing messages') + .settings-row + +number('Unacknowledged messages:', communication + '.unacknowledgedMessagesBufferSize', '"unacknowledgedMessagesBufferSize"', 'true', '0', '0', + 'Maximum number of stored unacknowledged messages per connection to node<br/>\ + If specified non zero value it should be\ + <ul>\ + <li>At least ack send threshold * 5</li>\ + <li>At least message queue limit * 5</li>\ + </ul>') + .settings-row + +number('Socket write timeout:', communication + '.socketWriteTimeout', '"socketWriteTimeout"', 'true', '2000', '0', 'Socket write timeout') + .settings-row + +number('Selectors count:', communication + '.selectorsCount', '"selectorsCount"', 'true', 'min(4, availableProcessors)', '1', 'Count of selectors te be used in TCP server') + .settings-row + +java-class('Address resolver:', communication + '.addressResolver', '"comAddressResolver"', 'true', 'false', 'Provides resolution between external and internal addresses') + .settings-row + +checkbox('Direct buffer', communication + '.directBuffer', '"directBuffer"', + 'If value is true, then SPI will use ByteBuffer.allocateDirect(int) call<br/>\ + Otherwise, SPI will use ByteBuffer.allocate(int) call.') + .settings-row + +checkbox('Direct send buffer', communication + '.directSendBuffer', '"directSendBuffer"', 'Flag defining whether direct send buffer should be used') + .settings-row + +checkbox('TCP_NODELAY option', communication + '.tcpNoDelay', '"tcpNoDelay"', 'Value for TCP_NODELAY socket option') + .col-sm-6 + +preview-xml-java(model, 'clusterCommunication')
