extension

Documentation

Index

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

Variables

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")
)

Types

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

func NewManager

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