sql

Aug 30, 2024

Changes in this version

type Querier

+ GetZombieAsyncCalls func(ctx context.Context, limit int32) ([]AsyncCall, error)

type Queries

+ func (q *Queries) GetZombieAsyncCalls(ctx context.Context, limit int32) ([]AsyncCall, error)

Aug 23, 2024

Changes in this version

type CreateAsyncCallParams

+ ScheduledAt time.Time

type CronJob

+ LastAsyncCallID optional.Option[int64]

+ LastExecution optional.Option[time.Time]

+ type GetCronJobByKeyRow struct

+ CronJob CronJob

+ Deployment Deployment

+ type GetUnscheduledCronJobsRow struct

+ CronJob CronJob

+ Deployment Deployment

type Querier

+ GetCronJobByKey func(ctx context.Context, key model.CronJobKey) (GetCronJobByKeyRow, error)

+ GetUnscheduledCronJobs func(ctx context.Context, startTime time.Time) ([]GetUnscheduledCronJobsRow, error)

+ IsCronJobPending func(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)

+ UpdateCronJobExecution func(ctx context.Context, arg UpdateCronJobExecutionParams) error

type Queries

+ func (q *Queries) GetCronJobByKey(ctx context.Context, key model.CronJobKey) (GetCronJobByKeyRow, error)

+ func (q *Queries) GetUnscheduledCronJobs(ctx context.Context, startTime time.Time) ([]GetUnscheduledCronJobsRow, error)

+ func (q *Queries) IsCronJobPending(ctx context.Context, key model.CronJobKey, startTime time.Time) (bool, error)

+ func (q *Queries) UpdateCronJobExecution(ctx context.Context, arg UpdateCronJobExecutionParams) error

+ type UpdateCronJobExecutionParams struct

+ Key model.CronJobKey

+ LastAsyncCallID int64

+ LastExecution time.Time

+ NextExecution time.Time

Aug 21, 2024

Changes in this version

type EncryptionKey

+ VerifyAsync encryption.OptionalEncryptedAsyncColumn

+ VerifyTimeline encryption.OptionalEncryptedTimelineColumn

+ type GetOnlyEncryptionKeyRow struct

+ Key []byte

+ VerifyAsync encryption.OptionalEncryptedAsyncColumn

+ VerifyTimeline encryption.OptionalEncryptedTimelineColumn

type Querier

+ UpdateEncryptionVerification func(ctx context.Context, verifyTimeline encryption.OptionalEncryptedTimelineColumn, ...) error

type Queries

+ func (q *Queries) UpdateEncryptionVerification(ctx context.Context, verifyTimeline encryption.OptionalEncryptedTimelineColumn, ...) error

Aug 15, 2024

Changes in this version

+ type FsmNextEvent struct

+ CreatedAt time.Time

+ FsmInstanceID int64

+ ID int64

+ NextState schema.RefKey

+ Request []byte

+ RequestType Type

type Querier

+ PopNextFSMEvent func(ctx context.Context, fsm schema.RefKey, instanceKey string) (FsmNextEvent, error)

+ SetNextFSMEvent func(ctx context.Context, arg SetNextFSMEventParams) (int64, error)

type Queries

+ func (q *Queries) PopNextFSMEvent(ctx context.Context, fsm schema.RefKey, instanceKey string) (FsmNextEvent, error)

+ func (q *Queries) SetNextFSMEvent(ctx context.Context, arg SetNextFSMEventParams) (int64, error)

+ type SetNextFSMEventParams struct

+ Event schema.RefKey

+ Fsm schema.RefKey

+ InstanceKey string

+ Request []byte

+ RequestType Type

Aug 14, 2024

Changes in this version

+ type InsertTimelineCallEventParams struct

+ DeploymentKey model.DeploymentKey

+ DestModule string

+ DestVerb string

+ ParentRequestKey optional.Option[string]

+ Payload []byte

+ RequestKey optional.Option[string]

+ SourceModule optional.Option[string]

+ SourceVerb optional.Option[string]

+ TimeStamp time.Time

+ type InsertTimelineDeploymentCreatedEventParams struct

+ DeploymentKey model.DeploymentKey

+ Language string

+ ModuleName string

+ Payload []byte

+ type InsertTimelineDeploymentUpdatedEventParams struct

+ DeploymentKey model.DeploymentKey

+ Language string

+ ModuleName string

+ Payload []byte

