CommandableGrpcClient

Implements: GrpcClient

Description

The CommandableGrpcClient class allows you to create clients that call a commandable GRPC service.

Important points

• Commandable services are generated automatically for ICommandable. Each command is exposed as an Invoke method that receives all parameters as args.

Configuration parameters

• connection(s):
  • discovery_key: (optional) a key to retrieve the connection from IDiscovery
  • protocol: connection protocol: http or https
  • host: host name or IP address
  • port: port number
  • uri: resource URI or connection string with all parameters in it
• options:
  • retries: number of retries (default: 3)
  • connect_timeout: connection timeout in milliseconds (default: 10 sec)
  • timeout: invocation timeout in milliseconds (default: 10 sec)

References

• *:discovery:*:*:1.0 - (optional) IDiscovery services
• *:logger:*:*:1.0 - (optional) ILogger components to pass log messages
• *:counters:*:*:1.0 - (optional) ICounters components to pass collected measurements and specify the counter’s source.

Constructors

NewCommandableGrpcClient

Creates a new instance of the client.

NewCommandableGrpcClient(name string) *CommandableGrpcClient

• name: string - service name.

Fields

Methods

CallCommand

Calls a remote method via the GRPC commadable protocol. The call is made via Invoke method and all parameters are sent in args object. The complete route to remote method is defined as serviceName + ‘.’ + name.

(c *CommandableGrpcClient) CallCommand(ctx context.Context, name string, correlationId string, params *cdata.AnyValueMap) (result interface{}, err error)

• ctx: context.Context - operation context
• name: string - name of the command to call.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• params: *cdata.AnyValueMap - command parameters.
• returns: (result interface{}, err error) - feature that receives the result

Examples

type MyCommandableGrpcClient struct {
	*CommandableGrpcClient
   	...
}

func (c * MyCommandableGrpcClient) GetData(ctx context.Context, correlationId string, id string) (result *MyData, err error) {
   	params := cdata.NewEmptyStringValueMap()
   	params.Put("id", id)
	response, calErr := c.CallCommand(MyDataType, "get_mydata_by_id", correlationId, params)
	if calErr != nil {
	    return nil, calErr
	}
	return grpcclients.HandleHttpResponse[*MyData](response, correlationId)
}
...

client := NewMyCommandableGrpcClient();
client.Configure(ctx, cconf.NewConfigParamsFromTuples(
    "connection.protocol", "http",
    "connection.host", "localhost",
    "connection.port", 8080,
));

result, err := client.GetData(ctx, "123", "1")
...