clients

type CommandableLambdaClient ¶

type CommandableLambdaClient struct {
	*LambdaClient
	// contains filtered or unexported fields
}

Abstract client that calls commandable AWS Lambda Functions.

Commandable services are generated automatically for ICommandable objects. Each command is exposed as action determined by "cmd" parameter.

### Configuration parameters ###

- connections:

• discovery_key: (optional) a key to retrieve the connection from IDiscovery
• region: (optional) AWS region

- credentials:

• store_key: (optional) a key to retrieve the credentials from ICredentialStore
• access_id: AWS access/client id
• access_key: AWS access/client id

- 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 - \*:credential-store:\*:\*:1.0 (optional) Credential stores to resolve credentials

See LambdaFunction ¶

### Example ###

type MyLambdaClient struct {
     *CommandableLambdaClient
}
     ...

     func (c* MyLambdaClient) GetData(correlationId string, id string)(result MyDataPage, err error) {

       return c.callCommand(MyDataPageType,
             "get_data",
             correlationId,
             map[string]interface{}{ "id": id })

     }
     ...

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

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

func NewCommandableLambdaClient(name string) *CommandableLambdaClient

func (c *CommandableLambdaClient) CallCommand(prototype reflect.Type, cmd string, correlationId string, params *cdata.AnyValueMap) (result interface{}, err error)

type LambdaClient ¶

type LambdaClient struct {
	// The reference to AWS Lambda Function.
	Lambda *lambda.Lambda
	// The opened flag.
	Opened bool
	// The AWS connection parameters
	Connection *awscon.AwsConnectionParams

	// The dependencies resolver.
	DependencyResolver *cref.DependencyResolver
	// The connection resolver.
	ConnectionResolver *awscon.AwsConnectionResolver
	// The logger.
	Logger *clog.CompositeLogger
	//The performance counters.
	Counters *ccount.CompositeCounters
	// The tracer.
	Tracer *ctrace.CompositeTracer
	// contains filtered or unexported fields
}

Abstract client that calls AWS Lambda Functions.

When making calls "cmd" parameter determines which what action shall be called, while other parameters are passed to the action itself.

### Configuration parameters ###

• connections:
• discovery_key: (optional) a key to retrieve the connection from IDiscovery
• region: (optional) AWS region
• credentials:
• store_key: (optional) a key to retrieve the credentials from ICredentialStore
• access_id: AWS access/client id
• access_key: AWS access/client id
• 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

• \*:credential-store:\*:\*:1.0 (optional) Credential stores to resolve credentials

  See LambdaFunction See CommandableLambdaClient

### Example ###

     type MyLambdaClient struct  {
        *LambdaClient
         ...
	 }
         func (c* MyLambdaClient) getData(correlationId string, id string)(result MyData, err error){

            timing := c.Instrument(correlationId, "myclient.get_data");
            callRes, callErr := c.Call(MyDataPageType ,"get_data" correlationId, map[string]interface{ "id": id })
            timing.EndTiming();
            return callRes, callErr
         }
         ...

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

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

func NewLambdaClient() *LambdaClient

func (c *LambdaClient) Call(prototype reflect.Type, cmd string, correlationId string, params map[string]interface{}) (result interface{}, err error)

func (c *LambdaClient) CallOneWay(prototype reflect.Type, cmd string, correlationId string, params map[string]interface{}) error

func (c *LambdaClient) Close(correlationId string) error

func (c *LambdaClient) Configure(config *cconf.ConfigParams)

func (c *LambdaClient) Instrument(correlationId string, name string) *ccount.CounterTiming

func (c *LambdaClient) Invoke(prototype reflect.Type, invocationType string, cmd string, correlationId string, args map[string]interface{}) (result interface{}, err error)

func (c *LambdaClient) IsOpen() bool

func (c *LambdaClient) Open(correlationId string) error

func (c *LambdaClient) SetReferences(references cref.IReferences)