registration

Documentation

Index

• Constants
• func BuildURL(prefix string, route string) string
• func EnableLogsCollection(id ID, registrationURL string, registrationTimeout time.Duration, ...) error
• type HTTPClient
• type ID
  • func RegisterExtension(runtimeURL string, registrationRoute string, timeout time.Duration) (ID, error)
  • func (i ID) String() string
• type LogSubscriptionPayload
  • func (p *LogSubscriptionPayload) MarshalJSON() ([]byte, error)

Constants

const (

	//HeaderExtID is the header name for the extension identifier
	HeaderExtID = "Lambda-Extension-Identifier"
)

Functions

func BuildURL

func BuildURL(prefix string, route string) string

BuildURL builds and URL with a prefix and a route

func EnableLogsCollection

func EnableLogsCollection(
	id ID,
	registrationURL string,
	registrationTimeout time.Duration,
	logsType string,
	port int,
	collectionRoute string,
	timeout int,
	maxBytes int,
	maxItems int) error

EnableLogsCollection enables logs collections via AWS Logs API

Types

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient represents an Http Client

type ID

type ID string

ID is the extension ID within the AWS Lambda environment.

func RegisterExtension

func RegisterExtension(runtimeURL string, registrationRoute string, timeout time.Duration) (ID, error)

RegisterExtension registers the serverless daemon and subscribe to INVOKE and SHUTDOWN messages. Returns either (the serverless ID assigned by the serverless daemon + the api key as read from the environment) or an error.

func (ID) String

func (i ID) String() string

String returns the string value for this ID.

type LogSubscriptionPayload

type LogSubscriptionPayload struct {
	Buffering     buffering   `json:"buffering"`
	Destination   destination `json:"destination"`
	Types         []string    `json:"types"`
	SchemaVersion string      `json:"schemaVersion"`
}

LogSubscriptionPayload is the payload we send while subscribing to the AWS Logs API

func (*LogSubscriptionPayload) MarshalJSON

func (p *LogSubscriptionPayload) MarshalJSON() ([]byte, error)

MarshalJSON marshals the given LogSubscriptionPayload object