extension

package

v0.0.0-...-65a99ba Latest Latest Go to latest Published: May 2, 2024 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/atlassian/gostatsd

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Manager
- func NewManager(lambdaDomain string, lambdaFileName string, log logrus.FieldLogger, ...) Manager
type ManagerOpt
- func WithManualFlushEnabled(fc flush.Coordinator, telemetryServerAddr string) ManagerOpt
type Server

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrFailedRegistration          = errors.New("extension failed to register with lambda")
	ErrIssueProgress               = errors.New("unable continue execution")
	ErrServerEarlyExit             = errors.New("server has shutdown early without cause")
	ErrFailedTelemetrySubscription = errors.New("extension failed to subscribe to lambda telemetry API")
)

Functions ¶

This section is empty.

Types ¶

type Manager ¶

type Manager interface {
	Run(ctx context.Context, server Server) error
}

Manager ensures that the lifetime management of the lambda

func NewManager ¶

func NewManager(lambdaDomain string, lambdaFileName string, log logrus.FieldLogger, opts ...ManagerOpt) Manager

type ManagerOpt ¶

type ManagerOpt func(*manager)

func WithManualFlushEnabled ¶

func WithManualFlushEnabled(fc flush.Coordinator, telemetryServerAddr string) ManagerOpt

WithManualFlushEnabled enables a flush per invocation, it requires a flush.Coordinator to trigger the flush and will register it as a telemetry server callback. A server address will also need to be provided for the server to run on.

type Server ¶

type Server interface {
	Run(ctx context.Context) error
}

Server is an interface to the gostatsd.Server type, the main purpose here is to allow for mocks to be used throughout testing and reduce the amount of set up code to test

Source Files ¶

View all Source files

manager.go

Directories ¶

Path	Synopsis
api Package api defines the interaction that is done between the aditional runtime (the current running extension) and the main business logic function running along aside it.	Package api defines the interaction that is done between the aditional runtime (the current running extension) and the main business logic function running along aside it.
telemetry Package telemetry defines the apis and server required to interact with the subscribe to the Telemetry API for AWS lambdas.	Package telemetry defines the apis and server required to interact with the subscribe to the Telemetry API for AWS lambdas.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL