Membrane.HTTPAdaptiveStream.Storage behaviour (Membrane HTTP Adaptive Stream plugin v0.4.0) View Source

Behaviour for storing manifests and stream segments.

Link to this section Summary

Types

callback_result_t()

config_t()

state_t()

t()

Callbacks

init(config_t)

Generates the storage state based on the configuration struct.

remove(resource_name, context, state_t)

Removes the resource.

store(resource_name, content, context, state_t)

Stores the resource on a storage.

Functions

apply_segment_changeset(storage, arg, payload)

Stores a new segment and removes stale ones.

cleanup(storage, segments)

Removes all the saved segments and manifests.

clear_cache(storage)

Clears the manifest cache.

new(storage_config, opts \\ [])

Initializes the storage.

store_header(storage, name, payload)

Stores stream header file.

store_manifests(storage, manifests)

Stores serialized manifest files

Link to this section Types

callback_result_t()

Specs

callback_result_t() :: :ok | {:error, reason :: any()}

config_t()

Specs

config_t() :: struct()

state_t()

Specs

state_t() :: any()

t()

(opaque)

Specs

t()

Link to this section Callbacks

init(config_t)

Specs

init(config_t()) :: state_t()

Generates the storage state based on the configuration struct.

remove(resource_name, context, state_t)

Specs

remove(
  resource_name :: String.t(),
  context :: %{type: :manifest | :header | :segment},
  state_t()
) :: callback_result_t()

Removes the resource.

store(resource_name, content, context, state_t)

Specs

store(
  resource_name :: String.t(),
  content :: String.t() | binary(),
  context :: %{type: :manifest | :header | :segment, mode: :text | :binary},
  state_t()
) :: callback_result_t()

Stores the resource on a storage.

Gets the mode that should be used when writing to a file and type of the resource

Link to this section Functions

apply_segment_changeset(storage, arg, payload)

Specs

apply_segment_changeset(
  t(),
  {to_add :: String.t(), to_remove :: [String.t()]},
  payload :: binary()
) :: {callback_result_t(), t()}

Stores a new segment and removes stale ones.

cleanup(storage, segments)

Specs

cleanup(t(), segments :: [String.t()]) :: {callback_result_t(), t()}

Removes all the saved segments and manifests.

clear_cache(storage)

Specs

clear_cache(t()) :: t()

Clears the manifest cache.

new(storage_config, opts \\ [])

Specs

new(config_t(), [{:enable_cache, boolean()}]) :: t()

Initializes the storage.

Accepts the following options:

enable_cache - if true (default), manifests will be stored only if they've been changed

store_header(storage, name, payload)

Specs

store_header(t(), name :: String.t(), payload :: binary()) ::
  {callback_result_t(), t()}

Stores stream header file.

store_manifests(storage, manifests)

Specs

store_manifests(t(), [{name :: String.t(), content :: String.t()}]) ::
  {callback_result_t(), t()}

Stores serialized manifest files