client

package

v3.65.0 Latest Latest Go to latest Published: Mar 7, 2022 License: MIT Imports: 13 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Jeffail/benthos

Links

Open Source Insights

Documentation ¶

Index ¶

func FieldSpecs() docs.FieldSpecs
func OptSetLogger(log log.Modular) func(*Type)
func OptSetManager(mgr types.Manager) func(*Type)
func OptSetStats(stats metrics.Type) func(*Type)
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)
- func (l *Type) InvokeV2(p types.Part) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func FieldSpecs ¶ added in v3.10.0

func FieldSpecs() docs.FieldSpecs

FieldSpecs returns field specs for a lambda client config.

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 Config ¶

type Config struct {
	session.Config `json:",inline" yaml:",inline"`
	Function       string `json:"function" yaml:"function"`
	Timeout        string `json:"timeout" yaml:"timeout"`
	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.

func (*Type) InvokeV2 ¶ added in v3.39.0

func (l *Type) InvokeV2(p types.Part) error

InvokeV2 attempts to invoke a lambda function with a message and replaces its contents with the result on success, or returns an error.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL