stdlambda

Documentation

Overview

Package stdlambda implements re-usable logic for AWS Lambda that is not tied to fx.

Index

• type HandlerFunc
  • func (f HandlerFunc) Invoke(ctx context.Context, payload []byte) ([]byte, error)
• type Invoker
  • func NewInvoker[I, O any](lambdaClient Lambda, functionName string) *Invoker[I, O]
  • func (inv Invoker[I, O]) Invoke(ctx context.Context, input I) (output *O, err error)
• type JSONHandlerFunc
  • func (f JSONHandlerFunc[I, O]) Invoke(ctx context.Context, payload []byte) ([]byte, error)
• type Lambda
• type ProtoInvoker
  • func NewProtoInvoker[I, O any, IP interface{ ... }, OP interface{ ... }](lambdaClient Lambda, functionName string) *ProtoInvoker[I, O, IP, OP]
  • func (inv ProtoInvoker[I, O, IP, OP]) Invoke(ctx context.Context, input IP) (output OP, err error)

Types

type HandlerFunc

type HandlerFunc func(ctx context.Context, payload []byte) ([]byte, error)

HandlerFunc implements lambda.Handler, similar to http.HandlerFunc.

func (HandlerFunc) Invoke

func (f HandlerFunc) Invoke(ctx context.Context, payload []byte) ([]byte, error)

type Invoker

type Invoker[I, O any] struct {
	// contains filtered or unexported fields
}

Invoker invokes a lambda using "I" as the input type and "O" as the output type.

func NewInvoker

func NewInvoker[I, O any](lambdaClient Lambda, functionName string) *Invoker[I, O]

NewInvoker inits the invoker.

func (Invoker[I, O]) Invoke

func (inv Invoker[I, O]) Invoke(ctx context.Context, input I) (output *O, err error)

Invoke invokes the lambda function.

type JSONHandlerFunc

type JSONHandlerFunc[
	I, O any] func(ctx context.Context, payload I) (O, error)

JSONHandlerFunc implements lambda.Handler but decodes and encodes as JSON.

func (JSONHandlerFunc[I, O]) Invoke

func (f JSONHandlerFunc[I, O]) Invoke(ctx context.Context, payload []byte) ([]byte, error)

type Lambda

type Lambda interface {
	Invoke(ctx context.Context, params *lambda.InvokeInput, optFns ...func(*lambda.Options)) (*lambda.InvokeOutput, error)
}

Lambda is implemented by the official SDK's client.

type ProtoInvoker

type ProtoInvoker[I, O any, IP interface {
	*I
	proto.Message
}, OP interface {
	*O
	proto.Message
}] struct {
	// contains filtered or unexported fields
}

ProtoInvoker invokes lambdas that use protobuf encoding.

func NewProtoInvoker

func NewProtoInvoker[I, O any, IP interface {
	*I
	proto.Message
}, OP interface {
	*O
	proto.Message
}](lambdaClient Lambda, functionName string) *ProtoInvoker[I, O, IP, OP]

NewProtoInvoker inits the invoker.

func (ProtoInvoker[I, O, IP, OP]) Invoke

func (inv ProtoInvoker[I, O, IP, OP]) Invoke(ctx context.Context, input IP) (output OP, err error)

Invoke invokes the lambda function but encodes it using protobuf JSON.