CommandableLambdaClient

Description

Commandable services are generated automatically for ICommandable. Each command is exposed as an action determined by the “cmd” parameter.

Configuration parameters

• connections:
  • discovery_key: (optional) key to retrieve the connection from IDiscovery
  • region: (optional) AWS region
• credentials:
  • store_key: (optional) key to retrieve the credentials from ICredentialStore
  • access_id: AWS access/client id
  • access_key: AWS access/client key
• options:
  • connect_timeout: (optional) connection timeout in milliseconds (default: 10 sec)

References

• *:logger:*:*:1.0 - (optional) ILogger components to pass log messages.
• *:counters:*:*:1.0 - (optional) ICounters components to pass collected measurements.
• *:discovery:*:*:1.0 - (optional) IDiscovery services to resolve connection.
• *:icredential-store:*:*:1.0 - (optional) Credential stores to resolve credentials.

Constructors

NewCommandableLambdaClient

Creates a new instance of this client.

NewCommandableLambdaClient(name string) *CommandableLambdaClient

• name: string - service’s name.

Methods

CallCommand

Calls a remote action in AWS Lambda function. The name of the action is added as “cmd” parameter to the action parameters.

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

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

Examples

type MyLambdaClient struct {
    *CommandableLambdaClient
}

...

 func (c* MyLambdaClient) GetData(ctx context.Context, correlationId string, id string)(result DataPage[MyData], err error) {

    valVal, err := c.callCommand(ctx,
          "get_data",
          correlationId,
          map[string]any{ "id": id })
    if calErr != nil {
       return nil, calErr
    }

    defer timing.EndTiming(ctx, err)

    return awsclient.HandleLambdaResponse[cdata.DataPage[MyData]](calValue)
}

...

client := NewMyLambdaClient();
client.Configure(context.Background(), NewConfigParamsFromTuples(
    "connection.region", "us-east-1",
    "connection.access_id", "XXXXXXXXXXX",
    "connection.access_key", "XXXXXXXXXXX",
    "connection.arn", "YYYYYYYYYYYYY"
))

res, err := client.GetData(context.Background(), "123", "1")
...

See also

• LambdaFunction