Function newRuntimeAPIClient

lambda/runtime_api_client.go:44–56

(address string)

}

func newRuntimeAPIClient(address string) *runtimeAPIClient {
	client := &http.Client{
		Timeout: 0, // connections to the runtime API are never expected to time out
	}
	endpoint := "http://" + address + "/" + apiVersion + "/runtime/invocation/"
	userAgent := "aws-lambda-go/" + runtime.Version()
	pool := &sync.Pool{
		New: func() interface{} {
			return bytes.NewBuffer(nil)
		},
	}
	return &runtimeAPIClient{endpoint, userAgent, client, pool}
}

type invoke struct {
	id      string