| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Servant.Types
Description
Response types for the Arbiter REST API.
Synopsis
- apiJobPairs :: ToJSON payload => JobRead payload -> [Pair]
- healthStatusToText :: HealthStatus -> Text
- jobLeasePairs :: JobLease -> [Pair]
- data AckRequest result = AckRequest {}
- data AllStatsResponse = AllStatsResponse {
- queues :: [QueueOverview]
- newtype ApiArchiveJob payload = ApiArchiveJob {
- unApiArchiveJob :: ArchiveJob payload
- newtype ApiDLQJob payload = ApiDLQJob {
- unApiDLQJob :: DLQJob payload
- newtype ApiJob payload = ApiJob {}
- data ApiJobWithStatus payload = ApiJobWithStatus {
- ajwsJob :: JobRead payload
- ajwsStatus :: JobStatus
- newtype ApiJobWrite payload = ApiJobWrite {
- unApiJobWrite :: JobWrite payload
- data ArchiveResponse payload = ArchiveResponse {
- archiveJobs :: [ApiArchiveJob payload]
- archiveTotal :: Int
- archiveOffset :: Int
- archiveLimit :: Int
- data BatchDeleteRequest = BatchDeleteRequest {}
- data BatchDeleteResponse = BatchDeleteResponse {}
- newtype BatchInsertRequest payload = BatchInsertRequest {
- jobWrites :: [ApiJobWrite payload]
- data BatchInsertResponse payload = BatchInsertResponse {
- inserted :: [ApiJob payload]
- insertedCount :: Int
- data ClaimRequest = ClaimRequest {}
- newtype ClaimResponse payload = ClaimResponse {
- claimedJobs :: [ApiJob payload]
- data ConcurrencyKeysResponse = ConcurrencyKeysResponse {
- keys :: [ConcurrencyKeyView]
- data ConcurrencyPoliciesResponse = ConcurrencyPoliciesResponse {}
- data ConcurrencyReconcileResponse = ConcurrencyReconcileResponse {
- reconciled :: Int64
- data CronScheduleView = CronScheduleView {}
- data CronSchedulesResponse = CronSchedulesResponse {}
- data DLQResponse payload = DLQResponse {}
- data ExtendRequest = ExtendRequest {}
- data HealthResponse = HealthResponse {
- status :: HealthStatus
- schemaName :: Text
- checkedAt :: UTCTime
- dbLatencyMs :: Maybe Double
- db :: Maybe PgDbHealth
- data HealthStatus
- data JobLease = JobLease {
- jlClaimSeq :: Int64
- jlClaimedBy :: UUID
- newtype JobResponse a = JobResponse {
- job :: a
- data JobsResponse payload = JobsResponse {
- jobs :: [ApiJobWithStatus payload]
- jobsTotal :: Int
- jobsOffset :: Int
- jobsLimit :: Int
- childCounts :: Map Int64 Int64
- pausedParents :: [Int64]
- dlqChildCounts :: Map Int64 Int64
- data LivenessResponse = LivenessResponse {}
- data MaintenanceResponse = MaintenanceResponse {
- maintenanceOps :: Map Text Int64
- maintenanceFailed :: [Text]
- data QueuesResponse = QueuesResponse {}
- data RateLimitBucketsResponse = RateLimitBucketsResponse {}
- data RateLimitPoliciesResponse = RateLimitPoliciesResponse {}
- data RateLimitResetResponse = RateLimitResetResponse {}
- data StatsResponse = StatsResponse {
- stats :: QueueStats
- timestamp :: Text
- data WorkersResponse = WorkersResponse {}
- data CronScheduleRow = CronScheduleRow {
- name :: Text
- queueName :: Text
- defaultExpression :: Text
- defaultOverlap :: Text
- defaultTimezone :: Maybe Text
- overrideExpression :: Maybe Text
- overrideOverlap :: Maybe Text
- overrideTimezone :: Maybe Text
- enabled :: Bool
- lastFiredAt :: Maybe UTCTime
- lastCheckedAt :: Maybe UTCTime
- runRequestedAt :: Maybe UTCTime
- lastManualRunAt :: Maybe UTCTime
- createdAt :: UTCTime
- updatedAt :: UTCTime
- data CronScheduleUpdate = CronScheduleUpdate {
- overrideExpression :: Maybe (Maybe Text)
- overrideOverlap :: Maybe (Maybe Text)
- overrideTimezone :: Maybe (Maybe Text)
- enabled :: Maybe Bool
- data QueueOverview = QueueOverview {}
- data QueueRow = QueueRow {}
- data WorkerRow = WorkerRow {
- workerId :: UUID
- queueName :: Text
- hostName :: Maybe Text
- workerCount :: Maybe Int32
- startedAt :: UTCTime
- lastHeartbeat :: UTCTime
- shuttingDown :: Bool
- paused :: Bool
- staleThresholdSecs :: Double
- metadata :: Maybe Value
- health :: WorkerHealth
- data RateLimitPolicyView = RateLimitPolicyView {}
- data RateLimitBucketView = RateLimitBucketView {
- rateLimitKey :: Text
- policyPrefix :: Text
- tokens :: Double
- maxTokens :: Double
- fillFraction :: Maybe Double
- lastRefill :: UTCTime
- data RateLimitPolicyUpdate = RateLimitPolicyUpdate {}
- data ConcurrencyPolicyView = ConcurrencyPolicyView {
- prefix :: Text
- defaultLimit :: Int32
- overrideLimit :: Maybe Int32
- keyCount :: Int64
- totalInFlight :: Int64
- maxInFlight :: Maybe Int32
- data ConcurrencyKeyView = ConcurrencyKeyView {}
- data ConcurrencyPolicyUpdate = ConcurrencyPolicyUpdate {
- overrideLimit :: Maybe (Maybe Int32)
- data PgDbHealth = PgDbHealth {}
Documentation
Source #apiJobPairs :: ToJSON payload => JobRead payload -> [Pair]
Shared JSON field list for a job row. ApiJobWithStatus appends status.
Source #jobLeasePairs :: JobLease -> [Pair]
Shared JSON fields for a lease. Request encoders append request-specific fields.
Source #data AckRequest result
A lease and an optional stored result. An absent result performs a plain ack.
Constructors
| AckRequest | |
Instances
| FromJSON result => FromJSON (AckRequest result) Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (AckRequest result) #parseJSONList :: Value -> Parser [AckRequest result] #omittedField :: Maybe (AckRequest result) | |
| ToJSON result => ToJSON (AckRequest result) Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: AckRequest result -> Value #toEncoding :: AckRequest result -> Encoding #toJSONList :: [AckRequest result] -> Value #toEncodingList :: [AckRequest result] -> Encoding #omitField :: AckRequest result -> Bool | |
| Eq result => Eq (AckRequest result) Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: AckRequest result -> AckRequest result -> Bool #(/=) :: AckRequest result -> AckRequest result -> Bool | |
| Show result => Show (AckRequest result) Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> AckRequest result -> ShowS #show :: AckRequest result -> String #showList :: [AckRequest result] -> ShowS | |
Source #data AllStatsResponse
Every queue's stats, for the landing overview.
Constructors
| AllStatsResponse | |
Fields
| |
Instances
Source #newtype ApiArchiveJob payload
An archived job in its JSON wire shape.
Constructors
| ApiArchiveJob | |
Fields
| |
Instances
| FromJSON payload => FromJSON (ApiArchiveJob payload) Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (ApiArchiveJob payload) #parseJSONList :: Value -> Parser [ApiArchiveJob payload] #omittedField :: Maybe (ApiArchiveJob payload) | |
| ToJSON payload => ToJSON (ApiArchiveJob payload) Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ApiArchiveJob payload -> Value #toEncoding :: ApiArchiveJob payload -> Encoding #toJSONList :: [ApiArchiveJob payload] -> Value #toEncodingList :: [ApiArchiveJob payload] -> Encoding #omitField :: ApiArchiveJob payload -> Bool | |
| Eq payload => Eq (ApiArchiveJob payload) Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: ApiArchiveJob payload -> ApiArchiveJob payload -> Bool #(/=) :: ApiArchiveJob payload -> ApiArchiveJob payload -> Bool | |
| Show payload => Show (ApiArchiveJob payload) Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ApiArchiveJob payload -> ShowS #show :: ApiArchiveJob payload -> String #showList :: [ApiArchiveJob payload] -> ShowS | |
Source #newtype ApiDLQJob payload
A DLQ entry in its JSON wire shape.
Constructors
| ApiDLQJob | |
Fields
| |
Source #newtype ApiJob payload
A job in its JSON wire shape.
Source #data ApiJobWithStatus payload
A job row plus its SQL-derived status, for the list endpoint.
Constructors
| ApiJobWithStatus | |
Fields
| |
Instances
| FromJSON payload => FromJSON (ApiJobWithStatus payload) Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (ApiJobWithStatus payload) #parseJSONList :: Value -> Parser [ApiJobWithStatus payload] #omittedField :: Maybe (ApiJobWithStatus payload) | |
| ToJSON payload => ToJSON (ApiJobWithStatus payload) Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ApiJobWithStatus payload -> Value #toEncoding :: ApiJobWithStatus payload -> Encoding #toJSONList :: [ApiJobWithStatus payload] -> Value #toEncodingList :: [ApiJobWithStatus payload] -> Encoding #omitField :: ApiJobWithStatus payload -> Bool | |
| Eq payload => Eq (ApiJobWithStatus payload) Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: ApiJobWithStatus payload -> ApiJobWithStatus payload -> Bool #(/=) :: ApiJobWithStatus payload -> ApiJobWithStatus payload -> Bool | |
| Show payload => Show (ApiJobWithStatus payload) Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ApiJobWithStatus payload -> ShowS #show :: ApiJobWithStatus payload -> String #showList :: [ApiJobWithStatus payload] -> ShowS | |
Source #newtype ApiJobWrite payload
Write-side job type for REST API insertion.
Accepts payload, groupKey, priority, notVisibleUntil, dedupKey,
and maxAttempts. Fields like parentId, parentState, and suspended
are managed internally and cannot be set through the REST API.
Constructors
| ApiJobWrite | |
Fields
| |
Instances
| FromJSON payload => FromJSON (ApiJobWrite payload) Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (ApiJobWrite payload) #parseJSONList :: Value -> Parser [ApiJobWrite payload] #omittedField :: Maybe (ApiJobWrite payload) | |
| ToJSON payload => ToJSON (ApiJobWrite payload) Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ApiJobWrite payload -> Value #toEncoding :: ApiJobWrite payload -> Encoding #toJSONList :: [ApiJobWrite payload] -> Value #toEncodingList :: [ApiJobWrite payload] -> Encoding #omitField :: ApiJobWrite payload -> Bool | |
| Eq payload => Eq (ApiJobWrite payload) Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: ApiJobWrite payload -> ApiJobWrite payload -> Bool #(/=) :: ApiJobWrite payload -> ApiJobWrite payload -> Bool | |
| Show payload => Show (ApiJobWrite payload) Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ApiJobWrite payload -> ShowS #show :: ApiJobWrite payload -> String #showList :: [ApiJobWrite payload] -> ShowS | |
Source #data ArchiveResponse payload
Response wrapper for archived jobs.
Constructors
| ArchiveResponse | |
Fields
| |
Instances
| FromJSON payload => FromJSON (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (ArchiveResponse payload) #parseJSONList :: Value -> Parser [ArchiveResponse payload] #omittedField :: Maybe (ArchiveResponse payload) | |||||
| ToJSON payload => ToJSON (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: ArchiveResponse payload -> Value #toEncoding :: ArchiveResponse payload -> Encoding #toJSONList :: [ArchiveResponse payload] -> Value #toEncodingList :: [ArchiveResponse payload] -> Encoding #omitField :: ArchiveResponse payload -> Bool | |||||
| Eq payload => Eq (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: ArchiveResponse payload -> ArchiveResponse payload -> Bool #(/=) :: ArchiveResponse payload -> ArchiveResponse payload -> Bool | |||||
| Generic (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: ArchiveResponse payload -> Rep (ArchiveResponse payload) x #to :: Rep (ArchiveResponse payload) x -> ArchiveResponse payload | |||||
| Show payload => Show (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ArchiveResponse payload -> ShowS #show :: ArchiveResponse payload -> String #showList :: [ArchiveResponse payload] -> ShowS | |||||
| type Rep (ArchiveResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (ArchiveResponse payload) = D1 ('MetaData "ArchiveResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ArchiveResponse" 'PrefixI 'True) ((S1 ('MetaSel ('Just "archiveJobs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ApiArchiveJob payload]) :*: S1 ('MetaSel ('Just "archiveTotal") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)) :*: (S1 ('MetaSel ('Just "archiveOffset") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :*: S1 ('MetaSel ('Just "archiveLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))) | |||||
Source #data BatchDeleteRequest
Request body for batch DLQ delete.
Constructors
| BatchDeleteRequest | |
Instances
| FromJSON BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser BatchDeleteRequest #parseJSONList :: Value -> Parser [BatchDeleteRequest] | |||||
| ToJSON BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: BatchDeleteRequest -> Value #toEncoding :: BatchDeleteRequest -> Encoding #toJSONList :: [BatchDeleteRequest] -> Value #toEncodingList :: [BatchDeleteRequest] -> Encoding #omitField :: BatchDeleteRequest -> Bool | |||||
| Eq BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: BatchDeleteRequest -> BatchDeleteRequest -> Bool #(/=) :: BatchDeleteRequest -> BatchDeleteRequest -> Bool | |||||
| Generic BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: BatchDeleteRequest -> Rep BatchDeleteRequest x #to :: Rep BatchDeleteRequest x -> BatchDeleteRequest | |||||
| Show BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> BatchDeleteRequest -> ShowS #show :: BatchDeleteRequest -> String #showList :: [BatchDeleteRequest] -> ShowS | |||||
| type Rep BatchDeleteRequest Source # | |||||
Defined in Arbiter.Servant.Types type Rep BatchDeleteRequest = D1 ('MetaData "BatchDeleteRequest" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "BatchDeleteRequest" 'PrefixI 'True) (S1 ('MetaSel ('Just "ids") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Int64]))) | |||||
Source #data BatchDeleteResponse
Response body for batch DLQ delete.
Constructors
| BatchDeleteResponse | |
Instances
| FromJSON BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser BatchDeleteResponse #parseJSONList :: Value -> Parser [BatchDeleteResponse] | |||||
| ToJSON BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: BatchDeleteResponse -> Value #toEncoding :: BatchDeleteResponse -> Encoding #toJSONList :: [BatchDeleteResponse] -> Value | |||||
| Eq BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: BatchDeleteResponse -> BatchDeleteResponse -> Bool #(/=) :: BatchDeleteResponse -> BatchDeleteResponse -> Bool | |||||
| Generic BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: BatchDeleteResponse -> Rep BatchDeleteResponse x #to :: Rep BatchDeleteResponse x -> BatchDeleteResponse | |||||
| Show BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> BatchDeleteResponse -> ShowS #show :: BatchDeleteResponse -> String #showList :: [BatchDeleteResponse] -> ShowS | |||||
| type Rep BatchDeleteResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep BatchDeleteResponse = D1 ('MetaData "BatchDeleteResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "BatchDeleteResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "deleted") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))) | |||||
Source #newtype BatchInsertRequest payload
Request body for batch job insert.
Constructors
| BatchInsertRequest | |
Fields
| |
Instances
| FromJSON payload => FromJSON (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (BatchInsertRequest payload) #parseJSONList :: Value -> Parser [BatchInsertRequest payload] #omittedField :: Maybe (BatchInsertRequest payload) | |||||
| ToJSON payload => ToJSON (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: BatchInsertRequest payload -> Value #toEncoding :: BatchInsertRequest payload -> Encoding #toJSONList :: [BatchInsertRequest payload] -> Value #toEncodingList :: [BatchInsertRequest payload] -> Encoding #omitField :: BatchInsertRequest payload -> Bool | |||||
| Eq payload => Eq (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: BatchInsertRequest payload -> BatchInsertRequest payload -> Bool #(/=) :: BatchInsertRequest payload -> BatchInsertRequest payload -> Bool | |||||
| Generic (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: BatchInsertRequest payload -> Rep (BatchInsertRequest payload) x #to :: Rep (BatchInsertRequest payload) x -> BatchInsertRequest payload | |||||
| Show payload => Show (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> BatchInsertRequest payload -> ShowS #show :: BatchInsertRequest payload -> String #showList :: [BatchInsertRequest payload] -> ShowS | |||||
| type Rep (BatchInsertRequest payload) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (BatchInsertRequest payload) = D1 ('MetaData "BatchInsertRequest" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'True) (C1 ('MetaCons "BatchInsertRequest" 'PrefixI 'True) (S1 ('MetaSel ('Just "jobWrites") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ApiJobWrite payload]))) | |||||
Source #data BatchInsertResponse payload
Response body for batch job insert.
Constructors
| BatchInsertResponse | |
Fields
| |
Instances
| FromJSON payload => FromJSON (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (BatchInsertResponse payload) #parseJSONList :: Value -> Parser [BatchInsertResponse payload] #omittedField :: Maybe (BatchInsertResponse payload) | |||||
| ToJSON payload => ToJSON (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: BatchInsertResponse payload -> Value #toEncoding :: BatchInsertResponse payload -> Encoding #toJSONList :: [BatchInsertResponse payload] -> Value #toEncodingList :: [BatchInsertResponse payload] -> Encoding #omitField :: BatchInsertResponse payload -> Bool | |||||
| Eq payload => Eq (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: BatchInsertResponse payload -> BatchInsertResponse payload -> Bool #(/=) :: BatchInsertResponse payload -> BatchInsertResponse payload -> Bool | |||||
| Generic (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: BatchInsertResponse payload -> Rep (BatchInsertResponse payload) x #to :: Rep (BatchInsertResponse payload) x -> BatchInsertResponse payload | |||||
| Show payload => Show (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> BatchInsertResponse payload -> ShowS #show :: BatchInsertResponse payload -> String #showList :: [BatchInsertResponse payload] -> ShowS | |||||
| type Rep (BatchInsertResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (BatchInsertResponse payload) = D1 ('MetaData "BatchInsertResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "BatchInsertResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "inserted") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ApiJob payload]) :*: S1 ('MetaSel ('Just "insertedCount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int))) | |||||
Source #data ClaimRequest
A consumer's request to lease visible jobs.
Constructors
| ClaimRequest | |
Instances
| FromJSON ClaimRequest Source # | |
Defined in Arbiter.Servant.Types | |
| ToJSON ClaimRequest Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ClaimRequest -> Value #toEncoding :: ClaimRequest -> Encoding #toJSONList :: [ClaimRequest] -> Value #toEncodingList :: [ClaimRequest] -> Encoding #omitField :: ClaimRequest -> Bool | |
| Eq ClaimRequest Source # | |
Defined in Arbiter.Servant.Types | |
| Show ClaimRequest Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ClaimRequest -> ShowS #show :: ClaimRequest -> String #showList :: [ClaimRequest] -> ShowS | |
Source #newtype ClaimResponse payload
Jobs returned by one claim. Each job contains the lease fields required for finalization.
Constructors
| ClaimResponse | |
Fields
| |
Instances
| FromJSON payload => FromJSON (ClaimResponse payload) Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (ClaimResponse payload) #parseJSONList :: Value -> Parser [ClaimResponse payload] #omittedField :: Maybe (ClaimResponse payload) | |
| ToJSON payload => ToJSON (ClaimResponse payload) Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ClaimResponse payload -> Value #toEncoding :: ClaimResponse payload -> Encoding #toJSONList :: [ClaimResponse payload] -> Value #toEncodingList :: [ClaimResponse payload] -> Encoding #omitField :: ClaimResponse payload -> Bool | |
| Eq payload => Eq (ClaimResponse payload) Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: ClaimResponse payload -> ClaimResponse payload -> Bool #(/=) :: ClaimResponse payload -> ClaimResponse payload -> Bool | |
| Show payload => Show (ClaimResponse payload) Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ClaimResponse payload -> ShowS #show :: ClaimResponse payload -> String #showList :: [ClaimResponse payload] -> ShowS | |
Source #data ConcurrencyKeysResponse
Concurrency keys response (one prefix's keys).
Constructors
| ConcurrencyKeysResponse | |
Fields
| |
Instances
| FromJSON ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: ConcurrencyKeysResponse -> Value #toEncoding :: ConcurrencyKeysResponse -> Encoding #toJSONList :: [ConcurrencyKeysResponse] -> Value | |||||
| Eq ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: ConcurrencyKeysResponse -> ConcurrencyKeysResponse -> Bool #(/=) :: ConcurrencyKeysResponse -> ConcurrencyKeysResponse -> Bool | |||||
| Generic ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: ConcurrencyKeysResponse -> Rep ConcurrencyKeysResponse x #to :: Rep ConcurrencyKeysResponse x -> ConcurrencyKeysResponse | |||||
| Show ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ConcurrencyKeysResponse -> ShowS #show :: ConcurrencyKeysResponse -> String #showList :: [ConcurrencyKeysResponse] -> ShowS | |||||
| type Rep ConcurrencyKeysResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep ConcurrencyKeysResponse = D1 ('MetaData "ConcurrencyKeysResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyKeysResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "keys") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ConcurrencyKeyView]))) | |||||
Source #data ConcurrencyPoliciesResponse
Concurrency pools response.
Constructors
| ConcurrencyPoliciesResponse | |
Fields | |
Instances
| FromJSON ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Eq ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Generic ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ConcurrencyPoliciesResponse -> ShowS | |||||
| type Rep ConcurrencyPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep ConcurrencyPoliciesResponse = D1 ('MetaData "ConcurrencyPoliciesResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyPoliciesResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "policies") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ConcurrencyPolicyView]))) | |||||
Source #data ConcurrencyReconcileResponse
Number of count rows repaired from live jobs.
Constructors
| ConcurrencyReconcileResponse | |
Fields
| |
Instances
| FromJSON ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Eq ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Generic ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ConcurrencyReconcileResponse -> ShowS | |||||
| type Rep ConcurrencyReconcileResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep ConcurrencyReconcileResponse = D1 ('MetaData "ConcurrencyReconcileResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyReconcileResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "reconciled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))) | |||||
Source #data CronScheduleView
A cron schedule row plus the next tick its effective expression fires at. An expression that never fires again, or one the server cannot parse, has none.
Constructors
| CronScheduleView | |
Fields | |
Instances
| FromJSON CronScheduleView Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser CronScheduleView #parseJSONList :: Value -> Parser [CronScheduleView] | |||||
| ToJSON CronScheduleView Source # | The row's own fields, with | ||||
Defined in Arbiter.Servant.Types Methods #toJSON :: CronScheduleView -> Value #toEncoding :: CronScheduleView -> Encoding #toJSONList :: [CronScheduleView] -> Value #toEncodingList :: [CronScheduleView] -> Encoding #omitField :: CronScheduleView -> Bool | |||||
| Eq CronScheduleView Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: CronScheduleView -> CronScheduleView -> Bool #(/=) :: CronScheduleView -> CronScheduleView -> Bool | |||||
| Generic CronScheduleView Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: CronScheduleView -> Rep CronScheduleView x #to :: Rep CronScheduleView x -> CronScheduleView | |||||
| Show CronScheduleView Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> CronScheduleView -> ShowS #show :: CronScheduleView -> String #showList :: [CronScheduleView] -> ShowS | |||||
| type Rep CronScheduleView Source # | |||||
Defined in Arbiter.Servant.Types type Rep CronScheduleView = D1 ('MetaData "CronScheduleView" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "CronScheduleView" 'PrefixI 'True) (S1 ('MetaSel ('Just "schedule") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 CronScheduleRow) :*: S1 ('MetaSel ('Just "nextRunAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)))) | |||||
Source #data CronSchedulesResponse
Cron schedules response.
Constructors
| CronSchedulesResponse | |
Fields | |
Instances
| FromJSON CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser CronSchedulesResponse | |||||
| ToJSON CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: CronSchedulesResponse -> Value #toEncoding :: CronSchedulesResponse -> Encoding #toJSONList :: [CronSchedulesResponse] -> Value | |||||
| Eq CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: CronSchedulesResponse -> CronSchedulesResponse -> Bool #(/=) :: CronSchedulesResponse -> CronSchedulesResponse -> Bool | |||||
| Generic CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: CronSchedulesResponse -> Rep CronSchedulesResponse x | |||||
| Show CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> CronSchedulesResponse -> ShowS #show :: CronSchedulesResponse -> String #showList :: [CronSchedulesResponse] -> ShowS | |||||
| type Rep CronSchedulesResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep CronSchedulesResponse = D1 ('MetaData "CronSchedulesResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "CronSchedulesResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "cronSchedules") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [CronScheduleView]))) | |||||
Source #data DLQResponse payload
Response wrapper for DLQ jobs.
Constructors
| DLQResponse | |
Instances
| FromJSON payload => FromJSON (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (DLQResponse payload) #parseJSONList :: Value -> Parser [DLQResponse payload] #omittedField :: Maybe (DLQResponse payload) | |||||
| ToJSON payload => ToJSON (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: DLQResponse payload -> Value #toEncoding :: DLQResponse payload -> Encoding #toJSONList :: [DLQResponse payload] -> Value #toEncodingList :: [DLQResponse payload] -> Encoding #omitField :: DLQResponse payload -> Bool | |||||
| Eq payload => Eq (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: DLQResponse payload -> DLQResponse payload -> Bool #(/=) :: DLQResponse payload -> DLQResponse payload -> Bool | |||||
| Generic (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: DLQResponse payload -> Rep (DLQResponse payload) x #to :: Rep (DLQResponse payload) x -> DLQResponse payload | |||||
| Show payload => Show (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> DLQResponse payload -> ShowS #show :: DLQResponse payload -> String #showList :: [DLQResponse payload] -> ShowS | |||||
| type Rep (DLQResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (DLQResponse payload) = D1 ('MetaData "DLQResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "DLQResponse" 'PrefixI 'True) ((S1 ('MetaSel ('Just "dlqJobs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ApiDLQJob payload]) :*: S1 ('MetaSel ('Just "dlqTotal") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)) :*: (S1 ('MetaSel ('Just "dlqOffset") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :*: S1 ('MetaSel ('Just "dlqLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))) | |||||
Source #data ExtendRequest
A lease plus the window to hide the job for, counted from now.
Constructors
| ExtendRequest | |
Instances
| FromJSON ExtendRequest Source # | |
Defined in Arbiter.Servant.Types | |
| ToJSON ExtendRequest Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: ExtendRequest -> Value #toEncoding :: ExtendRequest -> Encoding #toJSONList :: [ExtendRequest] -> Value #toEncodingList :: [ExtendRequest] -> Encoding #omitField :: ExtendRequest -> Bool | |
| Eq ExtendRequest Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: ExtendRequest -> ExtendRequest -> Bool #(/=) :: ExtendRequest -> ExtendRequest -> Bool | |
| Show ExtendRequest Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> ExtendRequest -> ShowS #show :: ExtendRequest -> String #showList :: [ExtendRequest] -> ShowS | |
Source #data HealthResponse
Readiness of the API and the database behind it.
Constructors
| HealthResponse | |
Fields
| |
Instances
| FromJSON HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser HealthResponse #parseJSONList :: Value -> Parser [HealthResponse] | |||||
| ToJSON HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: HealthResponse -> Value #toEncoding :: HealthResponse -> Encoding #toJSONList :: [HealthResponse] -> Value #toEncodingList :: [HealthResponse] -> Encoding #omitField :: HealthResponse -> Bool | |||||
| Eq HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: HealthResponse -> HealthResponse -> Bool #(/=) :: HealthResponse -> HealthResponse -> Bool | |||||
| Generic HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> HealthResponse -> ShowS #show :: HealthResponse -> String #showList :: [HealthResponse] -> ShowS | |||||
| type Rep HealthResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep HealthResponse = D1 ('MetaData "HealthResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "HealthResponse" 'PrefixI 'True) ((S1 ('MetaSel ('Just "status") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HealthStatus) :*: S1 ('MetaSel ('Just "schemaName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :*: (S1 ('MetaSel ('Just "checkedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: (S1 ('MetaSel ('Just "dbLatencyMs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :*: S1 ('MetaSel ('Just "db") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe PgDbHealth)))))) | |||||
Source #data HealthStatus
Whether the API can reach its database.
Instances
| FromJSON HealthStatus Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON HealthStatus Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: HealthStatus -> Value #toEncoding :: HealthStatus -> Encoding #toJSONList :: [HealthStatus] -> Value #toEncodingList :: [HealthStatus] -> Encoding #omitField :: HealthStatus -> Bool | |||||
| Eq HealthStatus Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Generic HealthStatus Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show HealthStatus Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> HealthStatus -> ShowS #show :: HealthStatus -> String #showList :: [HealthStatus] -> ShowS | |||||
| type Rep HealthStatus Source # | |||||
Proof that the caller still holds a claimed job.
Constructors
| JobLease | |
Fields
| |
Source #newtype JobResponse a
Single-job response envelope, parameterized over the job representation
(ApiJob for insert, ApiJobWithStatus for the detail endpoint).
Constructors
| JobResponse | |
Fields
| |
Instances
| FromJSON a => FromJSON (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (JobResponse a) #parseJSONList :: Value -> Parser [JobResponse a] #omittedField :: Maybe (JobResponse a) | |||||
| ToJSON a => ToJSON (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: JobResponse a -> Value #toEncoding :: JobResponse a -> Encoding #toJSONList :: [JobResponse a] -> Value #toEncodingList :: [JobResponse a] -> Encoding #omitField :: JobResponse a -> Bool | |||||
| Eq a => Eq (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: JobResponse a -> JobResponse a -> Bool #(/=) :: JobResponse a -> JobResponse a -> Bool | |||||
| Generic (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show a => Show (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> JobResponse a -> ShowS #show :: JobResponse a -> String #showList :: [JobResponse a] -> ShowS | |||||
| type Rep (JobResponse a) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (JobResponse a) = D1 ('MetaData "JobResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'True) (C1 ('MetaCons "JobResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "job") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a))) | |||||
Source #data JobsResponse payload
Response wrapper for multiple jobs.
Constructors
| JobsResponse | |
Fields
| |
Instances
| FromJSON payload => FromJSON (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser (JobsResponse payload) #parseJSONList :: Value -> Parser [JobsResponse payload] #omittedField :: Maybe (JobsResponse payload) | |||||
| ToJSON payload => ToJSON (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: JobsResponse payload -> Value #toEncoding :: JobsResponse payload -> Encoding #toJSONList :: [JobsResponse payload] -> Value #toEncodingList :: [JobsResponse payload] -> Encoding #omitField :: JobsResponse payload -> Bool | |||||
| Eq payload => Eq (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: JobsResponse payload -> JobsResponse payload -> Bool #(/=) :: JobsResponse payload -> JobsResponse payload -> Bool | |||||
| Generic (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: JobsResponse payload -> Rep (JobsResponse payload) x #to :: Rep (JobsResponse payload) x -> JobsResponse payload | |||||
| Show payload => Show (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> JobsResponse payload -> ShowS #show :: JobsResponse payload -> String #showList :: [JobsResponse payload] -> ShowS | |||||
| type Rep (JobsResponse payload) Source # | |||||
Defined in Arbiter.Servant.Types type Rep (JobsResponse payload) = D1 ('MetaData "JobsResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "JobsResponse" 'PrefixI 'True) ((S1 ('MetaSel ('Just "jobs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [ApiJobWithStatus payload]) :*: (S1 ('MetaSel ('Just "jobsTotal") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :*: S1 ('MetaSel ('Just "jobsOffset") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int))) :*: ((S1 ('MetaSel ('Just "jobsLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :*: S1 ('MetaSel ('Just "childCounts") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map Int64 Int64))) :*: (S1 ('MetaSel ('Just "pausedParents") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Int64]) :*: S1 ('MetaSel ('Just "dlqChildCounts") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map Int64 Int64)))))) | |||||
Source #data LivenessResponse
The process is running. Answered without touching the database.
Constructors
| LivenessResponse | |
Instances
| FromJSON LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser LivenessResponse #parseJSONList :: Value -> Parser [LivenessResponse] | |||||
| ToJSON LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: LivenessResponse -> Value #toEncoding :: LivenessResponse -> Encoding #toJSONList :: [LivenessResponse] -> Value #toEncodingList :: [LivenessResponse] -> Encoding #omitField :: LivenessResponse -> Bool | |||||
| Eq LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: LivenessResponse -> LivenessResponse -> Bool #(/=) :: LivenessResponse -> LivenessResponse -> Bool | |||||
| Generic LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: LivenessResponse -> Rep LivenessResponse x #to :: Rep LivenessResponse x -> LivenessResponse | |||||
| Show LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> LivenessResponse -> ShowS #show :: LivenessResponse -> String #showList :: [LivenessResponse] -> ShowS | |||||
| type Rep LivenessResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep LivenessResponse = D1 ('MetaData "LivenessResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "LivenessResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "alive") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool))) | |||||
Source #data MaintenanceResponse
Rows each maintenance operation touched, and the operations that raised. An operation in neither was skipped.
Constructors
| MaintenanceResponse | |
Fields
| |
Instances
| FromJSON MaintenanceResponse Source # | |
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser MaintenanceResponse #parseJSONList :: Value -> Parser [MaintenanceResponse] | |
| ToJSON MaintenanceResponse Source # | |
Defined in Arbiter.Servant.Types Methods #toJSON :: MaintenanceResponse -> Value #toEncoding :: MaintenanceResponse -> Encoding #toJSONList :: [MaintenanceResponse] -> Value | |
| Eq MaintenanceResponse Source # | |
Defined in Arbiter.Servant.Types Methods #(==) :: MaintenanceResponse -> MaintenanceResponse -> Bool #(/=) :: MaintenanceResponse -> MaintenanceResponse -> Bool | |
| Show MaintenanceResponse Source # | |
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> MaintenanceResponse -> ShowS #show :: MaintenanceResponse -> String #showList :: [MaintenanceResponse] -> ShowS | |
Source #data QueuesResponse
Queues list response.
Constructors
| QueuesResponse | |
Instances
| FromJSON QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser QueuesResponse #parseJSONList :: Value -> Parser [QueuesResponse] | |||||
| ToJSON QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: QueuesResponse -> Value #toEncoding :: QueuesResponse -> Encoding #toJSONList :: [QueuesResponse] -> Value #toEncodingList :: [QueuesResponse] -> Encoding #omitField :: QueuesResponse -> Bool | |||||
| Eq QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: QueuesResponse -> QueuesResponse -> Bool #(/=) :: QueuesResponse -> QueuesResponse -> Bool | |||||
| Generic QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> QueuesResponse -> ShowS #show :: QueuesResponse -> String #showList :: [QueuesResponse] -> ShowS | |||||
| type Rep QueuesResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep QueuesResponse = D1 ('MetaData "QueuesResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "QueuesResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "queues") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Text]))) | |||||
Source #data RateLimitBucketsResponse
Rate-limit buckets response (one prefix's keys).
Constructors
| RateLimitBucketsResponse | |
Fields | |
Instances
| FromJSON RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: RateLimitBucketsResponse -> Value #toEncoding :: RateLimitBucketsResponse -> Encoding #toJSONList :: [RateLimitBucketsResponse] -> Value | |||||
| Eq RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: RateLimitBucketsResponse -> RateLimitBucketsResponse -> Bool #(/=) :: RateLimitBucketsResponse -> RateLimitBucketsResponse -> Bool | |||||
| Generic RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: RateLimitBucketsResponse -> Rep RateLimitBucketsResponse x #to :: Rep RateLimitBucketsResponse x -> RateLimitBucketsResponse | |||||
| Show RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> RateLimitBucketsResponse -> ShowS #show :: RateLimitBucketsResponse -> String #showList :: [RateLimitBucketsResponse] -> ShowS | |||||
| type Rep RateLimitBucketsResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep RateLimitBucketsResponse = D1 ('MetaData "RateLimitBucketsResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitBucketsResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "buckets") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [RateLimitBucketView]))) | |||||
Source #data RateLimitPoliciesResponse
Rate-limit policies response.
Constructors
| RateLimitPoliciesResponse | |
Fields | |
Instances
| FromJSON RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| Eq RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: RateLimitPoliciesResponse -> RateLimitPoliciesResponse -> Bool #(/=) :: RateLimitPoliciesResponse -> RateLimitPoliciesResponse -> Bool | |||||
| Generic RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: RateLimitPoliciesResponse -> Rep RateLimitPoliciesResponse x #to :: Rep RateLimitPoliciesResponse x -> RateLimitPoliciesResponse | |||||
| Show RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> RateLimitPoliciesResponse -> ShowS #show :: RateLimitPoliciesResponse -> String #showList :: [RateLimitPoliciesResponse] -> ShowS | |||||
| type Rep RateLimitPoliciesResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep RateLimitPoliciesResponse = D1 ('MetaData "RateLimitPoliciesResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitPoliciesResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "policies") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [RateLimitPolicyView]))) | |||||
Source #data RateLimitResetResponse
Number of buckets cleared by a reset.
Constructors
| RateLimitResetResponse | |
Instances
| FromJSON RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: RateLimitResetResponse -> Value #toEncoding :: RateLimitResetResponse -> Encoding #toJSONList :: [RateLimitResetResponse] -> Value | |||||
| Eq RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: RateLimitResetResponse -> RateLimitResetResponse -> Bool #(/=) :: RateLimitResetResponse -> RateLimitResetResponse -> Bool | |||||
| Generic RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: RateLimitResetResponse -> Rep RateLimitResetResponse x #to :: Rep RateLimitResetResponse x -> RateLimitResetResponse | |||||
| Show RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> RateLimitResetResponse -> ShowS #show :: RateLimitResetResponse -> String #showList :: [RateLimitResetResponse] -> ShowS | |||||
| type Rep RateLimitResetResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep RateLimitResetResponse = D1 ('MetaData "RateLimitResetResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitResetResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "reset") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))) | |||||
Source #data StatsResponse
Queue statistics response.
Constructors
| StatsResponse | |
Fields
| |
Instances
| FromJSON StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types | |||||
| ToJSON StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: StatsResponse -> Value #toEncoding :: StatsResponse -> Encoding #toJSONList :: [StatsResponse] -> Value #toEncodingList :: [StatsResponse] -> Encoding #omitField :: StatsResponse -> Bool | |||||
| Eq StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: StatsResponse -> StatsResponse -> Bool #(/=) :: StatsResponse -> StatsResponse -> Bool | |||||
| Generic StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
| |||||
| Show StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> StatsResponse -> ShowS #show :: StatsResponse -> String #showList :: [StatsResponse] -> ShowS | |||||
| type Rep StatsResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep StatsResponse = D1 ('MetaData "StatsResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "StatsResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "stats") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 QueueStats) :*: S1 ('MetaSel ('Just "timestamp") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))) | |||||
Source #data WorkersResponse
Worker registry response.
Constructors
| WorkersResponse | |
Instances
| FromJSON WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #parseJSON :: Value -> Parser WorkersResponse #parseJSONList :: Value -> Parser [WorkersResponse] | |||||
| ToJSON WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #toJSON :: WorkersResponse -> Value #toEncoding :: WorkersResponse -> Encoding #toJSONList :: [WorkersResponse] -> Value #toEncodingList :: [WorkersResponse] -> Encoding #omitField :: WorkersResponse -> Bool | |||||
| Eq WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #(==) :: WorkersResponse -> WorkersResponse -> Bool #(/=) :: WorkersResponse -> WorkersResponse -> Bool | |||||
| Generic WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types Associated Types
Methods #from :: WorkersResponse -> Rep WorkersResponse x #to :: Rep WorkersResponse x -> WorkersResponse | |||||
| Show WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types Methods #showsPrec :: Int -> WorkersResponse -> ShowS #show :: WorkersResponse -> String #showList :: [WorkersResponse] -> ShowS | |||||
| type Rep WorkersResponse Source # | |||||
Defined in Arbiter.Servant.Types type Rep WorkersResponse = D1 ('MetaData "WorkersResponse" "Arbiter.Servant.Types" "arbiter-servant-0.1.0.0-inplace" 'False) (C1 ('MetaCons "WorkersResponse" 'PrefixI 'True) (S1 ('MetaSel ('Just "workers") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [WorkerRow]))) | |||||
#data CronScheduleRow
A row from the cron_schedules table.
Constructors
| CronScheduleRow | |
Fields
| |
Instances
| FromJSON CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule Methods #parseJSON :: Value -> Parser CronScheduleRow #parseJSONList :: Value -> Parser [CronScheduleRow] | |||||
| ToJSON CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule Methods #toJSON :: CronScheduleRow -> Value #toEncoding :: CronScheduleRow -> Encoding #toJSONList :: [CronScheduleRow] -> Value #toEncodingList :: [CronScheduleRow] -> Encoding #omitField :: CronScheduleRow -> Bool | |||||
| Eq CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule Methods #(==) :: CronScheduleRow -> CronScheduleRow -> Bool #(/=) :: CronScheduleRow -> CronScheduleRow -> Bool | |||||
| Generic CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule Associated Types
Methods #from :: CronScheduleRow -> Rep CronScheduleRow x #to :: Rep CronScheduleRow x -> CronScheduleRow | |||||
| Show CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule Methods #showsPrec :: Int -> CronScheduleRow -> ShowS #show :: CronScheduleRow -> String #showList :: [CronScheduleRow] -> ShowS | |||||
| type Rep CronScheduleRow # | |||||
Defined in Arbiter.Core.CronSchedule type Rep CronScheduleRow = D1 ('MetaData "CronScheduleRow" "Arbiter.Core.CronSchedule" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "CronScheduleRow" 'PrefixI 'True) (((S1 ('MetaSel ('Just "name") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "queueName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "defaultExpression") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text))) :*: ((S1 ('MetaSel ('Just "defaultOverlap") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "defaultTimezone") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Text))) :*: (S1 ('MetaSel ('Just "overrideExpression") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Text)) :*: S1 ('MetaSel ('Just "overrideOverlap") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Text))))) :*: (((S1 ('MetaSel ('Just "overrideTimezone") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Text)) :*: S1 ('MetaSel ('Just "enabled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool)) :*: (S1 ('MetaSel ('Just "lastFiredAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)) :*: S1 ('MetaSel ('Just "lastCheckedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)))) :*: ((S1 ('MetaSel ('Just "runRequestedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)) :*: S1 ('MetaSel ('Just "lastManualRunAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime))) :*: (S1 ('MetaSel ('Just "createdAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "updatedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))))) | |||||
#data CronScheduleUpdate
A patch over a cron schedule's overrides. Nothing leaves a field unchanged, Just
Nothing clears the override back to the default, Just (Just v) sets it.
Constructors
| CronScheduleUpdate | |
Fields
| |
Instances
| FromJSON CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule Methods #parseJSON :: Value -> Parser CronScheduleUpdate #parseJSONList :: Value -> Parser [CronScheduleUpdate] | |||||
| ToJSON CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule Methods #toJSON :: CronScheduleUpdate -> Value #toEncoding :: CronScheduleUpdate -> Encoding #toJSONList :: [CronScheduleUpdate] -> Value #toEncodingList :: [CronScheduleUpdate] -> Encoding #omitField :: CronScheduleUpdate -> Bool | |||||
| Eq CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule Methods #(==) :: CronScheduleUpdate -> CronScheduleUpdate -> Bool #(/=) :: CronScheduleUpdate -> CronScheduleUpdate -> Bool | |||||
| Generic CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule Associated Types
Methods #from :: CronScheduleUpdate -> Rep CronScheduleUpdate x #to :: Rep CronScheduleUpdate x -> CronScheduleUpdate | |||||
| Show CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule Methods #showsPrec :: Int -> CronScheduleUpdate -> ShowS #show :: CronScheduleUpdate -> String #showList :: [CronScheduleUpdate] -> ShowS | |||||
| type Rep CronScheduleUpdate # | |||||
Defined in Arbiter.Core.CronSchedule type Rep CronScheduleUpdate = D1 ('MetaData "CronScheduleUpdate" "Arbiter.Core.CronSchedule" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "CronScheduleUpdate" 'PrefixI 'True) ((S1 ('MetaSel ('Just "overrideExpression") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Text))) :*: S1 ('MetaSel ('Just "overrideOverlap") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Text)))) :*: (S1 ('MetaSel ('Just "overrideTimezone") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Text))) :*: S1 ('MetaSel ('Just "enabled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Bool))))) | |||||
#data QueueOverview
A landing-overview row: a queue's stats plus its pause state.
Constructors
| QueueOverview | |
Fields | |
Instances
| FromJSON QueueOverview # | |||||
Defined in Arbiter.Core.Operations | |||||
| ToJSON QueueOverview # | |||||
Defined in Arbiter.Core.Operations Methods #toJSON :: QueueOverview -> Value #toEncoding :: QueueOverview -> Encoding #toJSONList :: [QueueOverview] -> Value #toEncodingList :: [QueueOverview] -> Encoding #omitField :: QueueOverview -> Bool | |||||
| Eq QueueOverview # | |||||
Defined in Arbiter.Core.Operations Methods #(==) :: QueueOverview -> QueueOverview -> Bool #(/=) :: QueueOverview -> QueueOverview -> Bool | |||||
| Generic QueueOverview # | |||||
Defined in Arbiter.Core.Operations Associated Types
| |||||
| Show QueueOverview # | |||||
Defined in Arbiter.Core.Operations Methods #showsPrec :: Int -> QueueOverview -> ShowS #show :: QueueOverview -> String #showList :: [QueueOverview] -> ShowS | |||||
| type Rep QueueOverview # | |||||
Defined in Arbiter.Core.Operations type Rep QueueOverview = D1 ('MetaData "QueueOverview" "Arbiter.Core.Operations" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "QueueOverview" 'PrefixI 'True) ((S1 ('MetaSel ('Just "overviewQueue") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "overviewStats") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 QueueStats)) :*: (S1 ('MetaSel ('Just "overviewQueuePaused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :*: (S1 ('MetaSel ('Just "overviewWorkersLive") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "overviewWorkersPaused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))))) | |||||
A row of the arbiter_queues pause/resume table.
Constructors
| QueueRow | |
Instances
| FromJSON QueueRow # | |||||
Defined in Arbiter.Core.Queues | |||||
| ToJSON QueueRow # | |||||
| Eq QueueRow # | |||||
| Generic QueueRow # | |||||
Defined in Arbiter.Core.Queues Associated Types
| |||||
| Show QueueRow # | |||||
| type Rep QueueRow # | |||||
Defined in Arbiter.Core.Queues type Rep QueueRow = D1 ('MetaData "QueueRow" "Arbiter.Core.Queues" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "QueueRow" 'PrefixI 'True) ((S1 ('MetaSel ('Just "queueName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "paused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :*: S1 ('MetaSel ('Just "pausedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)))) :*: (S1 ('MetaSel ('Just "metadata") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)) :*: (S1 ('MetaSel ('Just "createdAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "updatedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime))))) | |||||
A row in the worker registry. One row per running worker pool.
Constructors
| WorkerRow | |
Fields
| |
Instances
| FromJSON WorkerRow # | |||||
Defined in Arbiter.Core.Worker | |||||
| ToJSON WorkerRow # | |||||
| Eq WorkerRow # | |||||
| Generic WorkerRow # | |||||
Defined in Arbiter.Core.Worker Associated Types
| |||||
| Show WorkerRow # | |||||
| type Rep WorkerRow # | |||||
Defined in Arbiter.Core.Worker type Rep WorkerRow = D1 ('MetaData "WorkerRow" "Arbiter.Core.Worker" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "WorkerRow" 'PrefixI 'True) (((S1 ('MetaSel ('Just "workerId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UUID) :*: S1 ('MetaSel ('Just "queueName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :*: (S1 ('MetaSel ('Just "hostName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Text)) :*: (S1 ('MetaSel ('Just "workerCount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Int32)) :*: S1 ('MetaSel ('Just "startedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))) :*: ((S1 ('MetaSel ('Just "lastHeartbeat") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: (S1 ('MetaSel ('Just "shuttingDown") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :*: S1 ('MetaSel ('Just "paused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool))) :*: (S1 ('MetaSel ('Just "staleThresholdSecs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double) :*: (S1 ('MetaSel ('Just "metadata") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)) :*: S1 ('MetaSel ('Just "health") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 WorkerHealth)))))) | |||||
#data RateLimitPolicyView
A policy with its default and override params plus live bucket and throttle
stats. The effective param is override when set, else default.
Constructors
| RateLimitPolicyView | |
Fields | |
Instances
| FromJSON RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #parseJSON :: Value -> Parser RateLimitPolicyView #parseJSONList :: Value -> Parser [RateLimitPolicyView] | |||||
| ToJSON RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #toJSON :: RateLimitPolicyView -> Value #toEncoding :: RateLimitPolicyView -> Encoding #toJSONList :: [RateLimitPolicyView] -> Value | |||||
| Eq RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #(==) :: RateLimitPolicyView -> RateLimitPolicyView -> Bool #(/=) :: RateLimitPolicyView -> RateLimitPolicyView -> Bool | |||||
| Generic RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Associated Types
Methods #from :: RateLimitPolicyView -> Rep RateLimitPolicyView x #to :: Rep RateLimitPolicyView x -> RateLimitPolicyView | |||||
| Show RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #showsPrec :: Int -> RateLimitPolicyView -> ShowS #show :: RateLimitPolicyView -> String #showList :: [RateLimitPolicyView] -> ShowS | |||||
| type Rep RateLimitPolicyView # | |||||
Defined in Arbiter.Core.RateLimit.Stats type Rep RateLimitPolicyView = D1 ('MetaData "RateLimitPolicyView" "Arbiter.Core.RateLimit.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitPolicyView" 'PrefixI 'True) (((S1 ('MetaSel ('Just "prefix") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "defaultMaxTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double)) :*: (S1 ('MetaSel ('Just "defaultRefillAmount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double) :*: (S1 ('MetaSel ('Just "defaultInterval") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double) :*: S1 ('MetaSel ('Just "overrideMaxTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double))))) :*: ((S1 ('MetaSel ('Just "overrideRefillAmount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :*: (S1 ('MetaSel ('Just "overrideInterval") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :*: S1 ('MetaSel ('Just "bucketCount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))) :*: (S1 ('MetaSel ('Just "throttledCount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: (S1 ('MetaSel ('Just "minTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :*: S1 ('MetaSel ('Just "avgTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double))))))) | |||||
#data RateLimitBucketView
A single key's bucket: current tokens, effective max, and fill fraction.
Constructors
| RateLimitBucketView | |
Fields
| |
Instances
| FromJSON RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #parseJSON :: Value -> Parser RateLimitBucketView #parseJSONList :: Value -> Parser [RateLimitBucketView] | |||||
| ToJSON RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #toJSON :: RateLimitBucketView -> Value #toEncoding :: RateLimitBucketView -> Encoding #toJSONList :: [RateLimitBucketView] -> Value | |||||
| Eq RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #(==) :: RateLimitBucketView -> RateLimitBucketView -> Bool #(/=) :: RateLimitBucketView -> RateLimitBucketView -> Bool | |||||
| Generic RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Associated Types
Methods #from :: RateLimitBucketView -> Rep RateLimitBucketView x #to :: Rep RateLimitBucketView x -> RateLimitBucketView | |||||
| Show RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #showsPrec :: Int -> RateLimitBucketView -> ShowS #show :: RateLimitBucketView -> String #showList :: [RateLimitBucketView] -> ShowS | |||||
| type Rep RateLimitBucketView # | |||||
Defined in Arbiter.Core.RateLimit.Stats type Rep RateLimitBucketView = D1 ('MetaData "RateLimitBucketView" "Arbiter.Core.RateLimit.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitBucketView" 'PrefixI 'True) ((S1 ('MetaSel ('Just "rateLimitKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "policyPrefix") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "tokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double))) :*: (S1 ('MetaSel ('Just "maxTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double) :*: (S1 ('MetaSel ('Just "fillFraction") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :*: S1 ('MetaSel ('Just "lastRefill") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime))))) | |||||
A patch over a policy's override params. Per field: Nothing leaves it
unchanged, Just Nothing clears the override (reverts to the default), and
Just (Just v) sets it.
Constructors
| RateLimitPolicyUpdate | |
Fields
| |
Instances
| FromJSON RateLimitPolicyUpdate # | Hand-written. A missing key leaves the field unchanged. An explicit | ||||
Defined in Arbiter.Core.RateLimit.Stats Methods #parseJSON :: Value -> Parser RateLimitPolicyUpdate | |||||
| ToJSON RateLimitPolicyUpdate # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #toJSON :: RateLimitPolicyUpdate -> Value #toEncoding :: RateLimitPolicyUpdate -> Encoding #toJSONList :: [RateLimitPolicyUpdate] -> Value | |||||
| Eq RateLimitPolicyUpdate # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #(==) :: RateLimitPolicyUpdate -> RateLimitPolicyUpdate -> Bool #(/=) :: RateLimitPolicyUpdate -> RateLimitPolicyUpdate -> Bool | |||||
| Generic RateLimitPolicyUpdate # | |||||
Defined in Arbiter.Core.RateLimit.Stats Associated Types
Methods #from :: RateLimitPolicyUpdate -> Rep RateLimitPolicyUpdate x | |||||
| Show RateLimitPolicyUpdate # | |||||
Defined in Arbiter.Core.RateLimit.Stats Methods #showsPrec :: Int -> RateLimitPolicyUpdate -> ShowS #show :: RateLimitPolicyUpdate -> String #showList :: [RateLimitPolicyUpdate] -> ShowS | |||||
| type Rep RateLimitPolicyUpdate # | |||||
Defined in Arbiter.Core.RateLimit.Stats type Rep RateLimitPolicyUpdate = D1 ('MetaData "RateLimitPolicyUpdate" "Arbiter.Core.RateLimit.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "RateLimitPolicyUpdate" 'PrefixI 'True) (S1 ('MetaSel ('Just "overrideMaxTokens") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Double))) :*: (S1 ('MetaSel ('Just "overrideRefillAmount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Double))) :*: S1 ('MetaSel ('Just "overrideInterval") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Double)))))) | |||||
A pool with its default and override limits plus live key and in-flight stats.
The effective cap is override when set, else default.
Constructors
| ConcurrencyPolicyView | |
Fields
| |
Instances
| FromJSON ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #parseJSON :: Value -> Parser ConcurrencyPolicyView | |||||
| ToJSON ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #toJSON :: ConcurrencyPolicyView -> Value #toEncoding :: ConcurrencyPolicyView -> Encoding #toJSONList :: [ConcurrencyPolicyView] -> Value | |||||
| Eq ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #(==) :: ConcurrencyPolicyView -> ConcurrencyPolicyView -> Bool #(/=) :: ConcurrencyPolicyView -> ConcurrencyPolicyView -> Bool | |||||
| Generic ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Associated Types
Methods #from :: ConcurrencyPolicyView -> Rep ConcurrencyPolicyView x | |||||
| Show ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #showsPrec :: Int -> ConcurrencyPolicyView -> ShowS #show :: ConcurrencyPolicyView -> String #showList :: [ConcurrencyPolicyView] -> ShowS | |||||
| type Rep ConcurrencyPolicyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats type Rep ConcurrencyPolicyView = D1 ('MetaData "ConcurrencyPolicyView" "Arbiter.Core.Concurrency.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyPolicyView" 'PrefixI 'True) ((S1 ('MetaSel ('Just "prefix") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "defaultLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int32) :*: S1 ('MetaSel ('Just "overrideLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Int32)))) :*: (S1 ('MetaSel ('Just "keyCount") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: (S1 ('MetaSel ('Just "totalInFlight") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "maxInFlight") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Int32)))))) | |||||
#data ConcurrencyKeyView
A single key's in-flight count, its effective cap, and fill fraction.
Constructors
| ConcurrencyKeyView | |
Fields
| |
Instances
| FromJSON ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #parseJSON :: Value -> Parser ConcurrencyKeyView #parseJSONList :: Value -> Parser [ConcurrencyKeyView] | |||||
| ToJSON ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #toJSON :: ConcurrencyKeyView -> Value #toEncoding :: ConcurrencyKeyView -> Encoding #toJSONList :: [ConcurrencyKeyView] -> Value #toEncodingList :: [ConcurrencyKeyView] -> Encoding #omitField :: ConcurrencyKeyView -> Bool | |||||
| Eq ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #(==) :: ConcurrencyKeyView -> ConcurrencyKeyView -> Bool #(/=) :: ConcurrencyKeyView -> ConcurrencyKeyView -> Bool | |||||
| Generic ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Associated Types
Methods #from :: ConcurrencyKeyView -> Rep ConcurrencyKeyView x #to :: Rep ConcurrencyKeyView x -> ConcurrencyKeyView | |||||
| Show ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #showsPrec :: Int -> ConcurrencyKeyView -> ShowS #show :: ConcurrencyKeyView -> String #showList :: [ConcurrencyKeyView] -> ShowS | |||||
| type Rep ConcurrencyKeyView # | |||||
Defined in Arbiter.Core.Concurrency.Stats type Rep ConcurrencyKeyView = D1 ('MetaData "ConcurrencyKeyView" "Arbiter.Core.Concurrency.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyKeyView" 'PrefixI 'True) ((S1 ('MetaSel ('Just "concurrencyKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: S1 ('MetaSel ('Just "concurrencyPrefix") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)) :*: (S1 ('MetaSel ('Just "inFlight") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int32) :*: (S1 ('MetaSel ('Just "effectiveLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int32) :*: S1 ('MetaSel ('Just "fillFraction") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)))))) | |||||
A patch over a pool's override limit. Nothing leaves it unchanged, Just
Nothing clears the override (reverts to the default), Just (Just v) sets it.
Constructors
| ConcurrencyPolicyUpdate | |
Fields
| |
Instances
| FromJSON ConcurrencyPolicyUpdate # | Hand-written. A missing key leaves the field unchanged. An explicit | ||||
Defined in Arbiter.Core.Concurrency.Stats | |||||
| ToJSON ConcurrencyPolicyUpdate # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #toJSON :: ConcurrencyPolicyUpdate -> Value #toEncoding :: ConcurrencyPolicyUpdate -> Encoding #toJSONList :: [ConcurrencyPolicyUpdate] -> Value | |||||
| Eq ConcurrencyPolicyUpdate # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #(==) :: ConcurrencyPolicyUpdate -> ConcurrencyPolicyUpdate -> Bool #(/=) :: ConcurrencyPolicyUpdate -> ConcurrencyPolicyUpdate -> Bool | |||||
| Generic ConcurrencyPolicyUpdate # | |||||
Defined in Arbiter.Core.Concurrency.Stats Associated Types
Methods #from :: ConcurrencyPolicyUpdate -> Rep ConcurrencyPolicyUpdate x #to :: Rep ConcurrencyPolicyUpdate x -> ConcurrencyPolicyUpdate | |||||
| Show ConcurrencyPolicyUpdate # | |||||
Defined in Arbiter.Core.Concurrency.Stats Methods #showsPrec :: Int -> ConcurrencyPolicyUpdate -> ShowS #show :: ConcurrencyPolicyUpdate -> String #showList :: [ConcurrencyPolicyUpdate] -> ShowS | |||||
| type Rep ConcurrencyPolicyUpdate # | |||||
Defined in Arbiter.Core.Concurrency.Stats type Rep ConcurrencyPolicyUpdate = D1 ('MetaData "ConcurrencyPolicyUpdate" "Arbiter.Core.Concurrency.Stats" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ConcurrencyPolicyUpdate" 'PrefixI 'True) (S1 ('MetaSel ('Just "overrideLimit") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe (Maybe Int32))))) | |||||
#data PgDbHealth
Connection and age counters for the current database, shared with its other clients.
Constructors
| PgDbHealth | |
Fields
| |
Instances
| FromJSON PgDbHealth # | |||||
Defined in Arbiter.Core.Health | |||||
| ToJSON PgDbHealth # | |||||
Defined in Arbiter.Core.Health Methods #toJSON :: PgDbHealth -> Value #toEncoding :: PgDbHealth -> Encoding #toJSONList :: [PgDbHealth] -> Value #toEncodingList :: [PgDbHealth] -> Encoding #omitField :: PgDbHealth -> Bool | |||||
| Eq PgDbHealth # | |||||
Defined in Arbiter.Core.Health | |||||
| Generic PgDbHealth # | |||||
Defined in Arbiter.Core.Health Associated Types
| |||||
| Show PgDbHealth # | |||||
Defined in Arbiter.Core.Health Methods #showsPrec :: Int -> PgDbHealth -> ShowS #show :: PgDbHealth -> String #showList :: [PgDbHealth] -> ShowS | |||||
| type Rep PgDbHealth # | |||||
Defined in Arbiter.Core.Health type Rep PgDbHealth = D1 ('MetaData "PgDbHealth" "Arbiter.Core.Health" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "PgDbHealth" 'PrefixI 'True) (((S1 ('MetaSel ('Just "numBackends") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "connActive") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64)) :*: (S1 ('MetaSel ('Just "connIdle") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "connIdleInTxn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64))) :*: ((S1 ('MetaSel ('Just "connIdleInTxnAborted") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "connBlocked") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64)) :*: (S1 ('MetaSel ('Just "connOther") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: (S1 ('MetaSel ('Just "oldestTxnAge") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double) :*: S1 ('MetaSel ('Just "oldestQueryAge") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Double)))))) | |||||