69 #define YPGRPC_SERVER_NAME (const xmlChar *)"server-name" 79 typedef struct agt_ypgrpc_stats_t_ {
95 typedef struct agt_ypgrpc_server_t_ {
120 typedef struct agt_ypgrpc_stream_t_ {
status_t agt_ypgrpc_init(void)
Initialize the YP-GRPC subsysystem handler.
Definition: agt_ypgrpc.c:1182
gRPC Server Control block struct
Definition: agt_ypgrpc.h:95
Streams Statistics.
Definition: agt_ypgrpc.h:79
uint32 active_server_streams
total active server streams
Definition: agt_ypgrpc.h:81
dlq provides general double-linked list and queue support:
xmlChar * server_name
gRPC Server name (aka subsystem name)
Definition: agt_ypgrpc.h:103
agt_ypgrpc_server_t * agt_ypgrpc_get_next_server(const agt_ypgrpc_server_t *server_entry)
Get the next serverentry in serverQ.
Definition: agt_ypgrpc.c:1348
xmlChar * server_name
RPC Server name (aka subsystem name)
Definition: agt_ypgrpc.h:125
boolean agt_ypgrpc_has_server_stream(void)
Check if there are any Server streams available.
Definition: agt_ypgrpc.c:1448
agt_ypgrpc_stats_t * agt_ypgrpc_get_total_stats(void)
Get a r/w pointer to the the totals stats.
Definition: agt_ypgrpc.c:1504
agt_ypgrpc_stats_t stats
gRPC Statistic information about Streams for this server
Definition: agt_ypgrpc.h:115
xmlChar * server_sttime
gRPC Server Start Time value
Definition: agt_ypgrpc.h:112
agt_ypgrpc_server_t * agt_ypgrpc_get_server(const xmlChar *name)
Get a specific gRPC server by name.
Definition: agt_ypgrpc.c:1372
gRPC Server and Client Streams Control block struct
Definition: agt_ypgrpc.h:120
xmlChar * location
Contains a URL that represents the RPC that uses this client or server stream.
Definition: agt_ypgrpc.h:136
uint32 total_closed_streams
total closed streams
Definition: agt_ypgrpc.h:90
boolean agt_ypgrpc_has_client_stream(void)
Check if there are any client streams available.
Definition: agt_ypgrpc.c:1478
val_value_t * server_val
gRPC Server val_value tree from the subsystem
Definition: agt_ypgrpc.h:100
agt_ypgrpc_stream_t * agt_ypgrpc_get_next_stream(const agt_ypgrpc_stream_t *entry)
Get the next server or client entry in streamQ.
Definition: agt_ypgrpc.c:1422
YANG module data structures Many internal representations of YANG module constructs.
xmlChar * server_address
gRPC Server Adress
Definition: agt_ypgrpc.h:106
uint32 total_active_streams
total active streams
Definition: agt_ypgrpc.h:87
agt_ypgrpc_stream_t * agt_ypgrpc_get_first_stream(void)
Get the first server or client stream entry in streamQ.
Definition: agt_ypgrpc.c:1394
Manage Server configuration edit transactions.
uint16 server_port
gRPC Server Port
Definition: agt_ypgrpc.h:109
one value to match one type
Definition: val.h:870
status_t
global error return code
Definition: status_enum.h:186
Multi-Protocol Network Management Server.
void agt_ypgrpc_cleanup(void)
Cleanup the YP-GRPC Module.
Definition: agt_ypgrpc.c:1234
uint32 active_client_streams
total active client streams
Definition: agt_ypgrpc.h:84
status_t agt_ypgrpc_delete_streams(const xmlChar *name)
Delete server and client streams associated with this gRPC server.
Definition: agt_ypgrpc.c:1297
Global error messages for status code enumerations.
agt_ypgrpc_server_t * agt_ypgrpc_get_first_server(void)
Get the first server entry in serverQ.
Definition: agt_ypgrpc.c:1320
status_t agt_ypgrpc_delete_server(const xmlChar *name)
Delete an existing server entry.
Definition: agt_ypgrpc.c:1272
xmlChar * sttime
Indicates the time the client or server stream was created.
Definition: agt_ypgrpc.h:131
boolean server_stream
TRUE if current stream if a server stream; FALSE for client stream.
Definition: agt_ypgrpc.h:141
xmlChar * name
Name of a client or server stream.
Definition: agt_ypgrpc.h:128