Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( RegisterValidator = func(v *validator.Validate) { if err := v.RegisterValidation("isValidTaskQueueState", ValidTaskQueueState); err != nil { panic(err) } } Validator = func() *validator.Validate { v := validator.New() RegisterValidator(v) return v }() )
Functions ¶
func ValidTaskQueueState ¶
func ValidTaskQueueState(fl validator.FieldLevel) bool
func ValidateQueueName ¶
func ValidateQueueName(queueName string) *util.ValidationError
Types ¶
type TaskQueue ¶
type TaskQueue struct { // UID is uuid of the queue. This can distinguish two queues with the same name in different lifecycle. UID uuid.UUID `json:"uid" yaml:"uid" validate:"required"` Spec TaskQueueSpec Status TaskQueueStatus }
func NewTaskQueue ¶
func NewTaskQueue(queueSpec TaskQueueSpec) *TaskQueue
type TaskQueueSpec ¶
type TaskQueueSpec struct { Name string `json:"name" validate:"required,min=1,max=256,excludesall=:"` State TaskQueueState `json:"state" validate:"isValidTaskQueueState,required"` }
func NewTaskQueueSpec ¶
func NewTaskQueueSpec(name string, state TaskQueueState) TaskQueueSpec
func (TaskQueueSpec) Validate ¶
func (s TaskQueueSpec) Validate() *util.ValidationError
type TaskQueueState ¶
type TaskQueueState string
const ( TaskQueueStateActive TaskQueueState = "active" TaskQueueStateSuspend TaskQueueState = "suspend" )
type TaskQueueStatus ¶
type TaskToDeadletterError ¶
func NewTaskToDeadletterError ¶
func NewTaskToDeadletterError(body string, err error) TaskToDeadletterError
func (TaskToDeadletterError) DLItem ¶
func (e TaskToDeadletterError) DLItem() string
func (TaskToDeadletterError) Error ¶
func (e TaskToDeadletterError) Error() string
Click to show internal directories.
Click to hide internal directories.