diff --git a/src/riak_pipe_builder.erl b/src/riak_pipe_builder.erl index e32ba2c..4c22490 100644 --- a/src/riak_pipe_builder.erl +++ b/src/riak_pipe_builder.erl @@ -52,6 +52,7 @@ sinkmon :: reference()}). % monitor ref -opaque state() :: #state{}. +-export_type([state/0]). %%%=================================================================== %%% API diff --git a/src/riak_pipe_fitting.erl b/src/riak_pipe_fitting.erl index c30fc6c..d684d34 100644 --- a/src/riak_pipe_fitting.erl +++ b/src/riak_pipe_fitting.erl @@ -62,7 +62,7 @@ -opaque state() :: #state{}. --export_type([details/0]). +-export_type([state/0, details/0]). -type details() :: #fitting_details{}. %%%=================================================================== diff --git a/src/riak_pipe_vnode.erl b/src/riak_pipe_vnode.erl index b23a7ee..e79575e 100644 --- a/src/riak_pipe_vnode.erl +++ b/src/riak_pipe_vnode.erl @@ -115,6 +115,7 @@ | #handoff{}}). -opaque state() :: #state{}. +-export_type([state/0]). -record(cmd_enqueue, {fitting :: #fitting{}, input :: term(), diff --git a/src/riak_pipe_vnode_worker.erl b/src/riak_pipe_vnode_worker.erl index 986d5e4..449210d 100644 --- a/src/riak_pipe_vnode_worker.erl +++ b/src/riak_pipe_vnode_worker.erl @@ -161,6 +161,7 @@ vnode :: pid(), modstate :: term()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Get information about this behavior. -spec behaviour_info(atom()) -> 'undefined' | [{atom(), arity()}]. diff --git a/src/riak_pipe_w_crash.erl b/src/riak_pipe_w_crash.erl index c04c8d7..56efad3 100644 --- a/src/riak_pipe_w_crash.erl +++ b/src/riak_pipe_w_crash.erl @@ -33,6 +33,7 @@ -record(state, {p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% name of the table reMEMbering restarts -define(MEM, ?MODULE). diff --git a/src/riak_pipe_w_fwd.erl b/src/riak_pipe_w_fwd.erl index c5809bb..6e908c0 100644 --- a/src/riak_pipe_w_fwd.erl +++ b/src/riak_pipe_w_fwd.erl @@ -35,6 +35,7 @@ -record(state, {fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Initialization just stows the fitting details in the module's %% state, for sending traces in {@link process/3}. diff --git a/src/riak_pipe_w_pass.erl b/src/riak_pipe_w_pass.erl index 6e15f45..f5e6170 100644 --- a/src/riak_pipe_w_pass.erl +++ b/src/riak_pipe_w_pass.erl @@ -35,6 +35,7 @@ -record(state, {p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Initialization just stows the partition and fitting details in %% the module's state, for sending outputs in {@link process/3}. diff --git a/src/riak_pipe_w_rec_countdown.erl b/src/riak_pipe_w_rec_countdown.erl index 065f8ff..0ab0159 100644 --- a/src/riak_pipe_w_rec_countdown.erl +++ b/src/riak_pipe_w_rec_countdown.erl @@ -81,6 +81,7 @@ -record(state, {p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Initialization just stows the partition and fitting details in %% the module's state, for sending outputs in {@link process/3}. diff --git a/src/riak_pipe_w_reduce.erl b/src/riak_pipe_w_reduce.erl index c25c959..555ce18 100644 --- a/src/riak_pipe_w_reduce.erl +++ b/src/riak_pipe_w_reduce.erl @@ -93,6 +93,7 @@ p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Setup creates the store for evaluation results (a dict()) and %% stashes away the `Partition' and `FittingDetails' for later. diff --git a/src/riak_pipe_w_tee.erl b/src/riak_pipe_w_tee.erl index 29e6d76..c93ec74 100644 --- a/src/riak_pipe_w_tee.erl +++ b/src/riak_pipe_w_tee.erl @@ -38,6 +38,7 @@ -record(state, {p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Init just stashes the `Partition' and `FittingDetails' for later. -spec init(riak_pipe_vnode:partition(), riak_pipe_fitting:details()) -> diff --git a/src/riak_pipe_w_xform.erl b/src/riak_pipe_w_xform.erl index 1760d28..e0a78bd 100644 --- a/src/riak_pipe_w_xform.erl +++ b/src/riak_pipe_w_xform.erl @@ -55,6 +55,7 @@ -record(state, {p :: riak_pipe_vnode:partition(), fd :: riak_pipe_fitting:details()}). -opaque state() :: #state{}. +-export_type([state/0]). %% @doc Init just stashes the `Partition' and `FittingDetails' for later. -spec init(riak_pipe_vnode:partition(), riak_pipe_fitting:details()) ->