local_lambda

Documentation

Index

• func StartAll(logger *zap.Logger, config configuration.Configuration, ...) error
• type Coordinator
  • func New(logger *zap.Logger, lambdaClient lambdaiface.LambdaAPI) *Coordinator
  • func (c *Coordinator) Run(conf configuration.Configuration) error
• type Subprocess
  • func NewSubprocess(path string, env []string) *Subprocess
  • func (s *Subprocess) Start() error
  • func (s *Subprocess) Tail(logger *zap.Logger) (*errgroup.Group, error)
  • func (s *Subprocess) Wait() error

Functions

func StartAll

func StartAll(logger *zap.Logger, config configuration.Configuration, provider awslambda.ConfigurationProvider) error

Types

type Coordinator

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

func New

func New(logger *zap.Logger, lambdaClient lambdaiface.LambdaAPI) *Coordinator

func (*Coordinator) Run

func (c *Coordinator) Run(conf configuration.Configuration) error

type Subprocess

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

func NewSubprocess

func NewSubprocess(path string, env []string) *Subprocess

func (*Subprocess) Start

func (s *Subprocess) Start() error

func (*Subprocess) Tail

func (s *Subprocess) Tail(logger *zap.Logger) (*errgroup.Group, error)

func (*Subprocess) Wait

func (s *Subprocess) Wait() error