swirl_tracker (swirl v0.2.8)

View Source

Summary

Types

flow/0

-type flow() ::
          #flow{id :: binary(),
                module :: module(),
                module_vsn :: undefined | module_vsn(),
                stream_filter :: undefined | string(),
                stream_names :: undefined | stream_names(),
                mapper_window :: undefined | pos_integer(),
                mapper_nodes :: undefined | [node()],
                mapper_opts :: mapper_opts(),
                reducer_window :: undefined | pos_integer(),
                reducer_node :: node(),
                reducer_opts :: reducer_opts(),
                reducer_skip :: undefined | boolean(),
                output_opts :: output_opts(),
                heartbeat :: undefined | pos_integer(),
                window_sync :: undefined | boolean(),
                started_at :: undefined | erlang:timestamp(),
                start_node :: node()}.

mapper_opts/0

-type mapper_opts() :: term().

module_vsn/0

-type module_vsn() :: pos_integer().

output_opts/0

-type output_opts() :: term().

reducer_opts/0

-type reducer_opts() :: term().

stream_name/0

-type stream_name() :: atom().

stream_names/0

-type stream_names() :: [stream_name()].

Functions

code_change(OldVsn, State, Extra)

handle_call(Request, From, State)

handle_cast(Msg, State)

handle_info(Info, State)

init(_)

lookup(TableId, Key)

-spec lookup(ets:tab(), term()) -> term().

message(Node, FlowId, Msg)

-spec message(node(), binary(), term()) -> ok.

register(TableId, Key, Value)

-spec register(ets:tab(), term(), term()) -> true.

start_link()

-spec start_link() -> {ok, pid()}.

start_mappers(Flow)

-spec start_mappers(flow()) -> ok.

start_reducer(Flow)

-spec start_reducer(flow()) -> ok.

stop_mappers(Flow)

-spec stop_mappers(flow()) -> ok.

stop_reducer(Flow)

-spec stop_reducer(flow()) -> ok.

terminate(Reason, State)

unregister(TableId, Key)

-spec unregister(ets:tab(), term()) -> true.