|
|
|
@ -65,7 +65,7 @@
|
|
|
|
|
*
|
|
|
|
|
* \par stasis_topic
|
|
|
|
|
*
|
|
|
|
|
* A \ref stasis_topic is an object to which \ref stasis_subscriber's may be
|
|
|
|
|
* A \ref stasis_topic is an object to which stasis_topic_subscriber's may be
|
|
|
|
|
* subscribed, and \ref stasis_message's may be published. Any message published
|
|
|
|
|
* to the topic is dispatched to all of its subscribers. The topic itself may be
|
|
|
|
|
* named, which is useful in debugging.
|
|
|
|
@ -106,7 +106,7 @@
|
|
|
|
|
* cache may be shared amongst different message types, such a usage is probably
|
|
|
|
|
* not a good idea.
|
|
|
|
|
*
|
|
|
|
|
* The \ref stasis_cache can only be written to by \ref stasis_caching_topics.
|
|
|
|
|
* The \ref stasis_cache can only be written to by \ref stasis_caching_topic.
|
|
|
|
|
* It's a thread safe container, so freely use the stasis_cache_get() and
|
|
|
|
|
* stasis_cache_dump() to query the cache.
|
|
|
|
|
*
|
|
|
|
@ -125,7 +125,7 @@
|
|
|
|
|
* The \ref stasis_cache object is a normal AO2 managed object, which can be
|
|
|
|
|
* release with ao2_cleanup().
|
|
|
|
|
*
|
|
|
|
|
* \par stasis_subscriber
|
|
|
|
|
* \par stasis_topic_subscriber
|
|
|
|
|
*
|
|
|
|
|
* Any topic may be subscribed to by simply providing stasis_subscribe() the
|
|
|
|
|
* \ref stasis_topic to subscribe to, a handler function and \c void pointer to
|
|
|
|
@ -247,8 +247,7 @@ struct stasis_message_vtable {
|
|
|
|
|
* \param sanitize Snapshot sanitization callback.
|
|
|
|
|
*
|
|
|
|
|
* \return Newly allocated JSON message.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if JSON format is not supported.
|
|
|
|
|
* \retval NULL if JSON format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_json *(*to_json)(struct stasis_message *message, const struct stasis_message_sanitizer *sanitize);
|
|
|
|
|
|
|
|
|
@ -260,8 +259,7 @@ struct stasis_message_vtable {
|
|
|
|
|
*
|
|
|
|
|
* \param message Message to convert to AMI string.
|
|
|
|
|
* \return Newly allocated \ref ast_manager_event_blob.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if AMI format is not supported.
|
|
|
|
|
* \retval NULL if AMI format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_manager_event_blob *(*to_ami)(
|
|
|
|
|
struct stasis_message *message);
|
|
|
|
@ -275,8 +273,7 @@ struct stasis_message_vtable {
|
|
|
|
|
*
|
|
|
|
|
* \param message Message to convert to an \ref ast_event.
|
|
|
|
|
* \return Newly allocated \ref ast_event.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if AMI format is not supported.
|
|
|
|
|
* \retval NULL if AMI format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_event *(*to_event)(
|
|
|
|
|
struct stasis_message *message);
|
|
|
|
@ -337,7 +334,7 @@ enum stasis_message_type_result stasis_message_type_create(const char *name,
|
|
|
|
|
* \brief Gets the name of a given message type
|
|
|
|
|
* \param type The type to get.
|
|
|
|
|
* \return Name of the type.
|
|
|
|
|
* \return \c NULL if \a type is \c NULL.
|
|
|
|
|
* \retval NULL if \a type is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
const char *stasis_message_type_name(const struct stasis_message_type *type);
|
|
|
|
@ -379,7 +376,7 @@ int stasis_message_type_declined(const char *name);
|
|
|
|
|
* \param data Immutable data that is the actual contents of the message
|
|
|
|
|
*
|
|
|
|
|
* \return New message
|
|
|
|
|
* \return \c NULL on error
|
|
|
|
|
* \retval NULL on error
|
|
|
|
|
*
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
@ -404,7 +401,7 @@ struct stasis_message *stasis_message_create(struct stasis_message_type *type, v
|
|
|
|
|
* any remote entities publishing to a mailbox.
|
|
|
|
|
*
|
|
|
|
|
* \retval New message
|
|
|
|
|
* \retval \c NULL on error
|
|
|
|
|
* \retval NULL on error
|
|
|
|
|
*
|
|
|
|
|
* \since 12.2.0
|
|
|
|
|
*/
|
|
|
|
@ -417,7 +414,7 @@ struct stasis_message *stasis_message_create_full(struct stasis_message_type *ty
|
|
|
|
|
* \param msg Message to get eid.
|
|
|
|
|
*
|
|
|
|
|
* \retval Entity id of \a msg
|
|
|
|
|
* \retval \c NULL if \a msg is an aggregate or \a msg is \c NULL.
|
|
|
|
|
* \retval NULL if \a msg is an aggregate or \a msg is \c NULL.
|
|
|
|
|
*/
|
|
|
|
|
const struct ast_eid *stasis_message_eid(const struct stasis_message *msg);
|
|
|
|
|
|
|
|
|
@ -425,7 +422,7 @@ const struct ast_eid *stasis_message_eid(const struct stasis_message *msg);
|
|
|
|
|
* \brief Get the message type for a \ref stasis_message.
|
|
|
|
|
* \param msg Message to type
|
|
|
|
|
* \return Type of \a msg
|
|
|
|
|
* \return \c NULL if \a msg is \c NULL.
|
|
|
|
|
* \retval NULL if \a msg is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_message_type *stasis_message_type(const struct stasis_message *msg);
|
|
|
|
@ -434,7 +431,7 @@ struct stasis_message_type *stasis_message_type(const struct stasis_message *msg
|
|
|
|
|
* \brief Get the data contained in a message.
|
|
|
|
|
* \param msg Message.
|
|
|
|
|
* \return Immutable data pointer
|
|
|
|
|
* \return \c NULL if msg is \c NULL.
|
|
|
|
|
* \retval NULL if msg is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
void *stasis_message_data(const struct stasis_message *msg);
|
|
|
|
@ -443,7 +440,7 @@ void *stasis_message_data(const struct stasis_message *msg);
|
|
|
|
|
* \brief Get the time when a message was created.
|
|
|
|
|
* \param msg Message.
|
|
|
|
|
* \return Pointer to the \a timeval when the message was created.
|
|
|
|
|
* \return \c NULL if msg is \c NULL.
|
|
|
|
|
* \retval NULL if msg is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
const struct timeval *stasis_message_timestamp(const struct stasis_message *msg);
|
|
|
|
@ -458,8 +455,7 @@ const struct timeval *stasis_message_timestamp(const struct stasis_message *msg)
|
|
|
|
|
* \param sanitize Snapshot sanitization callback.
|
|
|
|
|
*
|
|
|
|
|
* \return Newly allocated string with JSON message.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if JSON format is not supported.
|
|
|
|
|
* \retval NULL if JSON format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_json *stasis_message_to_json(struct stasis_message *msg, struct stasis_message_sanitizer *sanitize);
|
|
|
|
|
|
|
|
|
@ -470,8 +466,7 @@ struct ast_json *stasis_message_to_json(struct stasis_message *msg, struct stasi
|
|
|
|
|
* be ao2_cleanup()'ed.
|
|
|
|
|
*
|
|
|
|
|
* \param msg Message to convert to AMI.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if AMI format is not supported.
|
|
|
|
|
* \retval NULL if AMI format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_manager_event_blob *stasis_message_to_ami(struct stasis_message *msg);
|
|
|
|
|
|
|
|
|
@ -492,8 +487,7 @@ int stasis_message_can_be_ami(struct stasis_message *msg);
|
|
|
|
|
* be disposed of via \ref ast_event_destroy.
|
|
|
|
|
*
|
|
|
|
|
* \param msg Message to convert to AMI.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \return \c NULL if AMI format is not supported.
|
|
|
|
|
* \retval NULL if AMI format is not supported.
|
|
|
|
|
*/
|
|
|
|
|
struct ast_event *stasis_message_to_event(struct stasis_message *msg);
|
|
|
|
|
|
|
|
|
@ -507,7 +501,7 @@ struct stasis_topic;
|
|
|
|
|
* \brief Create a new topic.
|
|
|
|
|
* \param name Name of the new topic.
|
|
|
|
|
* \return New topic instance.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
* \since 12
|
|
|
|
|
*
|
|
|
|
|
* \note There is no explicit ability to unsubscribe all subscribers
|
|
|
|
@ -515,7 +509,8 @@ struct stasis_topic;
|
|
|
|
|
* the last subscriber unsubscribes itself even if there is no
|
|
|
|
|
* publisher.
|
|
|
|
|
*
|
|
|
|
|
* \note Topic names should be in the form of <subsystem>:<functionality>[/<object>]
|
|
|
|
|
* \note Topic names should be in the form of
|
|
|
|
|
* \verbatim <subsystem>:<functionality>[/<object>] \endverbatim
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_topic *stasis_topic_create(const char *name);
|
|
|
|
|
|
|
|
|
@ -524,7 +519,7 @@ struct stasis_topic *stasis_topic_create(const char *name);
|
|
|
|
|
* \param name Name of the new topic.
|
|
|
|
|
* \param detail Detail description of the new topic. i.e. "Queue main topic for subscribing every queue event"
|
|
|
|
|
* \return New topic instance.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
*
|
|
|
|
|
* \note There is no explicit ability to unsubscribe all subscribers
|
|
|
|
|
* from a topic and destroy it. As a result the topic can persist until
|
|
|
|
@ -538,7 +533,7 @@ struct stasis_topic *stasis_topic_create_with_detail(
|
|
|
|
|
* \brief Get a topic of the given name.
|
|
|
|
|
* \param name Topic's name.
|
|
|
|
|
* \return Name of the topic.
|
|
|
|
|
* \return \c NULL on error or not exist.
|
|
|
|
|
* \retval NULL on error or not exist.
|
|
|
|
|
*
|
|
|
|
|
* \note This SHOULD NOT be used in normal operation for publishing messages.
|
|
|
|
|
*/
|
|
|
|
@ -548,7 +543,7 @@ struct stasis_topic *stasis_topic_get(const char *name);
|
|
|
|
|
* \brief Return the uniqueid of a topic.
|
|
|
|
|
* \param topic Topic.
|
|
|
|
|
* \return Uniqueid of the topic.
|
|
|
|
|
* \return \c NULL if topic is \c NULL.
|
|
|
|
|
* \retval NULL if topic is \c NULL.
|
|
|
|
|
*/
|
|
|
|
|
const char *stasis_topic_uniqueid(const struct stasis_topic *topic);
|
|
|
|
|
|
|
|
|
@ -556,7 +551,7 @@ const char *stasis_topic_uniqueid(const struct stasis_topic *topic);
|
|
|
|
|
* \brief Return the name of a topic.
|
|
|
|
|
* \param topic Topic.
|
|
|
|
|
* \return Name of the topic.
|
|
|
|
|
* \return \c NULL if topic is \c NULL.
|
|
|
|
|
* \retval NULL if topic is \c NULL.
|
|
|
|
|
*/
|
|
|
|
|
const char *stasis_topic_name(const struct stasis_topic *topic);
|
|
|
|
|
|
|
|
|
@ -564,7 +559,7 @@ const char *stasis_topic_name(const struct stasis_topic *topic);
|
|
|
|
|
* \brief Return the detail of a topic.
|
|
|
|
|
* \param topic Topic.
|
|
|
|
|
* \return Detail of the topic.
|
|
|
|
|
* \return \c NULL if topic is \c NULL.
|
|
|
|
|
* \retval NULL if topic is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
const char *stasis_topic_detail(const struct stasis_topic *topic);
|
|
|
|
@ -598,7 +593,7 @@ void stasis_publish(struct stasis_topic *topic, struct stasis_message *message);
|
|
|
|
|
* The caller of stasis_publish_sync will block until the specified
|
|
|
|
|
* subscriber completes handling of the message.
|
|
|
|
|
*
|
|
|
|
|
* All other subscribers to the topic the \ref stasis_subpscription
|
|
|
|
|
* All other subscribers to the topic the \ref stasis_subscription
|
|
|
|
|
* is subscribed to are also delivered the message; this delivery however
|
|
|
|
|
* happens asynchronously.
|
|
|
|
|
*
|
|
|
|
@ -609,6 +604,7 @@ void stasis_publish_sync(struct stasis_subscription *sub, struct stasis_message
|
|
|
|
|
/*!
|
|
|
|
|
* \brief Callback function type for Stasis subscriptions.
|
|
|
|
|
* \param data Data field provided with subscription.
|
|
|
|
|
* \param sub Subscription published on.
|
|
|
|
|
* \param message Published message.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
@ -639,8 +635,9 @@ void stasis_subscription_cb_noop(void *data, struct stasis_subscription *sub, st
|
|
|
|
|
* \param topic Topic to subscribe to.
|
|
|
|
|
* \param callback Callback function for subscription messages.
|
|
|
|
|
* \param data Data to be passed to the callback, in addition to the message.
|
|
|
|
|
* \param file, lineno, func
|
|
|
|
|
* \return New \ref stasis_subscription object.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
* \since 12
|
|
|
|
|
*
|
|
|
|
|
* \note This callback will receive a callback with a message indicating it
|
|
|
|
@ -669,8 +666,9 @@ struct stasis_subscription *__stasis_subscribe(struct stasis_topic *topic,
|
|
|
|
|
* \param topic Topic to subscribe to.
|
|
|
|
|
* \param callback Callback function for subscription messages.
|
|
|
|
|
* \param data Data to be passed to the callback, in addition to the message.
|
|
|
|
|
* \param file, lineno, func
|
|
|
|
|
* \return New \ref stasis_subscription object.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
* \since 12.8.0
|
|
|
|
|
*
|
|
|
|
|
* \note This callback will receive a callback with a message indicating it
|
|
|
|
@ -768,7 +766,7 @@ enum stasis_subscription_message_formatters stasis_message_type_available_format
|
|
|
|
|
* delivery of the final message.
|
|
|
|
|
*
|
|
|
|
|
* \param subscription Subscription to cancel.
|
|
|
|
|
* \return \c NULL for convenience
|
|
|
|
|
* \retval NULL for convenience
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_subscription *stasis_unsubscribe(
|
|
|
|
@ -823,7 +821,7 @@ int stasis_subscription_is_done(struct stasis_subscription *subscription);
|
|
|
|
|
* a function in a shared module that no longer exists).
|
|
|
|
|
*
|
|
|
|
|
* \param subscription Subscription to cancel.
|
|
|
|
|
* \return \c NULL for convenience
|
|
|
|
|
* \retval NULL for convenience
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_subscription *stasis_unsubscribe_and_join(
|
|
|
|
@ -841,7 +839,7 @@ struct stasis_forward;
|
|
|
|
|
* \param from_topic Topic to forward.
|
|
|
|
|
* \param to_topic Destination topic of forwarded messages.
|
|
|
|
|
* \return New forwarding subscription.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_forward *stasis_forward_all(struct stasis_topic *from_topic,
|
|
|
|
@ -913,7 +911,7 @@ struct stasis_topic_pool;
|
|
|
|
|
* \brief Create a topic pool that routes messages from dynamically generated topics to the given topic
|
|
|
|
|
* \param pooled_topic Topic to which messages will be routed
|
|
|
|
|
* \return the new stasis_topic_pool
|
|
|
|
|
* \return \c NULL on failure
|
|
|
|
|
* \retval NULL on failure
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_topic_pool *stasis_topic_pool_create(struct stasis_topic *pooled_topic);
|
|
|
|
|
|
|
|
|
@ -922,7 +920,7 @@ struct stasis_topic_pool *stasis_topic_pool_create(struct stasis_topic *pooled_t
|
|
|
|
|
* \param pool Pool for which to get the topic
|
|
|
|
|
* \param topic_name Name of the topic to get
|
|
|
|
|
* \return The already stored or newly allocated topic
|
|
|
|
|
* \return \c NULL if the topic was not found and could not be allocated
|
|
|
|
|
* \retval NULL if the topic was not found and could not be allocated
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_topic *stasis_topic_pool_get_topic(struct stasis_topic_pool *pool, const char *topic_name);
|
|
|
|
|
|
|
|
|
@ -931,7 +929,7 @@ struct stasis_topic *stasis_topic_pool_get_topic(struct stasis_topic_pool *pool,
|
|
|
|
|
*
|
|
|
|
|
* \param pool Pool from which to delete the topic
|
|
|
|
|
* \param topic_name Name of the topic to delete in the form of
|
|
|
|
|
* <pool_topic_name>/<topic_name> or just <topic_name>
|
|
|
|
|
* \verbatim [<pool_topic_name>/]<topic_name> \endverbatim
|
|
|
|
|
*
|
|
|
|
|
* \since 13.24
|
|
|
|
|
* \since 15.6
|
|
|
|
@ -1005,7 +1003,7 @@ struct stasis_caching_topic;
|
|
|
|
|
*
|
|
|
|
|
* \param message Message to extract id from.
|
|
|
|
|
* \return String representing the snapshot's id.
|
|
|
|
|
* \return \c NULL if the message_type of the message isn't a handled snapshot.
|
|
|
|
|
* \retval NULL if the message_type of the message isn't a handled snapshot.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
typedef const char *(*snapshot_get_id)(struct stasis_message *message);
|
|
|
|
@ -1115,8 +1113,8 @@ struct stasis_message *stasis_cache_entry_get_remote(struct stasis_cache_entry *
|
|
|
|
|
*
|
|
|
|
|
* \param id_fn Callback to extract the id from a snapshot message.
|
|
|
|
|
*
|
|
|
|
|
* \retval New cache indexed by \a id_fn.
|
|
|
|
|
* \retval \c NULL on error
|
|
|
|
|
* \return New cache indexed by \a id_fn.
|
|
|
|
|
* \retval NULL on error
|
|
|
|
|
*
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
@ -1141,8 +1139,8 @@ struct stasis_cache *stasis_cache_create(snapshot_get_id id_fn);
|
|
|
|
|
* MWI message is the old/new MWI counts accumulated from the local and
|
|
|
|
|
* any remote entities publishing to a mailbox.
|
|
|
|
|
*
|
|
|
|
|
* \retval New cache indexed by \a id_fn.
|
|
|
|
|
* \retval \c NULL on error
|
|
|
|
|
* \return New cache indexed by \a id_fn.
|
|
|
|
|
* \retval NULL on error
|
|
|
|
|
*
|
|
|
|
|
* \since 12.2.0
|
|
|
|
|
*/
|
|
|
|
@ -1162,7 +1160,7 @@ struct stasis_cache *stasis_cache_create_full(snapshot_get_id id_fn, cache_aggre
|
|
|
|
|
* \param cache Backend cache in which to keep snapshots.
|
|
|
|
|
* \return New topic which changes snapshot messages to stasis_cache_update()
|
|
|
|
|
* messages, and forwards all other messages from the original topic.
|
|
|
|
|
* \return \c NULL on error
|
|
|
|
|
* \retval NULL on error
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_caching_topic *stasis_caching_topic_create(
|
|
|
|
@ -1175,7 +1173,7 @@ struct stasis_caching_topic *stasis_caching_topic_create(
|
|
|
|
|
* stasis_subscription_final_message() is received.
|
|
|
|
|
*
|
|
|
|
|
* \param caching_topic Caching topic to unsubscribe
|
|
|
|
|
* \return \c NULL for convenience
|
|
|
|
|
* \retval NULL for convenience
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_caching_topic *stasis_caching_unsubscribe(
|
|
|
|
@ -1189,7 +1187,7 @@ struct stasis_caching_topic *stasis_caching_unsubscribe(
|
|
|
|
|
* opposed to stasis_caching_unsubscribe().
|
|
|
|
|
*
|
|
|
|
|
* \param caching_topic Caching topic to unsubscribe
|
|
|
|
|
* \return \c NULL for convenience
|
|
|
|
|
* \retval NULL for convenience
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_caching_topic *stasis_caching_unsubscribe_and_join(
|
|
|
|
@ -1200,7 +1198,7 @@ struct stasis_caching_topic *stasis_caching_unsubscribe_and_join(
|
|
|
|
|
* \param caching_topic The caching topic.
|
|
|
|
|
* \return The topic that publishes cache update events, along with passthrough
|
|
|
|
|
* events from the underlying topic.
|
|
|
|
|
* \return \c NULL if \a caching_topic is \c NULL.
|
|
|
|
|
* \retval NULL if \a caching_topic is \c NULL.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_topic *stasis_caching_get_topic(
|
|
|
|
@ -1251,7 +1249,7 @@ int stasis_caching_set_filter(struct stasis_caching_topic *caching_topic,
|
|
|
|
|
*
|
|
|
|
|
* \return Message which, when sent to a \ref stasis_caching_topic, will clear
|
|
|
|
|
* the item from the cache.
|
|
|
|
|
* \return \c NULL on error.
|
|
|
|
|
* \retval NULL on error.
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
|
struct stasis_message *stasis_cache_clear_create(struct stasis_message *message);
|
|
|
|
@ -1265,8 +1263,8 @@ struct stasis_message *stasis_cache_clear_create(struct stasis_message *message)
|
|
|
|
|
* \param type Type of message to retrieve.
|
|
|
|
|
* \param id Identity of the snapshot to retrieve.
|
|
|
|
|
*
|
|
|
|
|
* \retval Message from the cache.
|
|
|
|
|
* \retval \c NULL if message is not found.
|
|
|
|
|
* \return Message from the cache.
|
|
|
|
|
* \retval NULL if message is not found.
|
|
|
|
|
*
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
@ -1289,8 +1287,8 @@ struct stasis_message *stasis_cache_get(struct stasis_cache *cache, struct stasi
|
|
|
|
|
* MWI message is the old/new MWI counts accumulated from the local and
|
|
|
|
|
* any remote entities publishing to a mailbox.
|
|
|
|
|
*
|
|
|
|
|
* \retval Message from the cache.
|
|
|
|
|
* \retval \c NULL if message is not found.
|
|
|
|
|
* \return Message from the cache.
|
|
|
|
|
* \retval NULL if message is not found.
|
|
|
|
|
*
|
|
|
|
|
* \since 12.2.0
|
|
|
|
|
*/
|
|
|
|
@ -1304,8 +1302,8 @@ struct stasis_message *stasis_cache_get_by_eid(struct stasis_cache *cache, struc
|
|
|
|
|
* \param type Type of message to retrieve.
|
|
|
|
|
* \param id Identity of the snapshot to retrieve.
|
|
|
|
|
*
|
|
|
|
|
* \retval Container of matching items found.
|
|
|
|
|
* \retval \c NULL if error.
|
|
|
|
|
* \return Container of matching items found.
|
|
|
|
|
* \retval NULL if error.
|
|
|
|
|
*/
|
|
|
|
|
struct ao2_container *stasis_cache_get_all(struct stasis_cache *cache, struct stasis_message_type *type, const char *id);
|
|
|
|
|
|
|
|
|
@ -1315,8 +1313,8 @@ struct ao2_container *stasis_cache_get_all(struct stasis_cache *cache, struct st
|
|
|
|
|
* \param cache The cache to query.
|
|
|
|
|
* \param type Type of message to dump (any type if \c NULL).
|
|
|
|
|
*
|
|
|
|
|
* \retval ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval \c NULL on allocation error
|
|
|
|
|
* \return ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval NULL on allocation error
|
|
|
|
|
*
|
|
|
|
|
* \since 12
|
|
|
|
|
*/
|
|
|
|
@ -1330,8 +1328,8 @@ struct ao2_container *stasis_cache_dump(struct stasis_cache *cache, struct stasi
|
|
|
|
|
* \param type Type of message to dump (any type if \c NULL).
|
|
|
|
|
* \param eid Specific entity id to retrieve. NULL for aggregate.
|
|
|
|
|
*
|
|
|
|
|
* \retval ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval \c NULL on allocation error
|
|
|
|
|
* \return ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval NULL on allocation error
|
|
|
|
|
*/
|
|
|
|
|
struct ao2_container *stasis_cache_dump_by_eid(struct stasis_cache *cache, struct stasis_message_type *type, const struct ast_eid *eid);
|
|
|
|
|
|
|
|
|
@ -1342,8 +1340,8 @@ struct ao2_container *stasis_cache_dump_by_eid(struct stasis_cache *cache, struc
|
|
|
|
|
* \param cache The cache to query.
|
|
|
|
|
* \param type Type of message to dump (any type if \c NULL).
|
|
|
|
|
*
|
|
|
|
|
* \retval ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval \c NULL on allocation error
|
|
|
|
|
* \return ao2_container containing all matches (must be unreffed by caller)
|
|
|
|
|
* \retval NULL on allocation error
|
|
|
|
|
*/
|
|
|
|
|
struct ao2_container *stasis_cache_dump_all(struct stasis_cache *cache, struct stasis_message_type *type);
|
|
|
|
|
|
|
|
|
@ -1399,8 +1397,6 @@ struct ast_multi_object_blob *ast_multi_object_blob_create(struct ast_json *blob
|
|
|
|
|
* \param multi The multi object blob previously created
|
|
|
|
|
* \param type Type code for the object such as channel, bridge, etc.
|
|
|
|
|
* \param object Snapshot object of the type supplied to typename
|
|
|
|
|
*
|
|
|
|
|
* \return Nothing
|
|
|
|
|
*/
|
|
|
|
|
void ast_multi_object_blob_add(struct ast_multi_object_blob *multi, enum stasis_user_multi_object_snapshot_type type, void *object);
|
|
|
|
|
|
|
|
|
@ -1416,8 +1412,6 @@ void ast_multi_object_blob_add(struct ast_multi_object_blob *multi, enum stasis_
|
|
|
|
|
* \param chan The channel to snapshot and publish event to
|
|
|
|
|
* \param type The message type
|
|
|
|
|
* \param blob A json blob to publish with the snapshot
|
|
|
|
|
*
|
|
|
|
|
* \return Nothing
|
|
|
|
|
*/
|
|
|
|
|
void ast_multi_object_blob_single_channel_publish(struct ast_channel *chan, struct stasis_message_type *type, struct ast_json *blob);
|
|
|
|
|
|
|
|
|
|