runtime

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

type EventPayload struct {
	Subscriber  string        `json:"subscriber,omitempty"`
	Event       *events.Event `json:"event,omitempty"`
	Traceparent string        `json:"traceparent,omitempty"`
}

type GetRDSConnectionArgs struct {
	Cfg       aws.Config
	Endpoint  string
	DbName    string
	SecretArn string
}

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

type HandlerArgs struct {
	// One of the logrus log levels, if omitted defaults to "error"
	LogLevel string

	// File-system path for the proto JSON for the Keel schema
	SchemaPath string
	// File-system path to a JSON file containing the Keel config. Note this should be a JSON file, not YAML.
	ConfigPath string
	// The project name. This needs to be provided as for local environments there won't necessarily be a project name in the config.
	ProjectName string
	// The env. For local environments will be "development" or "test", for deployed environments it's the user-provided env name.
	Env string
	// URL of SQS queue for subscriber events
	EventsQueueURL string
	// URL of SQS queue used to trigger orchestrate flows
	FlowsQueueURL string
	// ARN fo the iam role for scheduling
	SchedulerRoleARN string
	// Full ARN of functions Lambda.
	FunctionsARN string
	// Bucket name used for files and job inputs
	BucketName string
	// List of secret names to looad from SSM
	SecretNames []string
	// Webhook URL to use for sending job run updates
	JobsWebhookURL string
	// If true then tracing data will be exported using the GRPC exporter, otherwise a no-nop exporter will be used.
	TracingEnabled bool

	// RDS config (can be omitted if using an external db or local postgres)
	DBEndpoint  string
	DBName      string
	DBSecretArn string

	// If this is set all AWS operations will be directed to this endpoint by configuring the clients to use it.
	// This is used for mocking the API calls in integration tests
	AWSEndpoint string
}

type JobStatusWebhookPayload struct {
	// The ID provided in the payload
	ID string `json:"id"`
	// The name of the job
	Name        string `json:"name"`
	ProjectName string `json:"projectName"`
	Env         string `json:"env"`
	// One of "processing", "success", or "failed"
	Status string `json:"status"`
	// The OTEL trace ID for the job run
	TraceID   string `json:"traceId"`
	Timestamp string `json:"timestamp"`
}

type LambdaErrorResponse struct {
	ErrorType    string   `json:"errorType,omitempty"`
	ErrorMessage string   `json:"errorMessage,omitempty"`
	Trace        []string `json:"stackTrace,omitempty"`
}

type NoopExporter struct {
}

type ResponseWriter struct {
	StatusCode int
	Body       bytes.Buffer
	HeaderMap  http.Header
}

type RunJobPayload struct {
	// An ID for this job, if provided then it will be sent in the webhook status payload. Will be empty for scheduled jobs.
	ID string `json:"id"`
	// The name of the job to run e.g. MySpecialJob
	Name string `json:"name"`
	// An auth token to use to determine the identity running the job. Will be empty for scheduled jobs.
	Token string `json:"token"`
}