broker.h

Go to the documentation of this file.

// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

#ifndef BROKER_H
#define BROKER_H

typedef struct BROKER_HANDLE_DATA_TAG* BROKER_HANDLE;

#include "azure_c_shared_utility/macro_utils.h"
#include "message.h"
#include "module.h"
#include "gateway_export.h"

#ifdef __cplusplus
#include <cstddef>
extern "C"
{
#else
#include <stddef.h>
#endif

typedef struct BROKER_LINK_DATA_TAG {
    MODULE_HANDLE module_source_handle;
    MODULE_HANDLE module_sink_handle;
} BROKER_LINK_DATA;

#define BROKER_RESULT_VALUES \
    BROKER_OK, \
    BROKER_ERROR, \
    BROKER_ADD_LINK_ERROR, \
    BROKER_REMOVE_LINK_ERROR, \
    BROKER_INVALIDARG

DEFINE_ENUM(BROKER_RESULT, BROKER_RESULT_VALUES);

GATEWAY_EXPORT BROKER_HANDLE Broker_Create(void);

GATEWAY_EXPORT void Broker_IncRef(BROKER_HANDLE broker);

GATEWAY_EXPORT void Broker_DecRef(BROKER_HANDLE broker);

GATEWAY_EXPORT BROKER_RESULT Broker_Publish(BROKER_HANDLE broker, MODULE_HANDLE source, MESSAGE_HANDLE message);

GATEWAY_EXPORT BROKER_RESULT Broker_AddModule(BROKER_HANDLE broker, const MODULE* module);

GATEWAY_EXPORT BROKER_RESULT Broker_RemoveModule(BROKER_HANDLE broker, const MODULE* module);

GATEWAY_EXPORT BROKER_RESULT Broker_AddLink(BROKER_HANDLE broker, const BROKER_LINK_DATA* link);

GATEWAY_EXPORT BROKER_RESULT Broker_RemoveLink(BROKER_HANDLE broker, const BROKER_LINK_DATA* link);

GATEWAY_EXPORT void Broker_Destroy(BROKER_HANDLE broker);

#ifdef __cplusplus
}
#endif


#endif /*BROKER_H*/