lambdaapp

type Controller struct {
	// Name is the controller's, in log lines.
	Name string
	// Open assembles the controller.
	Open func(ctx context.Context) (Pass, error)
	Log  *slog.Logger
	// Unknown says an error is the controller not running that target.
	Unknown func(error) bool
}

type ExportsResult struct {
	Kind string `json:"kind"`
	// Outcome is "ran", "none" (no export is declared) or "failed".
	Outcome   string `json:"outcome"`
	Exports   int    `json:"exports"`
	Done      int    `json:"done"`
	Contended int    `json:"contended"`
	Failed    int    `json:"failed"`
}

type Function struct {
	Role    string
	Handler Handler
	// Flush sends what telemetry holds; the platform freezes the process when
	// an invocation returns, and a batch waiting for its timer waits for the
	// next invocation.
	Flush func(context.Context)
	// Close releases what the role holds, at shutdown.
	Close func()
}

type HTTP struct {
	// contains filtered or unexported fields
}

type Handler interface {
	Handle(ctx context.Context, payload json.RawMessage) (any, error)
}

type ParameterAPI interface {
	GetParameters(ctx context.Context, in *ssm.GetParametersInput, opts ...func(*ssm.Options)) (*ssm.GetParametersOutput, error)
}

type Pass interface {
	// Pass runs the target's pass under its lease; false, with no error, means
	// another runner holds it.
	Pass(ctx context.Context, target string, unsafeLocal bool) (ran bool, err error)
	// Close flushes what the pass recorded.
	Close() error
}

type RefreshResult struct {
	Kind       string `json:"kind"`
	Workspaces int    `json:"workspaces"`
	Ran        int    `json:"ran"`
	Contended  int    `json:"contended"`
	Failed     int    `json:"failed"`
}

type Result struct {
	Kind    string `json:"kind"`
	Target  string `json:"target"`
	Outcome string `json:"outcome"`
}

type SecretFile struct {
	Parameter string `json:"parameter"`
	Path      string `json:"path"`
}