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