agt_ypgrpc.h

Go to the documentation of this file.

/*
 * Copyright (c) 2021, YumaWorks, Inc., All Rights Reserved.
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
#ifdef WITH_GRPC
#ifndef _H_agt_ypgrpc
#define _H_agt_ypgrpc

/*  FILE: agt_ypgrpc.h
*********************************************************************
*                                                                   *
*                        P U R P O S E                              *
*                                                                   *
*********************************************************************/

/********************************************************************
*                                                                   *
*                  C H A N G E   H I S T O R Y                      *
*                                                                   *
*********************************************************************

date         init     comment
----------------------------------------------------------------------
17Sep21       am      begin
*/

#ifndef _H_agt
#include "agt.h"
#endif

#ifndef _H_agt_cfg
#include "agt_cfg.h"
#endif

#ifndef _H_ncxtypes
#include "ncxtypes.h"
#endif

#ifndef _H_dlq
#include "dlq.h"
#endif

#ifndef _H_status
#include "status.h"
#endif

#ifdef __cplusplus
extern "C" {
#endif

/********************************************************************
*                                                                   *
*                        C O N S T A N T S                          *
*                                                                   *
*********************************************************************/

#define YPGRPC_SERVER_NAME        (const xmlChar *)"server-name"


/********************************************************************
*                                                                   *
*                            T Y P E S                              *
*                                                                   *
*********************************************************************/

typedef struct agt_ypgrpc_stats_t_ {
    uint32                   active_server_streams;

    uint32                   active_client_streams;

    uint32                   total_active_streams;

    uint32                   total_closed_streams;
} agt_ypgrpc_stats_t;


typedef struct agt_ypgrpc_server_t_ {
    dlq_hdr_t                qhdr;

    val_value_t             *server_val;

    xmlChar                 *server_name;

    xmlChar                 *server_address;

    uint16                   server_port;

    xmlChar                 *server_sttime;

    agt_ypgrpc_stats_t       stats;
} agt_ypgrpc_server_t;


typedef struct agt_ypgrpc_stream_t_ {
    dlq_hdr_t                qhdr;

    xmlChar                 *server_name;

    xmlChar                 *name;

    xmlChar                 *sttime;

    xmlChar                 *location;

    boolean                  server_stream;
} agt_ypgrpc_stream_t;


/********************************************************************
*                                                                   *
*                        F U N C T I O N S                          *
*                                                                   *
*********************************************************************/



extern status_t
    agt_ypgrpc_init (void);


extern void
    agt_ypgrpc_cleanup (void);


extern status_t
    agt_ypgrpc_delete_server (const xmlChar *name);


extern status_t
    agt_ypgrpc_delete_streams (const xmlChar *name);


extern agt_ypgrpc_server_t *
    agt_ypgrpc_get_first_server (void);


extern agt_ypgrpc_server_t *
    agt_ypgrpc_get_next_server (const agt_ypgrpc_server_t *server_entry);


extern agt_ypgrpc_server_t *
    agt_ypgrpc_get_server (const xmlChar *name);


extern agt_ypgrpc_stream_t *
    agt_ypgrpc_get_first_stream (void);


extern agt_ypgrpc_stream_t *
    agt_ypgrpc_get_next_stream (const agt_ypgrpc_stream_t *entry);


extern boolean
    agt_ypgrpc_has_server_stream (void);


extern boolean
    agt_ypgrpc_has_client_stream (void);


extern agt_ypgrpc_stats_t *
    agt_ypgrpc_get_total_stats (void);


#ifdef __cplusplus
}  /* end extern 'C' */
#endif

#endif      /* _H_agt_ypgrpc */
#endif // WITH_GRPC