diff options
Diffstat (limited to 'include/rabbit_backing_queue_spec.hrl')
-rw-r--r-- | include/rabbit_backing_queue_spec.hrl | 71 |
1 files changed, 0 insertions, 71 deletions
diff --git a/include/rabbit_backing_queue_spec.hrl b/include/rabbit_backing_queue_spec.hrl deleted file mode 100644 index 79d44e1b..00000000 --- a/include/rabbit_backing_queue_spec.hrl +++ /dev/null @@ -1,71 +0,0 @@ -%% The contents of this file are subject to the Mozilla Public License -%% Version 1.1 (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.mozilla.org/MPL/ -%% -%% Software distributed under the License is distributed on an "AS IS" -%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See -%% the License for the specific language governing rights and -%% limitations under the License. -%% -%% The Original Code is RabbitMQ. -%% -%% The Initial Developer of the Original Code is VMware, Inc. -%% Copyright (c) 2007-2012 VMware, Inc. All rights reserved. -%% - --type(fetch_result(Ack) :: - ('empty' | - %% Message, IsDelivered, AckTag, Remaining_Len - {rabbit_types:basic_message(), boolean(), Ack, non_neg_integer()})). --type(is_durable() :: boolean()). --type(attempt_recovery() :: boolean()). --type(purged_msg_count() :: non_neg_integer()). --type(confirm_required() :: boolean()). --type(async_callback() :: fun ((atom(), fun ((atom(), state()) -> state())) -> 'ok')). --type(duration() :: ('undefined' | 'infinity' | number())). - --type(msg_fun() :: fun((rabbit_types:basic_message(), ack()) -> 'ok') | - 'undefined'). - --spec(start/1 :: ([rabbit_amqqueue:name()]) -> 'ok'). --spec(stop/0 :: () -> 'ok'). --spec(init/3 :: (rabbit_types:amqqueue(), attempt_recovery(), - async_callback()) -> state()). --spec(terminate/2 :: (any(), state()) -> state()). --spec(delete_and_terminate/2 :: (any(), state()) -> state()). --spec(purge/1 :: (state()) -> {purged_msg_count(), state()}). --spec(publish/4 :: (rabbit_types:basic_message(), - rabbit_types:message_properties(), pid(), state()) -> - state()). --spec(publish_delivered/5 :: (true, rabbit_types:basic_message(), - rabbit_types:message_properties(), pid(), state()) - -> {ack(), state()}; - (false, rabbit_types:basic_message(), - rabbit_types:message_properties(), pid(), state()) - -> {undefined, state()}). --spec(drain_confirmed/1 :: (state()) -> {[rabbit_guid:guid()], state()}). --spec(dropwhile/3 :: - (fun ((rabbit_types:message_properties()) -> boolean()), msg_fun(), - state()) - -> state()). --spec(fetch/2 :: (true, state()) -> {fetch_result(ack()), state()}; - (false, state()) -> {fetch_result(undefined), state()}). --spec(ack/2 :: ([ack()], state()) -> {[rabbit_guid:guid()], state()}). --spec(fold/3 :: (msg_fun(), state(), [ack()]) -> state()). --spec(requeue/2 :: ([ack()], state()) - -> {[rabbit_guid:guid()], state()}). --spec(len/1 :: (state()) -> non_neg_integer()). --spec(is_empty/1 :: (state()) -> boolean()). --spec(set_ram_duration_target/2 :: - (duration(), state()) -> state()). --spec(ram_duration/1 :: (state()) -> {duration(), state()}). --spec(needs_timeout/1 :: (state()) -> 'false' | 'timed' | 'idle'). --spec(timeout/1 :: (state()) -> state()). --spec(handle_pre_hibernate/1 :: (state()) -> state()). --spec(status/1 :: (state()) -> [{atom(), any()}]). --spec(invoke/3 :: (atom(), fun ((atom(), A) -> A), state()) -> state()). --spec(is_duplicate/2 :: - (rabbit_types:basic_message(), state()) -> - {'false'|'published'|'discarded', state()}). --spec(discard/3 :: (rabbit_types:basic_message(), pid(), state()) -> state()). |