Version: 2.3.3

Source / Track processing

`append`

Append an extra track to every track. Set the metadata ‘liq_append’ to false to inhibit appending on one track.

Type:

(?id : string?, ?insert_missing : bool, ?merge : bool, source('a),
 (([string * string]) -> source('a))) -> source('a)
where 'a is an orderable type

Arguments:

id (of type string?, which defaults to "append")
insert_missing (of type bool, which defaults to true): Treat track beginnings without metadata as having empty one.
merge (of type bool, which defaults to false): Merge the track with its appended track.
(unlabeled) (of type source('a) where 'a is an orderable type): Given the metadata, build the source producing the track to append. The function can return null to prevent appending a new track.
(unlabeled) (of type ([string * string]) -> source('a) where 'a is an orderable type)

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
cancel_pending (of type () -> unit):
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
pending (of type () -> source('A)? where 'A is an orderable type):
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
selected (of type () -> source('A)? where 'A is an orderable type): Currently selected source.
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
set_pending (of type (source('A)?) -> unit where 'A is an orderable type):
skip (of type (?cancel_pending : bool) -> unit):
time (of type () -> float): Get a source's time, based on its assigned clock.

`chop`

Regularly insert track boundaries in a stream (useful for testing tracks).

Type:

(?id : string?, ?every : {float}, ?metadata : {[string * string]},
 source('a)) -> source('a)

Arguments:

id (of type string?, which defaults to null)
every (of type {float}, which defaults to 3.0): Duration of a track (in seconds).
metadata (of type {[string * string]}, which defaults to []): Metadata for tracks.
(unlabeled) (of type source('a)): The stream.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`fallback.skip`

Special track insensitive fallback that always skips current song before switching.

Type:

(source('a), ?fallback : source('a)?) -> source('a)
where 'a is a set of internal tracks

Arguments:

(unlabeled) (of type source('a) where 'a is a set of internal tracks): The main source.
fallback (of type source('a)? where 'a is a set of internal tracks, which defaults to null): The fallback source. Defaults to blank if null.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`map_first_track`

Apply a function to the first track of a source

Type:

(?id : string?, ((source('a)) -> source('a)), source('a)) -> source('a)

Arguments:

id (of type string?, which defaults to "map_first_track"): Force the value of the source ID.
(unlabeled) (of type (source('a)) -> source('a)): The applied function.
(unlabeled) (of type source('a)): The input source.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
selected (of type () -> source('A)?): Currently selected source.
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`native.fallback`

At the beginning of each track, select the first ready child.

Type:

(?id : string?, ?track_sensitive : bool, {[source('a)]}) -> source('a)

Arguments:

id (of type string?, which defaults to null): Force the value of the source ID.
track_sensitive (of type bool, which defaults to true): Re-select only on end of tracks.
(unlabeled) (of type {[source('a)]})

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
current_source (of type () -> source('A)?): Return the source currently selected.
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
prepare (of type (source('A)) -> unit): Prepare a source that will be returned later.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`native.once`

Create a source that plays only one track of the input source.

Type:

(source('a)) -> source('a)

Arguments:

(unlabeled) (of type source('a))

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`native.sequence`

Play only one track of every successive source, except for the last one which is played as much as available.

Type:

(?id : string?,
 [source('a)
  .{
    buffered : () -> [string * float],
    clock : clock,
    duration : () -> float,
    elapsed : () -> float,
    fallible : bool,
    id : () -> string,
    is_active : () -> bool,
    is_ready : () -> bool,
    is_up : () -> bool,
    last_metadata : () -> [string * string]?,
    log : 
    {level : (() -> int).{set : (int) -> unit}
    },
    on_metadata : ((([string * string]) -> unit)) -> unit,
    on_shutdown : ((() -> unit)) -> unit,
    on_track : ((([string * string]) -> unit)) -> unit,
    on_wake_up : ((() -> unit)) -> unit,
    register_command : (?usage : string?, description : string, string,
                        ((string) -> string)) -> unit,
    remaining : () -> float,
    reset_last_metadata_on_track : (() -> bool)
    .{set : (bool) -> unit
    },
    seek : (float) -> float,
    self_sync : () -> bool,
    skip : () -> unit,
    time : () -> float
  }]) -> source('a)

Arguments:

id (of type string?, which defaults to null): Force the value of the source ID.
(unlabeled) (of type [source('a) .{ buffered : () -> [string * float], clock : clock, duration : () -> float, elapsed : () -> float, fallible : bool, id : () -> string, is_active : () -> bool, is_ready : () -> bool, is_up : () -> bool, last_metadata : () -> [string * string]?, log : {level : (() -> int).{set : (int) -> unit} }, on_metadata : ((([string * string]) -> unit)) -> unit, on_shutdown : ((() -> unit)) -> unit, on_track : ((([string * string]) -> unit)) -> unit, on_wake_up : ((() -> unit)) -> unit, register_command : (?usage : string?, description : string, string, ((string) -> string)) -> unit, remaining : () -> float, reset_last_metadata_on_track : (() -> bool) .{set : (bool) -> unit }, seek : (float) -> float, self_sync : () -> bool, skip : () -> unit, time : () -> float }]): List of sources to play tracks from.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`native.switch`

Select the first source whose predicate is true in a list. If the second argument is a getter, the source will be dynamically created.

Type:

(?id : string?, ?track_sensitive : bool, [{bool} * source('a)]) -> source('a)

Arguments:

id (of type string?, which defaults to null): Force the value of the source ID.
track_sensitive (of type bool, which defaults to true): Re-select only on end of tracks.
(unlabeled) (of type [{bool} * source('a)]): Sources with the predicate telling when they can be played.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
current_source (of type () -> source('A)?): Return the source currently selected.
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
prepare (of type (source('A)) -> unit): Prepare a source that will be returned later.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`notify_metadata`

Use notify to display metadata info.

Type:

(?urgency : string, ?icon : string, ?timeout : float,
 ?display : (([string * string]) -> string), ?title : string, 'b
 .{on_metadata : ((([string * string]) -> unit)) -> 'a}) -> 'a

Arguments:

urgency (of type string, which defaults to "low"): Urgency (low|normal|critical).
icon (of type string, which defaults to "stock_smiley-22"): Icon filename or stock icon to display.
timeout (of type float, which defaults to 3.0): Timeout in seconds.
display (of type ([string * string]) -> string, which defaults to <fun>): Function used to display a metadata packet.
title (of type string, which defaults to "Liquidsoap: new track"): Title of the notification message.
(unlabeled) (of type 'b.{on_metadata : ((([string * string]) -> unit)) -> 'a})

`osd_metadata`

Use X On Screen Display to display metadata info.

Type:

(?color : string, ?position : string, ?font : string,
 ?display : (([string * string]) -> string), 'b
 .{on_metadata : ((([string * string]) -> unit)) -> 'a}) -> 'a

Arguments:

color (of type string, which defaults to "green"): Color of the text.
position (of type string, which defaults to "top"): Position of the text (top|middle|bottom).
font (of type string, which defaults to "-*-courier-*-r-*-*-*-240-*-*-*-*-*-*"): Font used (xfontsel is your friend...)
display (of type ([string * string]) -> string, which defaults to <fun>): Function used to display a metadata packet.
(unlabeled) (of type 'b.{on_metadata : ((([string * string]) -> unit)) -> 'a})

`overlap_sources`

Rotate between overlapping sources. Next track starts according to 'liq_start_next' offset metadata.

Type:

(?id : string?, ?normalize : bool, ?start_next : string,
 ?weights : [{float}], [source('a)]) -> source('a)
where
  'a is a set of internal tracks and a set of tracks to be muxed into a source

Arguments:

id (of type string?, which defaults to "overlap_sources"): Force the value of the source ID.
normalize (of type bool, which defaults to false)
start_next (of type string, which defaults to "liq_start_next"): Metadata field indicating when the next track should start, relative to current track's time.
weights (of type [{float}], which defaults to []): Relative weight of the sources in the sum. The empty list stands for the homogeneous distribution.
(unlabeled) (of type [source('a)] where 'a is a set of internal tracks and a set of tracks to be muxed into a source): Sources to toggle from

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
insert_metadata (of type (?new_track : bool, [string * string]) -> unit): Insert metadata in the source. The new_track parameter indicates whether a track boundary should also be inserted (by default, no track is inserted).
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`playlog`

Keep a record of played files. This is primarily useful to know when a song was last played and avoid repetitions.

Type:

(?duration : float, ?persistency : string?,
 ?hash : (([string * string]) -> string)) -> unit

Arguments:

duration (of type float, which defaults to inf): Duration (in seconds) after which songs are forgotten. By default, songs are not forgotten which means that the playlog will contain all the songs ever played.
persistency (of type string?, which defaults to null): Set a file name where the values are stored and loaded in case the script is restarted.
hash (of type ([string * string]) -> string, which defaults to <fun>): Function to extract an identifier from the metadata. By default, the filename is used but we could return the artist to know when a song from a given artist was last played for instance.

Methods:

add (of type ([string * string]) -> unit): Record that file with given metadata has been played.
last (of type ([string * string]) -> float): How long ago a file was played (in seconds), infinity is returned if the song has never been played.

`prepend`

Prepend an extra track before every track. Set the metadata liq_prepend to false to inhibit prepending on one track.

Type:

(?id : string?, ?merge : bool, source('a),
 (([string * string]) -> source('a)?)) -> source('a)

Arguments:

id (of type string?, which defaults to "prepend")
merge (of type bool, which defaults to false): Merge the track with its appended track.
(unlabeled) (of type source('a)): Given the metadata, build the source producing the track to append. The function can return null to prevent any track prepend.
(unlabeled) (of type ([string * string]) -> source('a)?)

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
selected (of type () -> source('A)?): Currently selected source.
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`rotate.merge`

Same operator as rotate but merges tracks from each sources. For instance, rotate.merge([intro,main,outro]) creates a source that plays a sequence [intro,main,outro] as single track and loops back.

Type:

(?id : string?, ?transitions : [(source('a), source('a)) -> source('a)],
 ?weights : [{int}], [source('a)]) -> source('a)
where
  'a is a set of tracks to be muxed into a source and a set of internal tracks

Arguments:

id (of type string?, which defaults to "rotate.merge"): Force the value of the source ID.
transitions (of type [(source('a), source('a)) -> source('a)] where 'a is a set of tracks to be muxed into a source and a set of internal tracks, which defaults to []): Transition functions, padded with fun (x,y) -> y functions.
weights (of type [{int}], which defaults to []): Weights of the children (padded with 1), defining for each child how many tracks are played from it per round, if that many are actually available.
(unlabeled) (of type [source('a)] where 'a is a set of tracks to be muxed into a source and a set of internal tracks): Sequence of sources to be merged

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
selected (of type () -> source('A)? where 'A is a set of tracks to be muxed into a source and a set of internal tracks): Currently selected source.
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`server.insert_metadata`

Register a server/telnet command to update a source's metadata. Returns a new source, which will receive the updated metadata. The command has the following format: insert key1="val1",key2="val2",...

Type:

(?id : string?, source('a)) -> source('a)

Arguments:

id (of type string?, which defaults to null): Force the value of the source ID.
(unlabeled) (of type source('a))

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
insert_metadata (of type (?new_track : bool, [string * string]) -> unit): Insert metadata in the source. The new_track parameter indicates whether a track boundary should also be inserted (by default, no track is inserted).
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`skipper`

Regularly skip tracks from a source (useful for testing skipping).

Type:

(?every : {float}, source('a).{skip : () -> unit, time : () -> float}) ->
source('a)

Arguments:

every (of type {float}, which defaults to 5.0): How often to skip tracks.
(unlabeled) (of type source('a).{skip : () -> unit, time : () -> float}): The stream.

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

`source.cue`

Generate a CUE file for the source. This function will generate a new track in the file for each metadata of the source. This function tries to map metadata to the appropriate CUE file standard values. You can use the map_metadata argument to add your own pre-processing. The following metadata are recognized on tracks: "title", "artist", "album", "isrc", and "cue_year".

Type:

(?title : string?, ?performer : string?, ?file : string?,
 ?file_type : string?, ?comment : string?, ?year : 'a?,
 ?map_metadata : (([string * string]) -> [string * string]),
 ?last_tracks : int?, ?temp_dir : string?, ?deduplicate_using : [string],
 ?delete : bool, string, source('b)) -> source('b)
where 'b is a set of tracks to be muxed into a source

Arguments:

title (of type string?, which defaults to null): Title of the stream.
performer (of type string?, which defaults to null)
file (of type string?, which defaults to null): File where the stream is stored.
file_type (of type string?, which defaults to null): Format in which the stream is stored.
comment (of type string?, which defaults to null): Comment about the stream.
year (of type 'a?, which defaults to null): Year for the stream.
map_metadata (of type ([string * string]) -> [string * string], which defaults to <fun>): Function to apply to metadata before writing the CUE file (useful for pre-processing metadata).
last_tracks (of type int?, which defaults to null): Only report the number of last tracks.
temp_dir (of type string?, which defaults to null): Temporary directory for atomic write.
deduplicate_using (of type [string], which defaults to ["title", "artist", "album", "isrc", "cue_year"]): To avoid duplicate entries, duplicate metadata are filtered. Set this to a list of labels to use for detecting duplicated metadata.
delete (of type bool, which defaults to true): Delete the CUE files when starting if it exists.
(unlabeled) (of type string): Path where the CUE file should be written.
(unlabeled) (of type source('b) where 'b is a set of tracks to be muxed into a source)

Methods:

buffered (of type () -> [string * float]): Length of buffered data.
clock (of type clock): The source's clock
duration (of type () -> float): Estimation of the duration of the current track.
elapsed (of type () -> float): Elapsed time in the current track.
fallible (of type bool): Indicate if a source may fail, i.e. may not be ready to stream.
id (of type () -> string): Identifier of the source.
is_active (of type () -> bool): true if the source is active, i.e. it is continuously animated by its own clock whenever it is ready. Typically, true for outputs and sources such as input.http.
is_ready (of type () -> bool): Indicate if a source is ready to stream. This does not mean that the source is currently streaming, just that its resources are all properly initialized.
is_up (of type () -> bool): Indicate that the source can be asked to produce some data at any time. This is true when the source is currently being used or if it could be used at any time, typically inside a switch or fallback.
last_metadata (of type () -> [string * string]?): Return the last metadata from the source.
log (of type {level : (() -> int).{set : (int) -> unit}}): Get or set the source's log level, from 1 to 5.
on_metadata (of type ((([string * string]) -> unit)) -> unit): Call a given handler on metadata packets.
on_shutdown (of type ((() -> unit)) -> unit): Register a function to be called when source shuts down.
on_track (of type ((([string * string]) -> unit)) -> unit): Call a given handler on new tracks.
on_wake_up (of type ((() -> unit)) -> unit): Register a function to be called after the source is asked to get ready. This is when, for instance, the source's final ID is set.
register_command (of type (?usage : string?, description : string, string, ((string) -> string)) -> unit): Register a server command for this source. Command is registered under the source's id namespace when it gets up and de-registered when it gets down.
remaining (of type () -> float): Estimation of remaining time in the current track.
reset_last_metadata_on_track (of type (() -> bool).{set : (bool) -> unit}): If true, the source's last_metadata is reset on each new track. If a metadata is present along with the track mark, then it becomes the new last_metadata, otherwise, last_metadata becomes null`.
seek (of type (float) -> float): Seek forward, in seconds (returns the amount of time effectively seeked).
self_sync (of type () -> bool): Is the source currently controlling its own real-time loop.
skip (of type () -> unit): Skip to the next track.
time (of type () -> float): Get a source's time, based on its assigned clock.

append​

chop​

fallback.skip​

map_first_track​

native.fallback​

native.once​

native.sequence​

native.switch​

notify_metadata​

osd_metadata​

overlap_sources​

playlog​

prepend​

rotate.merge​

server.insert_metadata​

skipper​

source.cue​

`append`

`chop`

`fallback.skip`

`map_first_track`

`native.fallback`

`native.once`

`native.sequence`

`native.switch`

`notify_metadata`

`osd_metadata`

`overlap_sources`

`playlog`

`prepend`

`rotate.merge`

`server.insert_metadata`

`skipper`

`source.cue`