dal

May 2, 2024

Changes in this version

+ const AsyncCallOriginCron

+ const AsyncCallOriginFSM

+ const AsyncCallOriginPubSub

+ type AsyncCall struct

+ ID int64

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request json.RawMessage

+ Verb schema.Ref

+ type AsyncCallOrigin sql.AsyncCallOrigin

type DAL

+ func (d *DAL) CompleteAsyncCall(ctx context.Context, call *AsyncCall, response []byte, ...) error

+ func (d *DAL) LoadAsyncCall(ctx context.Context, id int64) (*AsyncCall, error)

May 1, 2024

Changes in this version

+ var ErrConstraint = errors.New("constraint violation")

type DAL

+ func (d *DAL) AcquireAsyncCall(ctx context.Context) (*Lease, error)

+ func (d *DAL) SendFSMEvent(ctx context.Context, name, executionKey, destinationState string, ...) error

Apr 29, 2024

Changes in this version

type DAL

+ func (d *DAL) AcquireLease(ctx context.Context, key leases.Key, ttl time.Duration) (leases.Lease, error)

+ func (d *DAL) ExpireLeases(ctx context.Context) error

+ type Lease struct

+ func (l *Lease) Release() error

+ func (l *Lease) String() string

Apr 17, 2024

Changes in this version

type DAL

+ func (d *DAL) GetActiveControllers(ctx context.Context) ([]Controller, error)

Apr 12, 2024

Changes in this version

+ const JobStateExecuting

+ const JobStateIdle

+ type AttemptedCronJob struct

+ DidStartExecution bool

+ HasMinReplicas bool

+ type CronJob struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ NextExecution time.Time

+ Ref schema.Ref

+ Schedule string

+ StartTime time.Time

+ State JobState

type DAL

+ func (d *DAL) CreateRequest(ctx context.Context, key model.RequestKey, addr string) error

+ func (d *DAL) EndCronJob(ctx context.Context, job CronJob, next time.Time) (CronJob, error)

+ func (d *DAL) GetCronJobs(ctx context.Context) ([]CronJob, error)

+ func (d *DAL) GetStaleCronJobs(ctx context.Context, duration time.Duration) ([]CronJob, error)

+ func (d *DAL) StartCronJobs(ctx context.Context, jobs []CronJob) (attemptedJobs []AttemptedCronJob, err error)

+ type JobState string

Apr 10, 2024

Changes in this version

type CallEvent

+ RequestKey optional.Option[model.RequestKey]

type LogEvent

+ RequestKey optional.Option[model.RequestKey]

Apr 9, 2024

Changes in this version

type DAL

+ func (d *DAL) GetDeploymentsWithMinReplicas(ctx context.Context) ([]Deployment, error)

Apr 4, 2024

Changes in this version

type Deployment

+ Replicas optional.Option[int]

Mar 15, 2024

Changes in this version

type CallEvent

+ DeploymentKey model.DeploymentKey

type Deployment

+ Key model.DeploymentKey

type DeploymentCreatedEvent

+ DeploymentKey model.DeploymentKey

type DeploymentUpdatedEvent

+ DeploymentKey model.DeploymentKey

type LogEvent

+ DeploymentKey model.DeploymentKey

Jan 12, 2024

Changes in this version

type DAL

+ func (d *DAL) GetControllers(ctx context.Context, allControllers bool) ([]Controller, error)

Dec 5, 2023

Changes in this version

type IngressRoute

+ Deployment model.DeploymentName

+ Path string

Dec 4, 2023

Changes in this version

type DAL

+ func (d *DAL) GetActiveDeploymentSchemas(ctx context.Context) ([]*schema.Module, error)

Nov 28, 2023

Changes in this version

type CallEvent

+ Stack types.Option[string]

type LogEvent

+ Stack types.Option[string]

Nov 3, 2023

Changes in this version

+ const ControllerStateDead

+ const ControllerStateLive

+ const EventTypeCall

+ const EventTypeDeploymentCreated

+ const EventTypeDeploymentUpdated

+ const EventTypeLog

+ const RequestOriginCron

+ const RequestOriginIngress

+ const RequestOriginPubsub

+ const RunnerStateAssigned

+ const RunnerStateDead

+ const RunnerStateIdle

+ const RunnerStateReserved

+ var ErrConflict = errors.New("conflict")

+ var ErrNotFound = errors.New("not found")

+ func WithReservation(ctx context.Context, reservation Reservation, fn func() error) error

+ type CallEvent struct

+ DeploymentName model.DeploymentName

+ DestVerb schema.VerbRef

+ Duration time.Duration

+ Error types.Option[string]

+ ID int64

+ Request []byte

+ RequestName types.Option[model.RequestName]

+ Response []byte

+ SourceVerb types.Option[schema.VerbRef]

+ Time time.Time

+ func (e *CallEvent) GetID() int64

+ type Controller struct

+ Endpoint string

+ Key model.ControllerKey

+ State ControllerState

+ type ControllerState string

+ func ControllerStateFromProto(state ftlv1.ControllerState) ControllerState

+ func (s ControllerState) ToProto() ftlv1.ControllerState

+ type DAL struct

+ DeploymentChanges *pubsub.Topic[DeploymentNotification]

+ func New(ctx context.Context, pool *pgxpool.Pool) (*DAL, error)

+ func (d *DAL) CreateArtefact(ctx context.Context, content []byte) (digest sha256.SHA256, err error)

+ func (d *DAL) CreateDeployment(ctx context.Context, language string, schema *schema.Module, ...) (key model.DeploymentName, err error)

+ func (d *DAL) CreateIngressRequest(ctx context.Context, route, addr string) (model.RequestName, error)

+ func (d *DAL) DeregisterRunner(ctx context.Context, key model.RunnerKey) error

+ func (d *DAL) ExpireRunnerClaims(ctx context.Context) (int64, error)

+ func (d *DAL) GetActiveDeployments(ctx context.Context) ([]Deployment, error)

+ func (d *DAL) GetActiveRunners(ctx context.Context) ([]Runner, error)

+ func (d *DAL) GetDeployment(ctx context.Context, name model.DeploymentName) (*model.Deployment, error)

+ func (d *DAL) GetDeploymentsNeedingReconciliation(ctx context.Context) ([]Reconciliation, error)

+ func (d *DAL) GetIdleRunners(ctx context.Context, limit int, labels model.Labels) ([]Runner, error)

+ func (d *DAL) GetIngressRoutes(ctx context.Context, method string, path string) ([]IngressRoute, error)

+ func (d *DAL) GetMissingArtefacts(ctx context.Context, digests []sha256.SHA256) ([]sha256.SHA256, error)

+ func (d *DAL) GetProcessList(ctx context.Context) ([]Process, error)

+ func (d *DAL) GetRoutingTable(ctx context.Context, modules []string) (map[string][]Route, error)

+ func (d *DAL) GetRunner(ctx context.Context, runnerKey model.RunnerKey) (Runner, error)

+ func (d *DAL) GetRunnerState(ctx context.Context, runnerKey model.RunnerKey) (RunnerState, error)

+ func (d *DAL) GetRunnersForDeployment(ctx context.Context, deployment model.DeploymentName) ([]Runner, error)

+ func (d *DAL) GetStatus(ctx context.Context, ...) (Status, error)

+ func (d *DAL) InsertCallEvent(ctx context.Context, call *CallEvent) error

+ func (d *DAL) InsertLogEvent(ctx context.Context, log *LogEvent) error

+ func (d *DAL) KillStaleControllers(ctx context.Context, age time.Duration) (int64, error)

+ func (d *DAL) KillStaleRunners(ctx context.Context, age time.Duration) (int64, error)

+ func (d *DAL) QueryEvents(ctx context.Context, limit int, filters ...EventFilter) ([]Event, error)

+ func (d *DAL) ReplaceDeployment(ctx context.Context, newDeploymentName model.DeploymentName, minReplicas int) (err error)

+ func (d *DAL) ReserveRunnerForDeployment(ctx context.Context, deployment model.DeploymentName, ...) (Reservation, error)

+ func (d *DAL) SetDeploymentReplicas(ctx context.Context, key model.DeploymentName, minReplicas int) error

+ func (d *DAL) UpsertController(ctx context.Context, key model.ControllerKey, addr string) (int64, error)

+ func (d *DAL) UpsertModule(ctx context.Context, language, name string) (err error)

+ func (d *DAL) UpsertRunner(ctx context.Context, runner Runner) error

+ type Deployment struct

+ CreatedAt time.Time

+ Labels model.Labels

+ Language string

+ MinReplicas int

+ Module string

+ Name model.DeploymentName

+ Schema *schema.Module

+ func (d Deployment) String() string

+ type DeploymentArtefact struct

+ Digest sha256.SHA256

+ Executable bool

+ Path string

+ func DeploymentArtefactFromProto(in *ftlv1.DeploymentArtefact) (DeploymentArtefact, error)

+ func (d *DeploymentArtefact) ToProto() *ftlv1.DeploymentArtefact

+ type DeploymentCreatedEvent struct

+ DeploymentName model.DeploymentName

+ ID int64

+ Language string

+ MinReplicas int

+ ModuleName string

+ ReplacedDeployment types.Option[model.DeploymentName]

+ Time time.Time

+ func (e *DeploymentCreatedEvent) GetID() int64

+ type DeploymentNotification = Notification[Deployment, model.DeploymentName, *model.DeploymentName]

+ type DeploymentUpdatedEvent struct

+ DeploymentName model.DeploymentName

+ ID int64

+ MinReplicas int

+ PrevMinReplicas int

+ Time time.Time

+ func (e *DeploymentUpdatedEvent) GetID() int64

+ type Event interface

+ GetID func() int64

+ type EventFilter func(query *eventFilter)

+ func FilterCall(sourceModule types.Option[string], destModule string, ...) EventFilter

+ func FilterDeployments(deploymentNames ...model.DeploymentName) EventFilter

+ func FilterDescending() EventFilter

+ func FilterIDRange(higherThan, lowerThan int64) EventFilter

+ func FilterLogLevel(level log.Level) EventFilter

+ func FilterRequests(requestNames ...model.RequestName) EventFilter

+ func FilterTimeRange(olderThan, newerThan time.Time) EventFilter

+ func FilterTypes(types ...sql.EventType) EventFilter

+ type EventType = sql.EventType

+ type IngressRoute struct

+ Endpoint string

+ Module string

+ Runner model.RunnerKey

+ Verb string

+ type IngressRouteEntry struct

+ Deployment model.DeploymentName

+ Method string

+ Module string

+ Path string

+ Verb string

+ type IngressRoutingEntry struct

+ Method string

+ Path string

+ Verb string

+ type LogEvent struct

+ Attributes map[string]string

+ DeploymentName model.DeploymentName

+ Error types.Option[string]

+ ID int64

+ Level int32

+ Message string

+ RequestName types.Option[model.RequestName]

+ Time time.Time

+ func (e *LogEvent) GetID() int64

+ type Notification struct

+ Deleted types.Option[Key]

+ Message types.Option[T]

+ func (n Notification[T, Key, KeyP]) String() string

+ type NotificationPayload interface

+ type Process struct

+ Deployment model.DeploymentName

+ Labels model.Labels

+ MinReplicas int

+ Runner types.Option[ProcessRunner]

+ type ProcessRunner struct

+ Endpoint string

+ Key model.RunnerKey

+ Labels model.Labels

+ type Reconciliation struct

+ AssignedReplicas int

+ Deployment model.DeploymentName

+ Language string

+ Module string

+ RequiredReplicas int

+ type RequestOrigin string

+ type Reservation interface

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

+ Runner func() Runner

+ type Route struct

+ Deployment model.DeploymentName

+ Endpoint string

+ Module string

+ Runner model.RunnerKey

+ func (r Route) String() string

+ type Runner struct

+ Deployment types.Option[model.DeploymentName]

+ Endpoint string

+ Key model.RunnerKey

+ Labels model.Labels

+ Module types.Option[string]

+ ReservationTimeout types.Option[time.Duration]

+ State RunnerState

+ type RunnerState string

+ func RunnerStateFromProto(state ftlv1.RunnerState) RunnerState

+ func (s RunnerState) ToProto() ftlv1.RunnerState

+ type Status struct

+ Controllers []Controller

+ Deployments []Deployment

+ IngressRoutes []IngressRouteEntry

+ Routes []Route

+ Runners []Runner