canyontest

Documentation

Index

• Variables
• func AsLambdaFallback(next lambda.Handler, sender canyon.WorkerSender) lambda.Handler
• func AsServer(next http.Handler, sender canyon.WorkerSender) http.Handler
• func AsWebsocket(next http.Handler, reqCtx events.APIGatewayWebsocketProxyRequestContext, ...) http.Handler
• func AsWorker(next http.Handler) http.Handler
• type Runner
  • func NewRunner(mux http.Handler, _opts ...canyon.Option) *Runner
  • func (r *Runner) Close() error
  • func (r *Runner) DLQReader() io.Reader
  • func (r *Runner) RunError() error

Variables

var DummySQSMessage = events.SQSMessage{
	MessageId:     "00000000-0000-0000-0000-000000000000",
	ReceiptHandle: "00000000/0000000000=",
	Body:          "{}",
	Attributes: map[string]string{
		"ApproximateReceiveCount":          "1",
		"SentTimestamp":                    "0",
		"SenderId":                         "000000000000",
		"ApproximateFirstReceiveTimestamp": "0",
	},
	MessageAttributes: map[string]events.SQSMessageAttribute{
		"Value": {
			StringValue: aws.String("1"),
			DataType:    "Number",
		},
	},
	EventSourceARN: "arn:aws:sqs:ap-northeast-1:123456789012:canyon-test",
	EventSource:    "aws:sqs",
	AWSRegion:      "ap-northeast-1",
}

DummySQSMessage is a dummy sqs message for testing.

Functions

func AsLambdaFallback

func AsLambdaFallback(next lambda.Handler, sender canyon.WorkerSender) lambda.Handler

AsLambdaFallback returns lambda.Handler that embeds logger and sqs message sender in context.

func AsServer

func AsServer(next http.Handler, sender canyon.WorkerSender) http.Handler

AsServer returns http.Handler that embeds logger and sqs message sender in context.

func AsWebsocket

func AsWebsocket(next http.Handler, reqCtx events.APIGatewayWebsocketProxyRequestContext, sender canyon.WorkerSender) http.Handler

AsWebsocket returns http.Handler that embeds logger and sqs message sender in context.

func AsWorker

func AsWorker(next http.Handler) http.Handler

AsServer returns http.Handler that embeds dummy sqs message hader and worker flag in context.

Types

type Runner

type Runner struct {
	URL      string // base URL of form http://ipaddr:port with no trailing slash
	Listener net.Listener
	Stdin    io.WriteCloser
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(mux http.Handler, _opts ...canyon.Option) *Runner

func (*Runner) Close

func (r *Runner) Close() error

func (*Runner) DLQReader

func (r *Runner) DLQReader() io.Reader

func (*Runner) RunError

func (r *Runner) RunError() error