diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-10-07 03:42:44 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2021-10-07 03:42:44 +0300 |
| commit | 798be7dcaf7f39c748abefc0c223463622f01b2e (patch) | |
| tree | babed200102f0c8f3910391de5de72b9fe474548 /deps/rabbitmq_peer_discovery_aws | |
| parent | d16037b419cf5a2e3cbb53594500f27a0b47ff8b (diff) | |
| download | rabbitmq-server-git-798be7dcaf7f39c748abefc0c223463622f01b2e.tar.gz | |
Peer discovery AWS, K8S: more Dialyzer fixes
Diffstat (limited to 'deps/rabbitmq_peer_discovery_aws')
| -rw-r--r-- | deps/rabbitmq_peer_discovery_aws/src/rabbit_peer_discovery_aws.erl | 5 | ||||
| -rw-r--r-- | deps/rabbitmq_peer_discovery_aws/src/rabbitmq_peer_discovery_aws.erl | 2 |
2 files changed, 3 insertions, 4 deletions
diff --git a/deps/rabbitmq_peer_discovery_aws/src/rabbit_peer_discovery_aws.erl b/deps/rabbitmq_peer_discovery_aws/src/rabbit_peer_discovery_aws.erl index 3df6890b54..a668f5843d 100644 --- a/deps/rabbitmq_peer_discovery_aws/src/rabbit_peer_discovery_aws.erl +++ b/deps/rabbitmq_peer_discovery_aws/src/rabbit_peer_discovery_aws.erl @@ -143,9 +143,7 @@ lock(Node) -> Error end. --spec unlock({{ResourceId :: string(), LockRequesterId :: node()}, Nodes :: [node()]}) -> - ok | {error, Reason :: string()}. - +-spec unlock({{ResourceId :: string(), LockRequestedId :: atom()}, Nodes :: [atom()]}) -> 'ok'. unlock({LockId, Nodes}) -> global:del_lock(LockId, Nodes), ok. @@ -153,6 +151,7 @@ unlock({LockId, Nodes}) -> %% %% Implementation %% + -spec get_config_key(Key :: atom(), Map :: #{atom() => peer_discovery_config_value()}) -> peer_discovery_config_value(). diff --git a/deps/rabbitmq_peer_discovery_aws/src/rabbitmq_peer_discovery_aws.erl b/deps/rabbitmq_peer_discovery_aws/src/rabbitmq_peer_discovery_aws.erl index 05bae26c20..840d7e7687 100644 --- a/deps/rabbitmq_peer_discovery_aws/src/rabbitmq_peer_discovery_aws.erl +++ b/deps/rabbitmq_peer_discovery_aws/src/rabbitmq_peer_discovery_aws.erl @@ -49,6 +49,6 @@ post_registration() -> lock(Node) -> ?DELEGATE:lock(Node). --spec unlock({ResourceId :: string(), LockRequesterId :: node()}) -> ok | {error, Reason :: string()}. +-spec unlock({{ResourceId :: string(), LockRequestedId :: atom()}, Nodes :: [atom()]}) -> 'ok'. unlock(Data) -> ?DELEGATE:unlock(Data). |