+ type InsertTimelineEventParams struct

+ CustomKey1 optional.Option[string]

+ CustomKey2 optional.Option[string]

+ CustomKey3 optional.Option[string]

+ CustomKey4 optional.Option[string]

+ DeploymentID int64

+ ParentRequestID optional.Option[string]

+ Payload []byte

+ RequestID optional.Option[int64]

+ Type EventType

+ type InsertTimelineLogEventParams struct

+ DeploymentKey model.DeploymentKey

+ Level int32

+ Payload []byte

+ RequestKey optional.Option[string]

+ TimeStamp time.Time

type Querier

+ DeleteOldTimelineEvents func(ctx context.Context, timeout sqltypes.Duration, type_ EventType) (int64, error)

+ InsertTimelineCallEvent func(ctx context.Context, arg InsertTimelineCallEventParams) error

+ InsertTimelineDeploymentCreatedEvent func(ctx context.Context, arg InsertTimelineDeploymentCreatedEventParams) error

+ InsertTimelineDeploymentUpdatedEvent func(ctx context.Context, arg InsertTimelineDeploymentUpdatedEventParams) error

+ InsertTimelineEvent func(ctx context.Context, arg InsertTimelineEventParams) error

+ InsertTimelineLogEvent func(ctx context.Context, arg InsertTimelineLogEventParams) error

type Queries

+ func (q *Queries) DeleteOldTimelineEvents(ctx context.Context, timeout sqltypes.Duration, type_ EventType) (int64, error)

+ func (q *Queries) InsertTimelineCallEvent(ctx context.Context, arg InsertTimelineCallEventParams) error

+ func (q *Queries) InsertTimelineDeploymentCreatedEvent(ctx context.Context, arg InsertTimelineDeploymentCreatedEventParams) error

+ func (q *Queries) InsertTimelineDeploymentUpdatedEvent(ctx context.Context, arg InsertTimelineDeploymentUpdatedEventParams) error

+ func (q *Queries) InsertTimelineEvent(ctx context.Context, arg InsertTimelineEventParams) error

+ func (q *Queries) InsertTimelineLogEvent(ctx context.Context, arg InsertTimelineLogEventParams) error

+ type Timeline struct

+ CustomKey1 optional.Option[string]

+ CustomKey2 optional.Option[string]

+ CustomKey3 optional.Option[string]

+ CustomKey4 optional.Option[string]

+ DeploymentID int64

+ ID int64

+ ParentRequestID optional.Option[string]

+ Payload []byte

+ RequestID optional.Option[int64]

+ TimeStamp time.Time

+ Type EventType

Aug 14, 2024

Changes in this version

+ type EncryptionKey struct

+ CreatedAt time.Time

+ ID int64

+ Key []byte

type Querier

+ CreateOnlyEncryptionKey func(ctx context.Context, key []byte) error

+ GetOnlyEncryptionKey func(ctx context.Context) ([]byte, error)

type Queries

+ func (q *Queries) CreateOnlyEncryptionKey(ctx context.Context, key []byte) error

+ func (q *Queries) GetOnlyEncryptionKey(ctx context.Context) ([]byte, error)

Aug 11, 2024

Changes in this version

type DBTX

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

Aug 8, 2024

Changes in this version

type AcquireAsyncCallRow

+ ParentRequestKey optional.Option[string]

+ TraceContext []byte

type AsyncCall

+ ParentRequestKey optional.Option[string]

+ TraceContext []byte

type CreateAsyncCallParams

+ ParentRequestKey optional.Option[string]

+ TraceContext []byte

type Event

+ ParentRequestID optional.Option[string]

type GetNextEventForSubscriptionRow

+ RequestKey optional.Option[string]

+ TraceContext []byte

type InsertCallEventParams

+ ParentRequestKey optional.Option[string]

type InsertEventParams

+ ParentRequestID optional.Option[string]

type PublishEventForTopicParams

+ RequestKey string

+ TraceContext []byte

type TopicEvent

+ RequestKey optional.Option[string]

+ TraceContext []byte

Aug 8, 2024

Changes in this version

type AcquireAsyncCallRow

+ CatchVerb optional.Option[schema.RefKey]

+ Catching bool

+ Error optional.Option[string]

type AsyncCall

+ CatchVerb optional.Option[schema.RefKey]

+ Catching bool

type CreateAsyncCallParams

+ CatchVerb optional.Option[schema.RefKey]

