Documentation
¶
Index ¶
- func MustUUIDFromString(value string) *uuid.UUID
- type APIKey
- type CompleteRunFailureParams
- type CompleteRunSuccessParams
- type CreateAPIKeyParams
- type CreateJobParams
- type CreateJobRunParams
- type CreateUserParams
- type DBTX
- type Job
- type JobRun
- type ManualJobTrigger
- type Queries
- func (q *Queries) ClaimDueJob(ctx context.Context, workerID string, staleInterval string) (*Job, error)
- func (q *Queries) ClaimManualTrigger(ctx context.Context, workerID string, staleInterval string) (*ManualJobTrigger, error)
- func (q *Queries) ClearJobClaim(ctx context.Context, id uuid.UUID) error
- func (q *Queries) CompleteManualJobExecution(ctx context.Context, jobID uuid.UUID, lastRunAt time.Time) error
- func (q *Queries) CompleteManualTrigger(ctx context.Context, triggerID uuid.UUID) error
- func (q *Queries) CompleteRunFailure(ctx context.Context, arg CompleteRunFailureParams) (JobRun, error)
- func (q *Queries) CompleteRunSuccess(ctx context.Context, arg CompleteRunSuccessParams) (JobRun, error)
- func (q *Queries) CompleteScheduledJobExecution(ctx context.Context, jobID uuid.UUID, lastRunAt time.Time, nextRunAt time.Time) error
- func (q *Queries) CreateAPIKey(ctx context.Context, arg CreateAPIKeyParams) (APIKey, error)
- func (q *Queries) CreateJob(ctx context.Context, arg CreateJobParams) (Job, error)
- func (q *Queries) CreateJobRun(ctx context.Context, arg CreateJobRunParams) (JobRun, error)
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
- func (q *Queries) DeleteJob(ctx context.Context, id uuid.UUID) error
- func (q *Queries) GetAPIKey(ctx context.Context, id uuid.UUID) (APIKey, error)
- func (q *Queries) GetAPIKeyByPrefix(ctx context.Context, prefix string) (APIKey, error)
- func (q *Queries) GetJob(ctx context.Context, id uuid.UUID) (Job, error)
- func (q *Queries) GetManualTriggerJob(ctx context.Context, triggerID uuid.UUID) (Job, error)
- func (q *Queries) GetRun(ctx context.Context, id uuid.UUID) (JobRun, error)
- func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)
- func (q *Queries) InsertManualTrigger(ctx context.Context, id uuid.UUID, jobID uuid.UUID, triggeredBy *string) (ManualJobTrigger, error)
- func (q *Queries) ListAPIKeys(ctx context.Context) ([]APIKey, error)
- func (q *Queries) ListJobs(ctx context.Context) ([]Job, error)
- func (q *Queries) ListRunsByJob(ctx context.Context, jobID uuid.UUID, limit int32) ([]JobRun, error)
- func (q *Queries) PauseJob(ctx context.Context, id uuid.UUID) (Job, error)
- func (q *Queries) ReleaseClaim(ctx context.Context, jobID uuid.UUID) error
- func (q *Queries) ResetManualTriggerClaim(ctx context.Context, triggerID uuid.UUID) error
- func (q *Queries) ResumeJob(ctx context.Context, id uuid.UUID, nextRunAt time.Time) (Job, error)
- func (q *Queries) RevokeAPIKey(ctx context.Context, id uuid.UUID) (APIKey, error)
- func (q *Queries) UpdateAPIKeyLastUsedAt(ctx context.Context, id uuid.UUID) error
- func (q *Queries) UpdateJob(ctx context.Context, arg UpdateJobParams) (Job, error)
- func (q *Queries) UpdateRunningAttempt(ctx context.Context, runID uuid.UUID, attemptNumber int32) error
- type UpdateJobParams
- type User
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustUUIDFromString ¶
Types ¶
type APIKey ¶
type APIKey struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
KeyPrefix string `json:"key_prefix"`
KeyHash string `json:"-"`
Scopes []byte `json:"scopes"`
TenantID *uuid.UUID `json:"tenant_id,omitempty"`
CreatedBy *string `json:"created_by,omitempty"`
LastUsedAt *time.Time `json:"last_used_at,omitempty"`
ExpiresAt *time.Time `json:"expires_at,omitempty"`
RevokedAt *time.Time `json:"revoked_at,omitempty"`
CreatedAt time.Time `json:"created_at"`
}
type CreateAPIKeyParams ¶
type CreateJobParams ¶
type CreateJobRunParams ¶
type CreateUserParams ¶
type Job ¶
type Job struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
Method string `json:"method"`
URL string `json:"url"`
Headers []byte `json:"headers"`
Body []byte `json:"body,omitempty"`
CronExpression string `json:"cron_expression"`
Timezone string `json:"timezone"`
RetryMax int32 `json:"retry_max"`
TimeoutSeconds int32 `json:"timeout_seconds"`
Enabled bool `json:"enabled"`
NextRunAt *time.Time `json:"next_run_at,omitempty"`
LastRunAt *time.Time `json:"last_run_at,omitempty"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
ClaimedAt *time.Time `json:"claimed_at,omitempty"`
ClaimedBy *string `json:"claimed_by,omitempty"`
TenantID *uuid.UUID `json:"tenant_id,omitempty"`
CreatedBy *string `json:"created_by,omitempty"`
}
type JobRun ¶
type JobRun struct {
ID uuid.UUID `json:"id"`
JobID uuid.UUID `json:"job_id"`
TriggerType string `json:"trigger_type"`
AttemptNumber int32 `json:"attempt_number"`
Status string `json:"status"`
RequestMethod string `json:"request_method"`
RequestURL string `json:"request_url"`
RequestHeaders []byte `json:"request_headers"`
RequestBody []byte `json:"request_body,omitempty"`
ResponseStatusCode *int32 `json:"response_status_code,omitempty"`
ResponseHeaders []byte `json:"response_headers,omitempty"`
ResponseBody *string `json:"response_body,omitempty"`
ErrorMessage *string `json:"error_message,omitempty"`
StartedAt time.Time `json:"started_at"`
FinishedAt *time.Time `json:"finished_at,omitempty"`
}
type ManualJobTrigger ¶
type ManualJobTrigger struct {
ID uuid.UUID `json:"id"`
JobID uuid.UUID `json:"job_id"`
TriggeredBy *string `json:"triggered_by,omitempty"`
CreatedAt time.Time `json:"created_at"`
ClaimedAt *time.Time `json:"claimed_at,omitempty"`
ClaimedBy *string `json:"claimed_by,omitempty"`
CompletedAt *time.Time `json:"completed_at,omitempty"`
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) ClaimDueJob ¶
func (*Queries) ClaimManualTrigger ¶
func (*Queries) ClearJobClaim ¶
func (*Queries) CompleteManualJobExecution ¶
func (*Queries) CompleteManualTrigger ¶
func (*Queries) CompleteRunFailure ¶
func (*Queries) CompleteRunSuccess ¶
func (*Queries) CompleteScheduledJobExecution ¶
func (*Queries) CreateAPIKey ¶
func (*Queries) CreateJobRun ¶
func (*Queries) CreateUser ¶
func (*Queries) GetAPIKeyByPrefix ¶
func (*Queries) GetManualTriggerJob ¶
func (*Queries) GetUserByEmail ¶
func (*Queries) InsertManualTrigger ¶
func (*Queries) ListRunsByJob ¶
func (*Queries) ReleaseClaim ¶
func (*Queries) ResetManualTriggerClaim ¶
func (*Queries) RevokeAPIKey ¶
func (*Queries) UpdateAPIKeyLastUsedAt ¶
type UpdateJobParams ¶
Click to show internal directories.
Click to hide internal directories.