client

Documentation

Index

• func OptSetLogger(log log.Modular) func(*Type)
• func OptSetManager(mgr types.Manager) func(*Type)
• func OptSetStats(stats metrics.Type) func(*Type)
• type AWSCredentialsConfig
• type Config
  • func NewConfig() Config
• type Type
  • func New(conf Config, opts ...func(*Type)) (*Type, error)
  • func (l *Type) Invoke(msg types.Message) (types.Message, error)

Functions

func OptSetLogger

func OptSetLogger(log log.Modular) func(*Type)

OptSetLogger sets the logger to use.

func OptSetManager

func OptSetManager(mgr types.Manager) func(*Type)

OptSetManager sets the manager to use.

func OptSetStats

func OptSetStats(stats metrics.Type) func(*Type)

OptSetStats sets the metrics aggregator to use.

Types

type AWSCredentialsConfig

type AWSCredentialsConfig struct {
	ID     string `json:"id" yaml:"id"`
	Secret string `json:"secret" yaml:"secret"`
	Token  string `json:"token" yaml:"token"`
	Role   string `json:"role" yaml:"role"`
}

AWSCredentialsConfig contains configuration params for AWS credentials.

type Config

type Config struct {
	Credentials AWSCredentialsConfig `json:"credentials" yaml:"credentials"`
	Region      string               `json:"region" yaml:"region"`
	Function    string               `json:"function" yaml:"function"`
	TimeoutMS   int64                `json:"timeout_ms" yaml:"timeout_ms"`
	NumRetries  int                  `json:"retries" yaml:"retries"`
	RateLimit   string               `json:"rate_limit" yaml:"rate_limit"`
}

Config contains configuration fields for the Lambda client.

func NewConfig

func NewConfig() Config

NewConfig returns a Config with default values.

type Type

type Type struct {
	// contains filtered or unexported fields
}

Type is a client that performs lambda invocations.

func New

func New(conf Config, opts ...func(*Type)) (*Type, error)

New returns a Lambda client.

func (*Type) Invoke

func (l *Type) Invoke(msg types.Message) (types.Message, error)

Invoke attempts to invoke lambda function with a message as its payload.