Drew Bailey da45c95956 Send events to EventSinks (#9171) ...

* Process to send events to configured sinks

This PR adds a SinkManager to a server which is responsible for managing
managed sinks. Managed sinks subscribe to the event broker and send
events to a sink writer (webhook). When changes to the eventstore are
made the sinkmanager and managed sink are responsible for reloading or
starting a new managed sink.

* periodically check in sink progress to raft

Save progress on the last successfully sent index to raft. This allows a
managed sink to resume close to where it left off in the event of a lost
server or leadership change

dereference eventsink so we can accurately use the watchch

When using a pointer to eventsink struct it was updated immediately and our reload logic would not trigger

2020-10-26 17:27:54 -04:00

..

agent

Send events to EventSinks (#9171)

2020-10-26 17:27:54 -04:00

assets

Update job examples with MBit deprecation

2020-09-16 11:06:19 -04:00

raft_tools

add helper commands for debugging state

2020-08-31 08:45:59 -04:00

test-resources

…

acl_bootstrap_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_bootstrap.go

…

acl_policy_apply_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_policy_apply.go

…

acl_policy_delete_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_policy_delete.go

…

acl_policy_info_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_policy_info.go

…

acl_policy_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_policy_list.go

…

acl_policy.go

use allow/deny instead of the colored alternatives (#9019)

2020-10-12 08:47:05 -04:00

acl_token_create_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_create.go

…

acl_token_delete_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_delete.go

…

acl_token_info_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_info.go

…

acl_token_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_list.go

cli: add acl token list command, documentation

2019-04-12 15:48:36 +00:00

acl_token_self_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_self.go

…

acl_token_update_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

acl_token_update.go

…

acl_token.go

…

acl.go

…

agent_info_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

agent_info.go

Add autocomplete where missing

2018-05-11 18:05:43 -04:00

agent_monitor_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

agent_monitor.go

Change tabs to spaces in nomad monitor help text

2020-09-14 15:08:30 -04:00

alloc_exec_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_exec_unix.go

add CLI commands for nomad exec

2019-05-12 22:04:50 -04:00

alloc_exec_windows.go

add CLI commands for nomad exec

2019-05-12 22:04:50 -04:00

alloc_exec.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc_fs_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_fs.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc_logs_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_logs.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc_restart_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_restart.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc_signal_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_signal.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc_status_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

alloc_status.go

command: correctly show host IP in ports output /w multi-host networks (#8289)

2020-06-25 15:16:01 -04:00

alloc_stop_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

alloc_stop.go

cli: query all namespaces for alloc subcommands

2020-06-17 16:31:06 -04:00

alloc.go

…

check_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

check.go

…

commands_oss.go

accomodate enterprise specific commands

2020-06-22 10:27:25 -04:00

commands.go

Merge pull request #9023 from hashicorp/f-gh-8648

2020-10-06 18:03:41 +02:00

data_format_test.go

…

data_format.go

vendor: explicit use of hashicorp/go-msgpack

2020-03-31 09:45:21 -04:00

deployment_fail_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_fail.go

Fix output of 'nomad deployment fail' with no arg

2018-12-13 13:22:17 -05:00

deployment_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_list.go

…

deployment_pause_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_pause.go

…

deployment_promote_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_promote.go

…

deployment_resume_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_resume.go

…

deployment_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_status.go

Multiregion deploy status and job status CLI

2020-06-17 11:03:34 -04:00

deployment_unblock_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

deployment_unblock.go

multiregion CLI: nomad deployment unblock

2020-06-17 11:03:44 -04:00

deployment.go

Fixed typo in deployment help text

2018-05-24 12:44:21 -04:00

eval_status_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

eval_status.go

add create and modify timestamps to evaluations (#5881)

2019-08-07 09:50:35 -07:00

eval.go

…

helper_devices_test.go

fixup! device attributes in nomad node status -verbose

2018-12-12 09:17:31 -05:00

helper_devices.go

device attributes in nomad node status -verbose

2018-12-10 12:18:24 -05:00

helpers_test.go

address review feedback

2020-10-22 11:49:37 -04:00

helpers.go

address review feedback

2020-10-22 11:49:37 -04:00

integration_test.go

tests: stop integration tests tasks explicitly

2018-12-04 11:50:59 -05:00

job_deployments_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_deployments.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_dispatch_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_dispatch.go

…

job_eval_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_eval.go

remove extra return

2018-05-21 18:00:14 -05:00

job_history_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_history.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_init_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

job_init.bindata_assetfs.go

Update job examples with MBit deprecation

2020-09-16 11:06:19 -04:00

job_init.go

cli: Allow user to specify dest filename for nomad init (#6520)

2019-12-19 14:59:12 -05:00

job_inspect_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_inspect.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_periodic_force_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_periodic_force.go

cli: jobs allow querying jobs in all namespaces

2020-06-17 16:31:01 -04:00

job_periodic.go

gofmt/goimport and test formatting

2019-04-12 20:55:55 +00:00

job_plan_test.go

hclv1: tweak HCLv1 tests

2020-10-21 14:05:46 -04:00

job_plan.go

cli: use HCLv2 parser

2020-10-21 15:46:57 -04:00

job_promote_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_promote.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_revert_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_revert.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_run_test.go

hclv1: tweak HCLv1 tests

2020-10-21 14:05:46 -04:00

job_run.go

address review feedback

2020-10-22 11:49:37 -04:00

job_scale_test.go

cli: add scale and scaling-events commands to job cmd.

2020-10-06 09:58:46 +02:00

job_scale.go

cli: add scale and scaling-events commands to job cmd.

2020-10-06 09:58:46 +02:00

job_scaling_events_test.go

cli: add scale and scaling-events commands to job cmd.

2020-10-06 09:58:46 +02:00

job_scaling_events.go

cli: add scale and scaling-events commands to job cmd.

2020-10-06 09:58:46 +02:00

job_status_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_status.go

cli: warn on multiple prefix matches when querying all namespaces

2020-06-17 16:32:51 -04:00

job_stop_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

job_stop.go

MRD: move 'job stop -global' handling into RPC (#8776)

2020-08-28 14:28:13 -04:00

job_validate_test.go

hclv1: tweak HCLv1 tests

2020-10-21 14:05:46 -04:00

job_validate.go

cli: use HCLv2 parser

2020-10-21 15:46:57 -04:00

job.go

…

license_get_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

license_get.go

cli: fix license get command help Synopsis text.

2020-06-23 18:47:39 +02:00

license_put_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

license_put.go

update license command output to reflect api changes

2020-05-05 10:28:58 -04:00

license.go

remove duplicate license info (#8496)

2020-07-22 10:21:56 -04:00

meta_test.go

command: add -tls-server-name flag

2019-09-24 09:20:41 -07:00

meta.go

command: fix a typo in the help text for namespaces (#8975)

2020-09-28 12:23:25 -04:00

metrics_test.go

Metrics gotemplate support, debug bundle features (#9067)

2020-10-14 15:16:10 -04:00

metrics.go

Metrics gotemplate support, debug bundle features (#9067)

2020-10-14 15:16:10 -04:00

monitor_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

monitor.go

update log output to clarify that nodes were filtered out rather than down

2020-03-17 14:45:11 -04:00

namespace_apply_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

namespace_apply.go

…

namespace_delete_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

namespace_delete.go

…

namespace_inspect_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

namespace_inspect.go

…

namespace_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

namespace_list.go

…

namespace_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

namespace_status.go

…

namespace.go

fix 'nomad namespace apply' help

2019-09-09 10:04:41 -07:00

node_config_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

node_config.go

typo: "atleast" -> "at least"

2019-05-13 10:01:19 -04:00

node_drain_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

node_drain.go

Fix typo, Ethier -> Either

2020-01-02 14:42:27 -08:00

node_eligibility_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

node_eligibility.go

Fix cmd.Name() for NodeEligibilityCommand

2020-08-29 22:45:42 +08:00

node_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

node_status.go

filter volumes by type in 'nomad node status' output (#8902)

2020-09-16 15:00:12 -04:00

node.go

Fix typo in nomad node help text

2018-06-14 15:48:01 +02:00

operator_autopilot_get_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_autopilot_get.go

implement MinQuorum

2020-02-16 16:04:59 -06:00

operator_autopilot_set_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_autopilot_set.go

implement MinQuorum

2020-02-16 16:04:59 -06:00

operator_autopilot_test.go

…

operator_autopilot.go

…

operator_debug_test.go

Metrics gotemplate support, debug bundle features (#9067)

2020-10-14 15:16:10 -04:00

operator_debug.go

Metrics gotemplate support, debug bundle features (#9067)

2020-10-14 15:16:10 -04:00

operator_keygen_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_keygen.go

Generate 32-byte gossip key for nomad operator keygen command

2020-09-30 17:02:37 -04:00

operator_keyring.go

…

operator_raft_info.go

refactor functions to find raft.db

2020-09-24 19:00:53 -04:00

operator_raft_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_raft_list.go

…

operator_raft_logs.go

refactor functions to find raft.db

2020-09-24 19:00:53 -04:00

operator_raft_remove_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_raft_remove.go

…

operator_raft_state.go

refactor functions to find raft.db

2020-09-24 19:00:53 -04:00

operator_raft_test.go

…

operator_raft.go

…

operator_snapshot_inspect_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_snapshot_inspect.go

cli: use <file> for consistency

2020-06-19 12:19:38 -04:00

operator_snapshot_restore_test.go

hclv1: tweak HCLv1 tests

2020-10-21 14:05:46 -04:00

operator_snapshot_restore.go

cli: use <file> for consistency

2020-06-19 12:19:38 -04:00

operator_snapshot_save_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

operator_snapshot_save.go

Apply suggestions from code review

2020-06-19 13:36:22 -04:00

operator_snapshot.go

Implement snapshot save CLI

2020-05-21 20:04:38 -04:00

operator_test.go

…

operator.go

…

plugin_status_csi.go

command/plugin_status_csi: plugin status :id keeps expected count

2020-08-31 13:56:54 -04:00

plugin_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

plugin_status.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

plugin.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

quota_apply_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_apply.go

command: remove mbits from quota hcl (#8740)

2020-09-24 11:44:59 -04:00

quota_delete_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_delete.go

…

quota_init_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_init.go

command: remove mbits from quota hcl (#8740)

2020-09-24 11:44:59 -04:00

quota_inspect_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_inspect.go

…

quota_list_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_list.go

…

quota_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

quota_status.go

command: quota status reports network usage

2019-11-20 17:59:34 -06:00

quota.go

…

scaling_policy_info_test.go

cli: add policy list and info to new scaling cmd.

2020-10-05 15:18:30 +02:00

scaling_policy_info.go

cli: add policy list and info to new scaling cmd.

2020-10-05 15:18:30 +02:00

scaling_policy_list_test.go

cli: add policy list and info to new scaling cmd.

2020-10-05 15:18:30 +02:00

scaling_policy_list.go

cli: add policy list and info to new scaling cmd.

2020-10-05 15:18:30 +02:00

scaling_policy_test.go

cli: ensure scaling policy target doesn't have trailing comma

2020-10-06 12:18:17 +02:00

scaling_policy.go

cli: ensure scaling policy target doesn't have trailing comma

2020-10-06 12:18:17 +02:00

scaling.go

cli: add policy list and info to new scaling cmd.

2020-10-05 15:18:30 +02:00

sentinel_apply_test.go

…

sentinel_apply.go

…

sentinel_delete_test.go

…

sentinel_delete.go

…

sentinel_list_test.go

…

sentinel_list.go

…

sentinel_read_test.go

…

sentinel_read.go

…

sentinel.go

…

server_force_leave_test.go

…

server_force_leave.go

Add autocomplete where missing

2018-05-11 18:05:43 -04:00

server_join_test.go

…

server_join.go

Add autocomplete where missing

2018-05-11 18:05:43 -04:00

server_members_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

server_members.go

…

server.go

…

status_test.go

Events/msgtype cleanup (#9117)

2020-10-19 09:30:15 -04:00

status.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

system_gc_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

system_gc.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

system_reconcile_summaries_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

system_reconcile_summaries.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

system_reconcile_test.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

system_reconcile.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

system_test.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

system.go

cli: add system command and subcmds to interact with system API.

2020-01-13 11:34:46 +01:00

ui.go

change url to client

2020-07-23 18:41:38 +03:00

util_test.go

always shutdown test server on test cleanup

2020-06-25 12:44:19 -04:00

version_test.go

…

version.go

…

volume_deregister.go

csi: add -force flag to volume deregister (#8295)

2020-07-01 12:17:51 -04:00

volume_detach.go

csi: allow for volume detach to work with gc'd nodes (#9057)

2020-10-09 09:45:03 -04:00

volume_register_csi.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

volume_register_test.go

csi: support Secrets parameter in CSI RPCs (#7923)

2020-05-11 17:12:51 -04:00

volume_register.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

volume_status_csi.go

csi: add mount_options to volumes and volume requests (#7398)

2020-03-23 13:59:25 -04:00

volume_status_test.go

cli: move tests to use NewMockUi func.

2020-10-05 16:07:41 +02:00

volume_status.go

csi: CLI for volume status, registration/deregistration and plugin status (#7193)

2020-03-23 13:58:30 -04:00

volume.go

csi: nomad volume detach command (#8584)

2020-08-11 10:18:54 -04:00