process

Apr 19, 2025

Changes in this version

+ type MethodConfig struct

+ Name []Name

+ RetryPolicy RetryPolicyDef

+ WaitForReady bool

+ type Name struct

+ Service string

+ type RetryPolicy struct

+ MethodConfig []MethodConfig

+ type RetryPolicyDef struct

+ BackoffMultiplier float64

+ InitialBackoff string

+ MaxAttempts int

+ MaxBackoff string

+ RetryableStatusCodes []string

Jan 9, 2024

Changes in this version

+ func LoadTimeOut(cancel func())

Oct 26, 2023

Changes in this version

+ func Exec(task *pb.Task) (result int, err error)

+ func RepeatHeartBeat(grpcDriver *client.GRPCDriver, queueID string, taskID string, ...)

+ func Work(grpcDriver *client.GRPCDriver, queueID string, workType string) (result int, err error)