consul/ui/packages/consul-ui/app/adapters/node.js

86 lines
2.0 KiB
JavaScript

import Adapter from './application';
import { inject as service } from '@ember/service';
// TODO: Update to use this.formatDatacenter()
// Node and Namespaces are a little strange in that Nodes don't belong in a
// namespace whereas things that belong to a Node do (Health Checks and
// Service Instances). So even though Nodes themselves don't require a
// namespace filter, you sill needs to pass the namespace through to API
// requests in order to get the correct information for the things that belong
// to the node.
export default class NodeAdapter extends Adapter {
@service abilities;
get peeringQuery() {
const query = {};
if (this.abilities.can('use peers')) {
query['with-peers'] = true;
}
return query;
}
requestForQuery(request, { dc, ns, partition, index, id, uri }) {
return request`
GET /v1/internal/ui/nodes?${{ dc }}
X-Request-ID: ${uri}
${{
...this.peeringQuery,
ns,
partition,
index,
}}
`;
}
requestForQueryRecord(request, { dc, ns, partition, index, id, uri, peer }) {
if (typeof id === 'undefined') {
throw new Error('You must specify an id');
}
let options = {
ns,
partition,
index,
};
if (peer) {
options = {
...options,
peer,
};
}
return request`
GET /v1/internal/ui/node/${id}?${{ dc }}
X-Request-ID: ${uri}
${options}
`;
}
// this does not require a partition parameter
requestForQueryLeader(request, { dc, uri }) {
return request`
GET /v1/status/leader?${{ dc }}
X-Request-ID: ${uri}
Refresh: 30
`;
}
queryLeader(store, type, id, snapshot) {
return this.rpc(
function(adapter, request, serialized, unserialized) {
return adapter.requestForQueryLeader(request, serialized, unserialized);
},
function(serializer, respond, serialized, unserialized) {
return serializer.respondForQueryLeader(respond, serialized, unserialized);
},
snapshot,
type.modelName
);
}
}