type FailAsyncCallWithRetryParams

+ Catching bool

+ OriginalError optional.Option[string]

type GetRandomSubscriberRow

+ CatchVerb optional.Option[schema.RefKey]

type InsertSubscriberParams

+ CatchVerb optional.Option[schema.RefKey]

type TopicSubscriber

+ CatchVerb optional.Option[schema.RefKey]

Aug 7, 2024

Changes in this version

type Querier

+ DeleteOldEvents func(ctx context.Context, timeout time.Duration, type_ EventType) (int64, error)

type Queries

+ func (q *Queries) DeleteOldEvents(ctx context.Context, timeout time.Duration, type_ EventType) (int64, error)

Aug 5, 2024

Changes in this version

type AcquireAsyncCallRow

+ QueueDepth int64

type Querier

+ AsyncCallQueueDepth func(ctx context.Context) (int64, error)

type Queries

+ func (q *Queries) AsyncCallQueueDepth(ctx context.Context) (int64, error)

Aug 2, 2024

Changes in this version

type InsertCallEventParams

+ Payload json.RawMessage

type InsertDeploymentCreatedEventParams

+ Payload json.RawMessage

type InsertDeploymentUpdatedEventParams

+ Payload json.RawMessage

type InsertLogEventParams

+ Payload json.RawMessage

Aug 1, 2024

Changes in this version

type GetNextEventForSubscriptionRow

+ Caller optional.Option[string]

type PublishEventForTopicParams

+ Caller string

type TopicEvent

+ Caller string

Aug 1, 2024

Changes in this version

+ type UpsertSubscriptionRow struct

+ ID int64

+ Inserted bool

Jul 31, 2024

Changes in this version

type Querier

+ GetSubscription func(ctx context.Context, column1 string, column2 string) (TopicSubscription, error)

+ GetTopic func(ctx context.Context, dollar_1 int64) (Topic, error)

+ GetTopicEvent func(ctx context.Context, dollar_1 int64) (TopicEvent, error)

+ SetSubscriptionCursor func(ctx context.Context, column1 model.SubscriptionKey, ...) error

type Queries

+ func (q *Queries) GetSubscription(ctx context.Context, column1 string, column2 string) (TopicSubscription, error)

+ func (q *Queries) GetTopic(ctx context.Context, dollar_1 int64) (Topic, error)

+ func (q *Queries) GetTopicEvent(ctx context.Context, dollar_1 int64) (TopicEvent, error)

+ func (q *Queries) SetSubscriptionCursor(ctx context.Context, column1 model.SubscriptionKey, ...) error

Jul 29, 2024

Changes in this version

type FsmInstance

+ UpdatedAt time.Time

Jul 8, 2024

Changes in this version

type Tx

+ func (t *Tx) Tx() pgx.Tx

Jul 3, 2024

Changes in this version

+ type ModuleSecret struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Url string

Jun 20, 2024

Changes in this version

+ type GetLeaseInfoRow struct

+ ExpiresAt time.Time

+ Metadata []byte

type Lease

+ Metadata []byte

type Querier

+ GetLeaseInfo func(ctx context.Context, key leases.Key) (GetLeaseInfoRow, error)

type Queries

+ func (q *Queries) GetLeaseInfo(ctx context.Context, key leases.Key) (GetLeaseInfoRow, error)

Jun 18, 2024

Changes in this version

type Querier

+ DeleteSubscribers func(ctx context.Context, deployment model.DeploymentKey) error

+ DeleteSubscriptions func(ctx context.Context, deployment model.DeploymentKey) error

+ GetSchemaForDeployment func(ctx context.Context, key model.DeploymentKey) (*schema.Module, error)

type Queries

+ func (q *Queries) DeleteSubscribers(ctx context.Context, deployment model.DeploymentKey) error

+ func (q *Queries) DeleteSubscriptions(ctx context.Context, deployment model.DeploymentKey) error

+ func (q *Queries) GetSchemaForDeployment(ctx context.Context, key model.DeploymentKey) (*schema.Module, error)

type TopicSubscription

+ DeploymentID int64

type UpsertSubscriptionParams

+ Deployment model.DeploymentKey

Jun 11, 2024

Changes in this version

type GetNextEventForSubscriptionRow

+ Ready bool

Jun 6, 2024

Changes in this version

+ type GetRandomSubscriberRow struct

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ RetryAttempts int32

+ Sink schema.RefKey

type InsertSubscriberParams

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ RetryAttempts int32

type Querier

+ GetRandomSubscriber func(ctx context.Context, key model.SubscriptionKey) (GetRandomSubscriberRow, error)

type Queries

+ func (q *Queries) GetRandomSubscriber(ctx context.Context, key model.SubscriptionKey) (GetRandomSubscriberRow, error)

type TopicSubscriber

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ RetryAttempts int32

Jun 6, 2024

Changes in this version

type GetNextEventForSubscriptionRow

+ CreatedAt optional.Option[time.Time]

type Querier

+ GetRandomSubscriberSink func(ctx context.Context, key model.SubscriptionKey) (schema.RefKey, error)

type Queries

+ func (q *Queries) GetRandomSubscriberSink(ctx context.Context, key model.SubscriptionKey) (schema.RefKey, error)

Jun 5, 2024

Changes in this version

+ type GetNextEventForSubscriptionRow struct

+ Event NullTopicEventKey

+ Payload []byte

+ type GetSubscriptionsNeedingUpdateRow struct

+ Cursor NullTopicEventKey

+ Key model.SubscriptionKey

+ Name string

+ Topic model.TopicKey

+ type LockSubscriptionAndGetSinkRow struct

+ Sink schema.RefKey

+ SubscriptionID int64

+ type NullSubscriberKey = optional.Option[model.SubscriberKey]

+ type NullSubscriptionKey = optional.Option[model.SubscriptionKey]

+ type NullTopicEventKey = optional.Option[model.TopicEventKey]

+ type NullTopicKey = optional.Option[model.TopicKey]

+ type NullTopicSubscriptionState struct

+ TopicSubscriptionState TopicSubscriptionState

+ Valid bool

+ func (ns *NullTopicSubscriptionState) Scan(value interface{}) error

+ func (ns NullTopicSubscriptionState) Value() (driver.Value, error)

type Querier

+ BeginConsumingTopicEvent func(ctx context.Context, subscriptionID optional.Option[int64], ...) error

+ CompleteEventForSubscription func(ctx context.Context, name string, module string) error

+ GetNextEventForSubscription func(ctx context.Context, topic model.TopicKey, cursor NullTopicEventKey) (GetNextEventForSubscriptionRow, error)

+ GetSubscriptionsNeedingUpdate func(ctx context.Context) ([]GetSubscriptionsNeedingUpdateRow, error)

+ LockSubscriptionAndGetSink func(ctx context.Context, key model.SubscriptionKey, cursor NullTopicEventKey) (LockSubscriptionAndGetSinkRow, error)

type Queries

+ func (q *Queries) BeginConsumingTopicEvent(ctx context.Context, subscriptionID optional.Option[int64], ...) error

+ func (q *Queries) CompleteEventForSubscription(ctx context.Context, name string, module string) error

+ func (q *Queries) GetNextEventForSubscription(ctx context.Context, topic model.TopicKey, cursor NullTopicEventKey) (GetNextEventForSubscriptionRow, error)

+ func (q *Queries) GetSubscriptionsNeedingUpdate(ctx context.Context) ([]GetSubscriptionsNeedingUpdateRow, error)

+ func (q *Queries) LockSubscriptionAndGetSink(ctx context.Context, key model.SubscriptionKey, cursor NullTopicEventKey) (LockSubscriptionAndGetSinkRow, error)

type Topic

+ Head optional.Option[int64]

type TopicSubscription

+ State TopicSubscriptionState

+ type TopicSubscriptionState string

+ const TopicSubscriptionStateExecuting

+ const TopicSubscriptionStateIdle

+ func (e *TopicSubscriptionState) Scan(src interface{}) error

Jun 4, 2024

Changes in this version

+ type PublishEventForTopicParams struct

+ Key model.TopicEventKey

+ Module string

+ Payload []byte

+ Topic string

type Querier

+ PublishEventForTopic func(ctx context.Context, arg PublishEventForTopicParams) error

type Queries

+ func (q *Queries) PublishEventForTopic(ctx context.Context, arg PublishEventForTopicParams) error

type TopicEvent

+ Key model.TopicEventKey

May 31, 2024

Changes in this version

+ type InsertSubscriberParams struct

+ Deployment model.DeploymentKey

+ Key model.SubscriberKey

+ Module string

+ Sink string

+ SubscriptionName string

type Querier

+ InsertSubscriber func(ctx context.Context, arg InsertSubscriberParams) error

+ UpsertSubscription func(ctx context.Context, arg UpsertSubscriptionParams) error

+ UpsertTopic func(ctx context.Context, arg UpsertTopicParams) error

type Queries

+ func (q *Queries) InsertSubscriber(ctx context.Context, arg InsertSubscriberParams) error

+ func (q *Queries) UpsertSubscription(ctx context.Context, arg UpsertSubscriptionParams) error

+ func (q *Queries) UpsertTopic(ctx context.Context, arg UpsertTopicParams) error

type TopicSubscriber

+ Sink string

type TopicSubscription

+ ModuleID int64

+ type UpsertSubscriptionParams struct

+ Key model.SubscriptionKey

+ Module string

+ Name string

+ TopicModule string

+ TopicName string

+ type UpsertTopicParams struct

+ EventType string

+ Module string

+ Name string

+ Topic model.TopicKey

May 29, 2024

Changes in this version

+ type ModuleConfiguration struct

+ CreatedAt time.Time

+ ID int64

+ Module optional.Option[string]

+ Name string

+ Value []byte

type Querier

+ GetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) ([]byte, error)

+ ListModuleConfiguration func(ctx context.Context) ([]ModuleConfiguration, error)

+ SetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string, value []byte) error

+ UnsetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) error

type Queries

+ func (q *Queries) GetModuleConfiguration(ctx context.Context, module optional.Option[string], name string) ([]byte, error)

+ func (q *Queries) ListModuleConfiguration(ctx context.Context) ([]ModuleConfiguration, error)

+ func (q *Queries) SetModuleConfiguration(ctx context.Context, module optional.Option[string], name string, value []byte) error

+ func (q *Queries) UnsetModuleConfiguration(ctx context.Context, module optional.Option[string], name string) error

May 28, 2024

Changes in this version

type AcquireAsyncCallRow

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ RemainingAttempts int32

+ ScheduledAt time.Time

type AsyncCall

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ RemainingAttempts int32

+ ScheduledAt time.Time

+ type CreateAsyncCallParams struct

+ Backoff time.Duration

+ MaxBackoff time.Duration

+ Origin string

+ RemainingAttempts int32

+ Request []byte

+ Verb schema.RefKey

+ type FailAsyncCallWithRetryParams struct

+ Backoff time.Duration

+ Error string

+ ID int64

+ MaxBackoff time.Duration

+ RemainingAttempts int32

+ ScheduledAt time.Time

type Querier

+ FailAsyncCallWithRetry func(ctx context.Context, arg FailAsyncCallWithRetryParams) (bool, error)

type Queries

+ func (q *Queries) FailAsyncCallWithRetry(ctx context.Context, arg FailAsyncCallWithRetryParams) (bool, error)

May 27, 2024

Changes in this version

+ type FsmInstance struct

+ AsyncCallID optional.Option[int64]

+ CreatedAt time.Time

+ CurrentState NullRef

+ DestinationState NullRef

+ Fsm schema.RefKey

+ ID int64

+ Key string

+ Status FsmStatus

+ type NullType = optional.Option[Type]

type Querier

+ CreateAsyncCall func(ctx context.Context, verb schema.RefKey, origin string, request []byte) (int64, error)

+ FailAsyncCall func(ctx context.Context, error string, iD int64) (bool, error)

+ FailFSMInstance func(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

+ FinishFSMTransition func(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

+ GetFSMInstance func(ctx context.Context, fsm schema.RefKey, key string) (FsmInstance, error)

+ StartFSMTransition func(ctx context.Context, arg StartFSMTransitionParams) (FsmInstance, error)

+ SucceedAsyncCall func(ctx context.Context, response []byte, iD int64) (bool, error)

+ SucceedFSMInstance func(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

type Queries

+ func (q *Queries) CreateAsyncCall(ctx context.Context, verb schema.RefKey, origin string, request []byte) (int64, error)

+ func (q *Queries) FailAsyncCall(ctx context.Context, error string, iD int64) (bool, error)

+ func (q *Queries) FailFSMInstance(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

+ func (q *Queries) FinishFSMTransition(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

+ func (q *Queries) GetFSMInstance(ctx context.Context, fsm schema.RefKey, key string) (FsmInstance, error)

+ func (q *Queries) StartFSMTransition(ctx context.Context, arg StartFSMTransitionParams) (FsmInstance, error)

+ func (q *Queries) SucceedAsyncCall(ctx context.Context, response []byte, iD int64) (bool, error)

+ func (q *Queries) SucceedFSMInstance(ctx context.Context, fsm schema.RefKey, key string) (bool, error)

+ type StartFSMTransitionParams struct

+ AsyncCallID int64

+ DestinationState schema.RefKey

+ Fsm schema.RefKey

+ Key string

+ type Type struct

+ func (t *Type) Scan(src interface{}) error

+ func (t *Type) Value() (driver.Value, error)

May 20, 2024

Changes in this version

+ type ConnI interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

type DBI

+ Conn func() ConnI

type Tx

+ func (t *Tx) Begin(ctx context.Context) (*Tx, error)

+ func (t *Tx) Conn() ConnI

May 2, 2024

Changes in this version

type AcquireAsyncCallRow

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Verb schema.Ref

+ type NullRef = optional.Option[schema.Ref]

type Querier

+ CompleteAsyncCall func(ctx context.Context, response []byte, error optional.Option[string], iD int64) (bool, error)

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

type Queries

+ func (q *Queries) CompleteAsyncCall(ctx context.Context, response []byte, error optional.Option[string], iD int64) (bool, error)

+ func (q *Queries) LoadAsyncCall(ctx context.Context, id int64) (AsyncCall, error)

May 1, 2024

Changes in this version

+ type AcquireAsyncCallRow struct

+ AsyncCallID int64

+ LeaseIdempotencyKey uuid.UUID

+ LeaseKey leases.Key

+ type AddAsyncCallParams struct

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Verb string

+ type AsyncCall struct

+ CreatedAt time.Time

+ Error optional.Option[string]

+ ID int64

+ LeaseID optional.Option[int64]

+ Origin AsyncCallOrigin

+ OriginKey string

+ Request []byte

+ Response []byte

+ State AsyncCallState

+ Verb string

+ type AsyncCallOrigin string

+ const AsyncCallOriginCron

+ const AsyncCallOriginFsm

+ const AsyncCallOriginPubsub

+ func (e *AsyncCallOrigin) Scan(src interface{}) error

+ type AsyncCallState string

+ const AsyncCallStateError

+ const AsyncCallStateExecuting

+ const AsyncCallStatePending

+ const AsyncCallStateSuccess

+ func (e *AsyncCallState) Scan(src interface{}) error

+ type FsmExecution struct

+ CreatedAt time.Time

+ ID int64

+ Key string

+ Name string

+ State string

+ Status FsmStatus

+ type FsmStatus string

+ const FsmStatusCompleted

+ const FsmStatusFailed

+ const FsmStatusRunning

+ func (e *FsmStatus) Scan(src interface{}) error

+ type FsmTransition struct

+ AsyncCallsID int64

+ FsmExecutionsID int64

+ ID int64

+ type NullAsyncCallOrigin struct

+ AsyncCallOrigin AsyncCallOrigin

+ Valid bool

+ func (ns *NullAsyncCallOrigin) Scan(value interface{}) error

+ func (ns NullAsyncCallOrigin) Value() (driver.Value, error)

+ type NullAsyncCallState struct

+ AsyncCallState AsyncCallState

+ Valid bool

+ func (ns *NullAsyncCallState) Scan(value interface{}) error

+ func (ns NullAsyncCallState) Value() (driver.Value, error)

+ type NullFsmStatus struct

+ FsmStatus FsmStatus

+ Valid bool

+ func (ns *NullFsmStatus) Scan(value interface{}) error

+ func (ns NullFsmStatus) Value() (driver.Value, error)

type Querier

+ AcquireAsyncCall func(ctx context.Context, ttl time.Duration) (AcquireAsyncCallRow, error)

+ AddAsyncCall func(ctx context.Context, arg AddAsyncCallParams) (bool, error)

+ SendFSMEvent func(ctx context.Context, arg SendFSMEventParams) (int64, error)

type Queries

+ func (q *Queries) AcquireAsyncCall(ctx context.Context, ttl time.Duration) (AcquireAsyncCallRow, error)

+ func (q *Queries) AddAsyncCall(ctx context.Context, arg AddAsyncCallParams) (bool, error)

+ func (q *Queries) SendFSMEvent(ctx context.Context, arg SendFSMEventParams) (int64, error)

+ type SendFSMEventParams struct

+ Key string

+ Name string

+ Request []byte

+ State string

+ Verb string

Apr 29, 2024

Changes in this version

+ type Lease struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID int64

+ IdempotencyKey uuid.UUID

+ Key leases.Key

+ type NullLeaseKey = optional.Option[leases.Key]

+ type NullUUID = optional.Option[uuid.UUID]

type Querier

+ ExpireLeases func(ctx context.Context) (int64, error)

+ NewLease func(ctx context.Context, key leases.Key, expiresAt time.Time) (uuid.UUID, error)

+ ReleaseLease func(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ RenewLease func(ctx context.Context, expiresIn time.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

type Queries

+ func (q *Queries) ExpireLeases(ctx context.Context) (int64, error)

+ func (q *Queries) NewLease(ctx context.Context, key leases.Key, expiresAt time.Time) (uuid.UUID, error)

+ func (q *Queries) ReleaseLease(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ func (q *Queries) RenewLease(ctx context.Context, expiresIn time.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

Apr 17, 2024

Changes in this version

+ type GetActiveIngressRoutesRow struct

+ DeploymentKey model.DeploymentKey

+ Method string

+ Module string

+ Path string

+ Verb string

type Querier

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

+ GetActiveIngressRoutes func(ctx context.Context) ([]GetActiveIngressRoutesRow, error)

type Queries

+ func (q *Queries) GetActiveControllers(ctx context.Context) ([]Controller, error)

+ func (q *Queries) GetActiveIngressRoutes(ctx context.Context) ([]GetActiveIngressRoutesRow, error)

Apr 12, 2024

Changes in this version

+ type CreateCronJobParams struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ ModuleName string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ Verb string

+ type CronJob struct

+ DeploymentID int64

+ ID int64

+ Key model.CronJobKey

+ ModuleName string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type CronJobState string

+ const CronJobStateExecuting

+ const CronJobStateIdle

+ func (e *CronJobState) Scan(src interface{}) error

+ type EndCronJobRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type GetCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type GetStaleCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Verb string

+ type NullCronJobKey = optional.Option[model.CronJobKey]

+ type NullCronJobState struct

+ CronJobState CronJobState

+ Valid bool

+ func (ns *NullCronJobState) Scan(value interface{}) error

+ func (ns NullCronJobState) Value() (driver.Value, error)

type Querier

+ CreateCronJob func(ctx context.Context, arg CreateCronJobParams) error

+ CreateCronRequest func(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ CreateRequest func(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ EndCronJob func(ctx context.Context, nextExecution time.Time, key model.CronJobKey, ...) (EndCronJobRow, error)

+ GetCronJobs func(ctx context.Context) ([]GetCronJobsRow, error)

+ GetStaleCronJobs func(ctx context.Context, dollar_1 time.Duration) ([]GetStaleCronJobsRow, error)

+ StartCronJobs func(ctx context.Context, keys []string) ([]StartCronJobsRow, error)

type Queries

+ func (q *Queries) CreateCronJob(ctx context.Context, arg CreateCronJobParams) error

+ func (q *Queries) CreateCronRequest(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ func (q *Queries) CreateRequest(ctx context.Context, origin Origin, key model.RequestKey, sourceAddr string) error

+ func (q *Queries) EndCronJob(ctx context.Context, nextExecution time.Time, key model.CronJobKey, ...) (EndCronJobRow, error)

+ func (q *Queries) GetCronJobs(ctx context.Context) ([]GetCronJobsRow, error)

+ func (q *Queries) GetStaleCronJobs(ctx context.Context, dollar_1 time.Duration) ([]GetStaleCronJobsRow, error)

+ func (q *Queries) StartCronJobs(ctx context.Context, keys []string) ([]StartCronJobsRow, error)

+ type StartCronJobsRow struct

+ DeploymentKey model.DeploymentKey

+ HasMinReplicas bool

+ Key model.CronJobKey

+ Module string

+ NextExecution time.Time

+ Schedule string

+ StartTime time.Time

+ State CronJobState

+ Updated bool

+ Verb string

Apr 10, 2024

Changes in this version

type InsertCallEventParams

+ RequestKey optional.Option[string]

type InsertLogEventParams

+ RequestKey optional.Option[string]

+ type NullRequestKey = optional.Option[model.RequestKey]

type Request

+ Key model.RequestKey

Apr 9, 2024

Changes in this version

+ type GetDeploymentsWithMinReplicasRow struct

+ Deployment Deployment

+ Language string

+ ModuleName string

type Querier

+ GetDeploymentsWithMinReplicas func(ctx context.Context) ([]GetDeploymentsWithMinReplicasRow, error)

type Queries

+ func (q *Queries) GetDeploymentsWithMinReplicas(ctx context.Context) ([]GetDeploymentsWithMinReplicasRow, error)

type Topic

+ Key interface{}

type TopicSubscriber

+ Key interface{}

type TopicSubscription

+ Key interface{}

Apr 4, 2024

Changes in this version

type GetActiveDeploymentsRow

+ Replicas int64

Apr 2, 2024

Changes in this version

+ type Topic struct

+ CreatedAt time.Time

+ ID int64

+ ModuleID int64

+ Name string

+ Type string

+ type TopicEvent struct

+ CreatedAt time.Time

+ ID int64

+ Payload []byte

+ TopicID int64

+ type TopicSubscriber struct

+ CreatedAt time.Time

+ DeploymentID int64

+ ID int64

+ TopicSubscriptionsID int64

+ Verb string

+ type TopicSubscription struct

+ CreatedAt time.Time

+ Cursor int64

+ ID int64

+ Name string

+ TopicID int64

Mar 15, 2024

Changes in this version

type AssociateArtefactWithDeploymentParams

+ Key model.DeploymentKey

type CreateIngressRouteParams

+ Key model.DeploymentKey

type Deployment

+ Key model.DeploymentKey

type GetActiveDeploymentSchemasRow

+ Key model.DeploymentKey

type GetActiveRunnersRow

+ DeploymentKey optional.Option[string]

type GetAllIngressRoutesRow

+ DeploymentKey model.DeploymentKey

type GetDeploymentsNeedingReconciliationRow

+ DeploymentKey model.DeploymentKey

type GetDeploymentsWithArtefactsRow

+ DeploymentKey model.DeploymentKey

type GetExistingDeploymentForModuleRow

+ Key model.DeploymentKey

type GetIngressRoutesRow

+ DeploymentKey model.DeploymentKey

type GetProcessListRow

+ DeploymentKey model.DeploymentKey

type GetRouteForRunnerRow

+ DeploymentKey NullDeploymentKey

type GetRoutingTableRow

+ DeploymentKey NullDeploymentKey

type GetRunnerRow

+ DeploymentKey optional.Option[string]

type GetRunnersForDeploymentRow

+ Key_2 model.DeploymentKey

type InsertCallEventParams

+ DeploymentKey model.DeploymentKey

type InsertDeploymentCreatedEventParams

+ DeploymentKey model.DeploymentKey

type InsertDeploymentUpdatedEventParams

+ DeploymentKey model.DeploymentKey

type InsertLogEventParams

+ DeploymentKey model.DeploymentKey

+ type NullDeploymentKey = optional.Option[model.DeploymentKey]

type UpsertRunnerParams

+ DeploymentKey NullDeploymentKey

Mar 13, 2024

Changes in this version

+ type NullRunnerKey = optional.Option[model.RunnerKey]

Jan 31, 2024

Changes in this version

type GetDeploymentsWithArtefactsRow

+ Schema []byte

Dec 5, 2023

Changes in this version

type GetIngressRoutesRow

+ DeploymentName model.DeploymentName

+ Path string

Dec 4, 2023

Changes in this version

+ type GetActiveDeploymentSchemasRow struct

+ Name model.DeploymentName

+ Schema []byte

+ type GetActiveDeploymentsRow struct

+ Deployment Deployment

+ Language string

+ ModuleName string

type Querier

+ GetActiveDeploymentSchemas func(ctx context.Context) ([]GetActiveDeploymentSchemasRow, error)

+ GetActiveDeployments func(ctx context.Context, all bool) ([]GetActiveDeploymentsRow, error)

type Queries

+ func (q *Queries) GetActiveDeploymentSchemas(ctx context.Context) ([]GetActiveDeploymentSchemasRow, error)

+ func (q *Queries) GetActiveDeployments(ctx context.Context, all bool) ([]GetActiveDeploymentsRow, error)

Nov 28, 2023

Changes in this version

type InsertCallEventParams

+ Stack types.Option[string]

type InsertLogEventParams

+ Stack types.Option[string]

Nov 24, 2023

Changes in this version

type InsertEventParams

+ CustomKey2 types.Option[string]