YP-GRPC

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_t *	agt_ypgrpc_get_first_server (void)
	Get the first server entry in serverQ. More...
agt_ypgrpc_server_t *	agt_ypgrpc_get_next_server (const agt_ypgrpc_server_t *server_entry)
	Get the next serverentry in serverQ. More...
agt_ypgrpc_server_t *	agt_ypgrpc_get_server (const xmlChar *name)
	Get a specific gRPC server by name. More...
agt_ypgrpc_stream_t *	agt_ypgrpc_get_first_stream (void)
	Get the first server or client stream entry in streamQ. More...
agt_ypgrpc_stream_t *	agt_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_t *	agt_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

name	name 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

name	of 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_entry

server 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

entry

server 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

name	name 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: