Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Showing
with
3,960 additions
and 0 deletions.
- +202 −0 LICENSE
- +17 −0 Makefile
- +5 −0 NOTICE
- +19 −0 README.md
- +19 −0 cmd/pulsectl/README.md
- +19 −0 cmd/pulsectl/commands.go
- +19 −0 cmd/pulsectl/flags.go
- +19 −0 cmd/pulsectl/main.go
- +19 −0 cmd/pulsectl/metric.go
- +19 −0 cmd/pulsectl/plugin.go
- +19 −0 cmd/pulsectl/task.go
- +19 −0 control/available_plugin.go
- +19 −0 control/available_plugin_test.go
- +19 −0 control/control.go
- +19 −0 control/control_test.go
- +19 −0 control/metrics.go
- +19 −0 control/metrics_test.go
- +19 −0 control/monitor.go
- +19 −0 control/monitor_test.go
- +19 −0 control/mttrie.go
- +19 −0 control/mttrie_test.go
- +19 −0 control/plugin/client/cache.go
- +19 −0 control/plugin/client/cache_test.go
- +19 −0 control/plugin/client/client.go
- +19 −0 control/plugin/client/httpjsonrpc.go
- +19 −0 control/plugin/client/httpjsonrpc_test.go
- +19 −0 control/plugin/client/native.go
- +19 −0 control/plugin/collector.go
- +19 −0 control/plugin/collector_proxy.go
- +19 −0 control/plugin/collector_proxy_test.go
- +19 −0 control/plugin/collector_test.go
- +19 −0 control/plugin/cpolicy/float.go
- +19 −0 control/plugin/cpolicy/float_test.go
- +19 −0 control/plugin/cpolicy/integer.go
- +19 −0 control/plugin/cpolicy/integer_test.go
- +19 −0 control/plugin/cpolicy/node.go
- +19 −0 control/plugin/cpolicy/node_test.go
- +19 −0 control/plugin/cpolicy/rule.go
- +19 −0 control/plugin/cpolicy/string.go
- +19 −0 control/plugin/cpolicy/string_test.go
- +19 −0 control/plugin/cpolicy/tree.go
- +19 −0 control/plugin/cpolicy/tree_test.go
- +19 −0 control/plugin/encoding/encoding.go
- +19 −0 control/plugin/encoding/gob.go
- +19 −0 control/plugin/encoding/json.go
- +19 −0 control/plugin/encrypter/encrypter.go
- +19 −0 control/plugin/encrypter/encrypter_test.go
- +19 −0 control/plugin/execution.go
- +19 −0 control/plugin/execution_test.go
- +19 −0 control/plugin/metric.go
- +19 −0 control/plugin/metric_test.go
- +19 −0 control/plugin/plugin.go
- +19 −0 control/plugin/plugin_test.go
- +19 −0 control/plugin/processor.go
- +19 −0 control/plugin/processor_proxy.go
- +19 −0 control/plugin/processor_test.go
- +19 −0 control/plugin/publisher.go
- +19 −0 control/plugin/publisher_proxy.go
- +19 −0 control/plugin/publisher_test.go
- +19 −0 control/plugin/session.go
- +19 −0 control/plugin/session_test.go
- +19 −0 control/plugin_manager.go
- +19 −0 control/plugin_manager_test.go
- +19 −0 control/router.go
- +19 −0 control/routing/round_robin.go
- +19 −0 control/routing/routing.go
- +19 −0 control/runner.go
- +19 −0 control/runner_test.go
- +19 −0 core/cdata/node.go
- +19 −0 core/cdata/node_test.go
- +19 −0 core/cdata/tree.go
- +19 −0 core/cdata/tree_test.go
- +19 −0 core/control_event/control_event.go
- +19 −0 core/ctypes/ctypes.go
- +19 −0 core/metric.go
- +19 −0 core/perror/perror.go
- +19 −0 core/plugin.go
- +19 −0 core/scheduler_event/scheduler_event.go
- +19 −0 core/task.go
- +19 −0 core/workflow.go
- +19 −0 docs/PULSED.md
- +19 −0 examples/README.md
- +19 −0 examples/influxdb-grafana/README.md
- +17 −0 examples/influxdb-grafana/influxdb/0.9/run.sh
- +17 −0 examples/influxdb-grafana/run-pcm.sh
- +17 −0 examples/influxdb-grafana/run-psutil.sh
- +17 −0 examples/influxdb-grafana/run.sh
- +17 −0 examples/linux_prep.sh
- +17 −0 examples/riemann/Vagrantfile
- +17 −0 examples/riemann/script/init.sh
- +19 −0 examples/tasks/README.md
- +17 −0 examples/videos.md
- +19 −0 mgmt/rest/client/README.md
- +19 −0 mgmt/rest/client/client.go
- +19 −0 mgmt/rest/client/client_func_test.go
- +19 −0 mgmt/rest/client/metric.go
- +19 −0 mgmt/rest/client/plugin.go
- +19 −0 mgmt/rest/client/task.go
- +19 −0 mgmt/rest/log_handler.go
- +19 −0 mgmt/rest/metric.go
- +19 −0 mgmt/rest/plugin.go
- +19 −0 mgmt/rest/rbody/body.go
- +19 −0 mgmt/rest/rbody/error.go
- +19 −0 mgmt/rest/rbody/metric.go
- +19 −0 mgmt/rest/rbody/plugin.go
- +19 −0 mgmt/rest/rbody/task.go
- +19 −0 mgmt/rest/rbody/tribe.go
- +19 −0 mgmt/rest/readme.md
- +19 −0 mgmt/rest/request/task.go
- +19 −0 mgmt/rest/rest_func_test.go
- +19 −0 mgmt/rest/server.go
- +19 −0 mgmt/rest/task.go
- +19 −0 mgmt/rest/tls.go
- +19 −0 mgmt/rest/tribe.go
- +19 −0 mgmt/rest/tribe_test.go
- +19 −0 mgmt/tribe/agreement/agreement.go
- +19 −0 mgmt/tribe/broadcast.go
- +19 −0 mgmt/tribe/clock.go
- +19 −0 mgmt/tribe/delegate.go
- +19 −0 mgmt/tribe/flags.go
- +19 −0 mgmt/tribe/member_delegate.go
- +19 −0 mgmt/tribe/messages.go
- +19 −0 mgmt/tribe/tribe.go
- +19 −0 mgmt/tribe/tribe_test.go
- +19 −0 mgmt/tribe/worker/worker.go
- +19 −0 mgmt/tribe/worker/worker_test.go
- +19 −0 pkg/ctree/tree.go
- +19 −0 pkg/ctree/tree_test.go
- +19 −0 pkg/psigning/psigning.go
- +19 −0 pkg/psigning/psigning_test.go
- +19 −0 plugin/collector/pulse-collector-dummy1/README.md
- +19 −0 plugin/collector/pulse-collector-dummy1/dummy/dummy.go
- +19 −0 plugin/collector/pulse-collector-dummy1/main.go
- +19 −0 plugin/collector/pulse-collector-dummy1/main_test.go
- +19 −0 plugin/collector/pulse-collector-dummy2/README.md
- +19 −0 plugin/collector/pulse-collector-dummy2/dummy/dummy.go
- +19 −0 plugin/collector/pulse-collector-dummy2/main.go
- +19 −0 plugin/collector/pulse-collector-dummy2/main_test.go
- +19 −0 plugin/collector/pulse-collector-facter/README.md
- +19 −0 plugin/collector/pulse-collector-facter/facter/cmd.go
- +19 −0 plugin/collector/pulse-collector-facter/facter/cmd_test.go
- +19 −0 plugin/collector/pulse-collector-facter/facter/facter.go
- +19 −0 plugin/collector/pulse-collector-facter/facter/facter_test.go
- +19 −0 plugin/collector/pulse-collector-facter/main.go
- +19 −0 plugin/collector/pulse-collector-facter/main_test.go
- +19 −0 plugin/collector/pulse-collector-pcm/README.md
- +19 −0 plugin/collector/pulse-collector-pcm/main.go
- +19 −0 plugin/collector/pulse-collector-pcm/pcm/pcm.go
- +19 −0 plugin/collector/pulse-collector-perfevents/README.md
- +19 −0 plugin/collector/pulse-collector-perfevents/main.go
- +19 −0 plugin/collector/pulse-collector-perfevents/perfevents/perfevents.go
- +19 −0 plugin/collector/pulse-collector-perfevents/perfevents/perfevents_test.go
- +19 −0 plugin/collector/pulse-collector-psutil/main.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/cpu.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/load.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/mem.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/net.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/psutil.go
- +19 −0 plugin/collector/pulse-collector-psutil/psutil/psutil_integration_test.go
- +19 −0 plugin/collector/pulse-collector-smart/main.go
- +19 −0 plugin/collector/pulse-collector-smart/main_test.go
- +19 −0 plugin/collector/pulse-collector-smart/smart/plugin.go
- +19 −0 plugin/collector/pulse-collector-smart/smart/plugin_test.go
- +19 −0 plugin/collector/pulse-collector-smart/smart/smart.go
- +19 −0 plugin/collector/pulse-collector-smart/smart/smart_test.go
- +19 −0 plugin/helper/helper.go
- +19 −0 plugin/processor/pulse-processor-passthru/main.go
- +19 −0 plugin/processor/pulse-processor-passthru/passthru/passthru.go
- +18 −0 plugin/publisher/pulse-publisher-file/README.md
- +19 −0 plugin/publisher/pulse-publisher-file/file/file.go
- +19 −0 plugin/publisher/pulse-publisher-file/file/file_test.go
- +19 −0 plugin/publisher/pulse-publisher-file/main.go
- +19 −0 plugin/publisher/pulse-publisher-file/main_test.go
- +19 −0 pulse.go
- +19 −0 scheduler/job.go
- +19 −0 scheduler/job_test.go
- +19 −0 scheduler/queue.go
- +19 −0 scheduler/queue_test.go
- +19 −0 scheduler/scheduler.go
- +19 −0 scheduler/scheduler_test.go
- +19 −0 scheduler/task.go
- +19 −0 scheduler/task_test.go
- +19 −0 scheduler/watcher.go
- +19 −0 scheduler/watcher_test.go
- +19 −0 scheduler/wmap/string.go
- +19 −0 scheduler/wmap/wmap.go
- +19 −0 scheduler/wmap/wmap_test.go
- +19 −0 scheduler/work_manager.go
- +19 −0 scheduler/work_manager_test.go
- +19 −0 scheduler/worker.go
- +19 −0 scheduler/worker_test.go
- +19 −0 scheduler/workflow.go
- +19 −0 scheduler/workflow_string.go
- +19 −0 scheduler/workflow_string_test.go
- +19 −0 scheduler/workflow_test.go
- +17 −0 scripts/build-plugin.sh
- +17 −0 scripts/build.sh
- +18 −0 scripts/deps.sh
- +18 −0 scripts/release.sh
- +17 −0 scripts/run_tests_with_docker.sh
- +18 −0 scripts/test.sh
@@ -0,0 +1,202 @@ | ||
|
||
Apache License | ||
Version 2.0, January 2004 | ||
http://www.apache.org/licenses/ | ||
|
||
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION | ||
|
||
1. Definitions. | ||
|
||
"License" shall mean the terms and conditions for use, reproduction, | ||
and distribution as defined by Sections 1 through 9 of this document. | ||
|
||
"Licensor" shall mean the copyright owner or entity authorized by | ||
the copyright owner that is granting the License. | ||
|
||
"Legal Entity" shall mean the union of the acting entity and all | ||
other entities that control, are controlled by, or are under common | ||
control with that entity. For the purposes of this definition, | ||
"control" means (i) the power, direct or indirect, to cause the | ||
direction or management of such entity, whether by contract or | ||
otherwise, or (ii) ownership of fifty percent (50%) or more of the | ||
outstanding shares, or (iii) beneficial ownership of such entity. | ||
|
||
"You" (or "Your") shall mean an individual or Legal Entity | ||
exercising permissions granted by this License. | ||
|
||
"Source" form shall mean the preferred form for making modifications, | ||
including but not limited to software source code, documentation | ||
source, and configuration files. | ||
|
||
"Object" form shall mean any form resulting from mechanical | ||
transformation or translation of a Source form, including but | ||
not limited to compiled object code, generated documentation, | ||
and conversions to other media types. | ||
|
||
"Work" shall mean the work of authorship, whether in Source or | ||
Object form, made available under the License, as indicated by a | ||
copyright notice that is included in or attached to the work | ||
(an example is provided in the Appendix below). | ||
|
||
"Derivative Works" shall mean any work, whether in Source or Object | ||
form, that is based on (or derived from) the Work and for which the | ||
editorial revisions, annotations, elaborations, or other modifications | ||
represent, as a whole, an original work of authorship. For the purposes | ||
of this License, Derivative Works shall not include works that remain | ||
separable from, or merely link (or bind by name) to the interfaces of, | ||
the Work and Derivative Works thereof. | ||
|
||
"Contribution" shall mean any work of authorship, including | ||
the original version of the Work and any modifications or additions | ||
to that Work or Derivative Works thereof, that is intentionally | ||
submitted to Licensor for inclusion in the Work by the copyright owner | ||
or by an individual or Legal Entity authorized to submit on behalf of | ||
the copyright owner. For the purposes of this definition, "submitted" | ||
means any form of electronic, verbal, or written communication sent | ||
to the Licensor or its representatives, including but not limited to | ||
communication on electronic mailing lists, source code control systems, | ||
and issue tracking systems that are managed by, or on behalf of, the | ||
Licensor for the purpose of discussing and improving the Work, but | ||
excluding communication that is conspicuously marked or otherwise | ||
designated in writing by the copyright owner as "Not a Contribution." | ||
|
||
"Contributor" shall mean Licensor and any individual or Legal Entity | ||
on behalf of whom a Contribution has been received by Licensor and | ||
subsequently incorporated within the Work. | ||
|
||
2. Grant of Copyright License. Subject to the terms and conditions of | ||
this License, each Contributor hereby grants to You a perpetual, | ||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable | ||
copyright license to reproduce, prepare Derivative Works of, | ||
publicly display, publicly perform, sublicense, and distribute the | ||
Work and such Derivative Works in Source or Object form. | ||
|
||
3. Grant of Patent License. Subject to the terms and conditions of | ||
this License, each Contributor hereby grants to You a perpetual, | ||
worldwide, non-exclusive, no-charge, royalty-free, irrevocable | ||
(except as stated in this section) patent license to make, have made, | ||
use, offer to sell, sell, import, and otherwise transfer the Work, | ||
where such license applies only to those patent claims licensable | ||
by such Contributor that are necessarily infringed by their | ||
Contribution(s) alone or by combination of their Contribution(s) | ||
with the Work to which such Contribution(s) was submitted. If You | ||
institute patent litigation against any entity (including a | ||
cross-claim or counterclaim in a lawsuit) alleging that the Work | ||
or a Contribution incorporated within the Work constitutes direct | ||
or contributory patent infringement, then any patent licenses | ||
granted to You under this License for that Work shall terminate | ||
as of the date such litigation is filed. | ||
|
||
4. Redistribution. You may reproduce and distribute copies of the | ||
Work or Derivative Works thereof in any medium, with or without | ||
modifications, and in Source or Object form, provided that You | ||
meet the following conditions: | ||
|
||
(a) You must give any other recipients of the Work or | ||
Derivative Works a copy of this License; and | ||
|
||
(b) You must cause any modified files to carry prominent notices | ||
stating that You changed the files; and | ||
|
||
(c) You must retain, in the Source form of any Derivative Works | ||
that You distribute, all copyright, patent, trademark, and | ||
attribution notices from the Source form of the Work, | ||
excluding those notices that do not pertain to any part of | ||
the Derivative Works; and | ||
|
||
(d) If the Work includes a "NOTICE" text file as part of its | ||
distribution, then any Derivative Works that You distribute must | ||
include a readable copy of the attribution notices contained | ||
within such NOTICE file, excluding those notices that do not | ||
pertain to any part of the Derivative Works, in at least one | ||
of the following places: within a NOTICE text file distributed | ||
as part of the Derivative Works; within the Source form or | ||
documentation, if provided along with the Derivative Works; or, | ||
within a display generated by the Derivative Works, if and | ||
wherever such third-party notices normally appear. The contents | ||
of the NOTICE file are for informational purposes only and | ||
do not modify the License. You may add Your own attribution | ||
notices within Derivative Works that You distribute, alongside | ||
or as an addendum to the NOTICE text from the Work, provided | ||
that such additional attribution notices cannot be construed | ||
as modifying the License. | ||
|
||
You may add Your own copyright statement to Your modifications and | ||
may provide additional or different license terms and conditions | ||
for use, reproduction, or distribution of Your modifications, or | ||
for any such Derivative Works as a whole, provided Your use, | ||
reproduction, and distribution of the Work otherwise complies with | ||
the conditions stated in this License. | ||
|
||
5. Submission of Contributions. Unless You explicitly state otherwise, | ||
any Contribution intentionally submitted for inclusion in the Work | ||
by You to the Licensor shall be under the terms and conditions of | ||
this License, without any additional terms or conditions. | ||
Notwithstanding the above, nothing herein shall supersede or modify | ||
the terms of any separate license agreement you may have executed | ||
with Licensor regarding such Contributions. | ||
|
||
6. Trademarks. This License does not grant permission to use the trade | ||
names, trademarks, service marks, or product names of the Licensor, | ||
except as required for reasonable and customary use in describing the | ||
origin of the Work and reproducing the content of the NOTICE file. | ||
|
||
7. Disclaimer of Warranty. Unless required by applicable law or | ||
agreed to in writing, Licensor provides the Work (and each | ||
Contributor provides its Contributions) on an "AS IS" BASIS, | ||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or | ||
implied, including, without limitation, any warranties or conditions | ||
of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A | ||
PARTICULAR PURPOSE. You are solely responsible for determining the | ||
appropriateness of using or redistributing the Work and assume any | ||
risks associated with Your exercise of permissions under this License. | ||
|
||
8. Limitation of Liability. In no event and under no legal theory, | ||
whether in tort (including negligence), contract, or otherwise, | ||
unless required by applicable law (such as deliberate and grossly | ||
negligent acts) or agreed to in writing, shall any Contributor be | ||
liable to You for damages, including any direct, indirect, special, | ||
incidental, or consequential damages of any character arising as a | ||
result of this License or out of the use or inability to use the | ||
Work (including but not limited to damages for loss of goodwill, | ||
work stoppage, computer failure or malfunction, or any and all | ||
other commercial damages or losses), even if such Contributor | ||
has been advised of the possibility of such damages. | ||
|
||
9. Accepting Warranty or Additional Liability. While redistributing | ||
the Work or Derivative Works thereof, You may choose to offer, | ||
and charge a fee for, acceptance of support, warranty, indemnity, | ||
or other liability obligations and/or rights consistent with this | ||
License. However, in accepting such obligations, You may act only | ||
on Your own behalf and on Your sole responsibility, not on behalf | ||
of any other Contributor, and only if You agree to indemnify, | ||
defend, and hold each Contributor harmless for any liability | ||
incurred by, or claims asserted against, such Contributor by reason | ||
of your accepting any such warranty or additional liability. | ||
|
||
END OF TERMS AND CONDITIONS | ||
|
||
APPENDIX: How to apply the Apache License to your work. | ||
|
||
To apply the Apache License to your work, attach the following | ||
boilerplate notice, with the fields enclosed by brackets "[]" | ||
replaced with your own identifying information. (Don't include | ||
the brackets!) The text should be enclosed in the appropriate | ||
comment syntax for the file format. We also recommend that a | ||
file or class name and description of purpose be included on the | ||
same "printed page" as the copyright notice for easier | ||
identification within third-party archives. | ||
|
||
Copyright [yyyy] [name of copyright owner] | ||
|
||
Licensed 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. |
@@ -0,0 +1,5 @@ | ||
Apache pulse | ||
Copyright 2015 The Apache Software Foundation | ||
|
||
This product includes software developed at | ||
The Apache Software Foundation (http://www.apache.org/). |
Oops, something went wrong.