structs

package
v0.0.0-...-84c575d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 19, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EncodeTaskMessage

func EncodeTaskMessage(msg *TaskMessage) (string, error)

Types

type ServerInfo

type ServerInfo struct {
}

type ServerStatus

type ServerStatus struct {
	// contains filtered or unexported fields
}

ServerStatus represents status of a server. It is concurrency safe.

func NewServerStatus

func NewServerStatus(v ServerStatusValue) *ServerStatus

NewServerStatus returns a new status instance given an initial value.

func (*ServerStatus) Get

Get returns the status value.

func (*ServerStatus) Set

func (s *ServerStatus) Set(v ServerStatusValue)

Set sets the status value.

func (*ServerStatus) String

func (s *ServerStatus) String() string

type ServerStatusValue

type ServerStatusValue int
const (
	// StatusIdle indicates the server is in idle state.
	StatusIdle ServerStatusValue = iota

	// StatusRunning indicates the server is up and active.
	StatusRunning

	// StatusQuiet indicates the server is up but not active.
	StatusQuiet

	// StatusStopped indicates the server server has been stopped.
	StatusStopped
)

type TaskMessage

type TaskMessage struct {
	// 唯一ID
	ID uuid.UUID

	// 此 task 所在的 queue 名称,可以不指定,此时会使用默认值 `default`
	// 这个字段的作用是给这个任务起一个名字,相当于 namespace。常见的场景是,当我们想停掉某个任务时,传入对应的名字就能区分
	QueueName string

	// task 类型
	Type TaskMessageType

	// 唯一标识这个 msg
	UniqueKey string

	// 剩余重试次数
	CanRetry int

	// 上一次失败时的错误
	LastErrMsg error

	// 每次执行的 timeout,单位为 s。0 表示没有超时时间
	Timeout int64

	//
	Deadline int64

	// 这个 task 中存储的数据
	Payload map[string]interface{}
}

func DocodeTaskMessage

func DocodeTaskMessage(s string) (*TaskMessage, error)

type TaskMessageType

type TaskMessageType string

func (TaskMessageType) String

func (tt TaskMessageType) String() string

type WorkerInfo

type WorkerInfo struct {
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL