model

Documentation

Index

• type Blob
• type Message
• type MessageAttr
  • func (n *MessageAttr) Scan(value any) error
  • func (n MessageAttr) Value() (driver.Value, error)
• type MessageStatus

Types

type Blob

type Blob struct {
	Digest   string `json:"digest"`
	Progress int64  `json:"progress"`
	Size     int64  `json:"size"`
	Error    string `json:"error,omitempty"`
}

type Message

type Message struct {
	MessageID     int64
	Content       string
	Lease         string
	Priority      int
	Status        MessageStatus
	Data          MessageAttr
	LastHeartbeat time.Time
}

type MessageAttr

type MessageAttr struct {
	Error string `json:"error,omitempty"`

	Host     string `json:"host,omitempty"`
	Image    string `json:"image,omitempty"`
	Progress int64  `json:"progress,omitempty"`
	Size     int64  `json:"size,omitempty"`

	Spec []byte `json:"spec,omitempty"`

	// Deprecate
	Blobs []Blob `json:"blobs,omitempty"`
}

func (*MessageAttr) Scan

func (n *MessageAttr) Scan(value any) error

func (MessageAttr) Value

func (n MessageAttr) Value() (driver.Value, error)

type MessageStatus

type MessageStatus uint64

const (
	StatusPending    MessageStatus = 0
	StatusProcessing MessageStatus = 10
	StatusCompleted  MessageStatus = 20
	StatusFailed     MessageStatus = 30
	StatusCleanup    MessageStatus = 90
)