invoker

Documentation

Index

• Constants
• Variables
• type FunctionCloser
• type FunctionInvoker
• type LocalInvoker
  • func (ivk *LocalInvoker) Close()
  • func (ivk *LocalInvoker) InvokeWithContext(ctx context.Context, invokeInput *lambda.InvokeInput, opts ...request.Option) (*lambda.InvokeOutput, error)
• type LocalOutputPayloadSetter

Constants

const (
	ShmSize = 4096
)

Variables

var (
	ErrNodeMismatched = errors.New("node mismatched")
)

Types

type FunctionCloser

type FunctionCloser interface {
	Close()
}

type FunctionInvoker

type FunctionInvoker interface {
	InvokeWithContext(context.Context, *lambda.InvokeInput, ...request.Option) (*lambda.InvokeOutput, error)
}

type LocalInvoker

type LocalInvoker struct {
	SetOutputPayload LocalOutputPayloadSetter
	// contains filtered or unexported fields
}

LocalInvoker Invoke local lambda function simulation Use throttle to simulate Lambda network: https://github.com/sitespeedio/throttle throttle --up 800000 --down 800000 --rtt 1 (800kbit/s, 1ms) throttle stop Use container to simulate Lambda resouce limit

func (*LocalInvoker) Close

func (ivk *LocalInvoker) Close()

func (*LocalInvoker) InvokeWithContext

func (ivk *LocalInvoker) InvokeWithContext(ctx context.Context, invokeInput *lambda.InvokeInput, opts ...request.Option) (*lambda.InvokeOutput, error)

type LocalOutputPayloadSetter

type LocalOutputPayloadSetter func(string, []byte)