awslambda

Documentation

Index

• type LambdaScheduler
  • func (g *LambdaScheduler) Done()
  • func (g *LambdaScheduler) Inbound()
  • func (g *LambdaScheduler) Timedout()

Types

type LambdaScheduler

type LambdaScheduler struct {
	GrpcHost string
	Lambda   *lambda.Lambda
	Limiter  *rate.Limiter
	Ctx      context.Context
	// contains filtered or unexported fields
}

LambdaScheduler is simple scheduler to invoke long running lambda functions in AWS and Inviting them to connect back by gRPC, bidrectional, to serve multiple requests.

func (*LambdaScheduler) Done

func (g *LambdaScheduler) Done()

Done is called when a task is done

func (*LambdaScheduler) Inbound

func (g *LambdaScheduler) Inbound()

Inbound is called before a new task is added.

func (*LambdaScheduler) Timedout

func (g *LambdaScheduler) Timedout()

Timedout is called when no response was received on time for a task