Skip to content
This repository
tree: fd21fea013
Fetching contributors…

Cannot retrieve contributors at this time

file 39 lines (35 sloc) 1.401 kb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39
-define(PT_MSG_INIT, 0).
-define(PT_MSG_OBJ, 1).
-define(PT_MSG_OLDSYNC, 2).
-define(PT_MSG_SYNC, 3).
-define(PT_MSG_CONFIGURE, 4).

-record(ho_stats,
        {
          interval_end :: erlang:timestamp(),
          last_update :: erlang:timestamp(),
          objs=0 :: non_neg_integer(),
          bytes=0 :: non_neg_integer()
        }).

-type ho_stats() :: #ho_stats{}.
-type ho_type() :: ownership_handoff | hinted_handoff | repair.
-type predicate() :: fun((any()) -> boolean()).

-type index() :: integer().
-type mod_src_tgt() :: {module(), index(), index()}.
-type mod_partition() :: {module(), index()}.

-record(handoff_status,
        { mod_src_tgt :: mod_src_tgt(),
          src_node :: node(),
          target_node :: node(),
          direction :: inbound | outbound,
          transport_pid :: pid(),
          transport_mon :: reference(),
          timestamp :: tuple(),
          status :: any(),
          stats :: dict(),
          vnode_pid :: pid() | undefined,
          vnode_mon :: reference(),
          type :: ho_type(),
          req_origin :: node(),
          filter_mod_fun :: {module(), atom()}
        }).
-type handoff_status() :: #handoff_status{}.
Something went wrong with that request. Please try again.