View Source OffBroadway.Splunk.Client behaviour (off_broadway_splunk v2.1.2)

A generic behaviour for implementing Splunk clients for OffBroadway.Splunk.Producer.

This module defines callbacks to normalize options and receive items for a Splunk job.

Modules that implements this behaviour should be passed as the :splunk_client option from OffBroadway.Splunk.Producer.

Summary

Types

@type messages() :: [Broadway.Message.t()]

Callbacks

Link to this callback

ack_message(message, ack_options)

View Source (optional)
@callback ack_message(message :: Broadway.Message.t(), ack_options :: any()) :: any()
@callback init(opts :: any()) ::
  {:ok, normalized_opts :: any()} | {:error, reason :: binary()}
Link to this callback

receive_messages(sid, demand, opts)

View Source
@callback receive_messages(sid :: binary(), demand :: pos_integer(), opts :: any()) ::
  messages()
Link to this callback

receive_status(name, opts)

View Source
@callback receive_status(name :: binary(), opts :: any()) ::
  {:ok, response :: any()} | {:error, reason :: any()}