yumapro  23.10T-6
YumaPro SDK
Loading...
Searching...
No Matches

YumaPro gRPC implementation integrated into the server. More...

Collaboration diagram for YP-GRPC:

Functions

status_t agt_ypgrpc_init (void)
 Initialize the YP-GRPC subsysystem handler. More...
 
void agt_ypgrpc_cleanup (void)
 Cleanup the YP-GRPC Module. More...
 
status_t agt_ypgrpc_delete_server (const xmlChar *name)
 Delete an existing server entry. More...
 
status_t agt_ypgrpc_delete_streams (const xmlChar *name)
 Delete server and client streams associated with this gRPC server. More...
 
agt_ypgrpc_server_tagt_ypgrpc_get_first_server (void)
 Get the first server entry in serverQ. More...
 
agt_ypgrpc_server_tagt_ypgrpc_get_next_server (const agt_ypgrpc_server_t *server_entry)
 Get the next serverentry in serverQ. More...
 
agt_ypgrpc_server_tagt_ypgrpc_get_server (const xmlChar *name)
 Get a specific gRPC server by name. More...
 
agt_ypgrpc_stream_tagt_ypgrpc_get_first_stream (void)
 Get the first server or client stream entry in streamQ. More...
 
agt_ypgrpc_stream_tagt_ypgrpc_get_next_stream (const agt_ypgrpc_stream_t *entry)
 Get the next server or client entry in streamQ. More...
 
boolean agt_ypgrpc_has_server_stream (void)
 Check if there are any Server streams available. More...
 
boolean agt_ypgrpc_has_client_stream (void)
 Check if there are any client streams available. More...
 
agt_ypgrpc_stats_tagt_ypgrpc_get_total_stats (void)
 Get a r/w pointer to the the totals stats. More...
 
status_t agt_ypgrpc_state_init (void)
 Phase 1: Initialize the yumaworks-grpc-mon server instrumentation library. More...
 
void agt_ypgrpc_state_cleanup (void)
 Cleanup the yumaworks-grpc-mon server instrumentation library. More...
 

Detailed Description

YumaPro gRPC implementation integrated into the server.

YumaPro gRPC Monitoring implementation.

The server communicates with a GO subsystem that implements gRPC

YANG instrumentation library. Generated by yangdump-sdk.

Function Documentation

◆ agt_ypgrpc_cleanup()

void agt_ypgrpc_cleanup ( void  )

Cleanup the YP-GRPC Module.

Only present if WITH_GRPC=1

Here is the call graph for this function:

◆ agt_ypgrpc_delete_server()

status_t agt_ypgrpc_delete_server ( const xmlChar *  name)

Delete an existing server entry.

Parameters
namename of entry to modify
Returns
status

◆ agt_ypgrpc_delete_streams()

status_t agt_ypgrpc_delete_streams ( const xmlChar *  name)

Delete server and client streams associated with this gRPC server.

Parameters
nameof gRPC server entry to use
Returns
status

◆ agt_ypgrpc_get_first_server()

agt_ypgrpc_server_t * agt_ypgrpc_get_first_server ( void  )

Get the first server entry in serverQ.

Returns
pointer to the first entry or NULL if empty Q

◆ agt_ypgrpc_get_first_stream()

agt_ypgrpc_stream_t * agt_ypgrpc_get_first_stream ( void  )

Get the first server or client stream entry in streamQ.

Returns
pointer to the first entry or NULL if empty Q
Here is the caller graph for this function:

◆ agt_ypgrpc_get_next_server()

agt_ypgrpc_server_t * agt_ypgrpc_get_next_server ( const agt_ypgrpc_server_t server_entry)

Get the next serverentry in serverQ.

Parameters
server_entryserver entry
Returns
pointer to the first entry or NULL if empty Q

◆ agt_ypgrpc_get_next_stream()

agt_ypgrpc_stream_t * agt_ypgrpc_get_next_stream ( const agt_ypgrpc_stream_t entry)

Get the next server or client entry in streamQ.

Parameters
entryserver or client stream entry
Returns
pointer to the first entry or NULL if empty Q
Here is the caller graph for this function:

◆ agt_ypgrpc_get_server()

agt_ypgrpc_server_t * agt_ypgrpc_get_server ( const xmlChar *  name)

Get a specific gRPC server by name.

Parameters
namename of entry to modify
Returns
server Control Block pointer

◆ agt_ypgrpc_get_total_stats()

agt_ypgrpc_stats_t * agt_ypgrpc_get_total_stats ( void  )

Get a r/w pointer to the the totals stats.

Returns
pointer to the global stats struct

◆ agt_ypgrpc_has_client_stream()

boolean agt_ypgrpc_has_client_stream ( void  )

Check if there are any client streams available.

Let the grpc-state callback to decide if it needs to star AIO processing or can just skip callback since there is no any streams available

Returns
TRUE if there is some stream to process; FALSE is there are no any streams available
Here is the call graph for this function:

◆ agt_ypgrpc_has_server_stream()

boolean agt_ypgrpc_has_server_stream ( void  )

Check if there are any Server streams available.

Let the grpc-state callback to decide if it needs to star AIO processing or can just skip callback since there is no any streams available

Returns
TRUE if there is some stream to process; FALSE is there are no any streams available
Here is the call graph for this function:

◆ agt_ypgrpc_init()

status_t agt_ypgrpc_init ( void  )

Initialize the YP-GRPC subsysystem handler.

Only present if WITH_GRPC=1

Returns
status of the initialization procedure
Here is the call graph for this function:
Here is the caller graph for this function:

◆ agt_ypgrpc_state_cleanup()

void agt_ypgrpc_state_cleanup ( void  )

Cleanup the yumaworks-grpc-mon server instrumentation library.

Called by server when module is unloaded.

Here is the call graph for this function:

◆ agt_ypgrpc_state_init()

status_t agt_ypgrpc_state_init ( void  )

Phase 1: Initialize the yumaworks-grpc-mon server instrumentation library.

Called by server when module is loaded.

Returns
return status. An error will cause the module load to fail.
Here is the call graph for this function:
Here is the caller graph for this function: