job

package

v2.1.43 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dragonflyoss/Dragonfly2

Documentation ¶

Index ¶

Constants
func MarshalRequest(v any) ([]machineryv1tasks.Arg, error)
func MarshalResponse(v any) (string, error)
func UnmarshalRequest(data string, v any) error
func UnmarshalResponse(data []reflect.Value, v any) error
type Config
type GroupJobState
type Job
- func New(cfg *Config, queue Queue) (*Job, error)
type MachineryLogger
type PreheatRequest
type PreheatResponse
type Queue
- func GetSchedulerQueue(clusterID uint, hostname string) (Queue, error)
- func (q Queue) String() string

Constants ¶

View Source

const (
	GlobalQueue     = Queue("global")
	SchedulersQueue = Queue("schedulers")
)

Queue Name.

View Source

const (
	// PreheatJob is the name of preheat job.
	PreheatJob = "preheat"

	// SyncPeersJob is the name of syncing peers job.
	SyncPeersJob = "sync_peers"
)

Job Name.

View Source

const (
	DefaultResultsExpireIn     = 86400
	DefaultRedisMaxIdle        = 10
	DefaultRedisIdleTimeout    = 300
	DefaultRedisReadTimeout    = 60
	DefaultRedisWriteTimeout   = 60
	DefaultRedisConnectTimeout = 60
)

Machinery server configuration.

Variables ¶

This section is empty.

Functions ¶

func MarshalRequest ¶

func MarshalRequest(v any) ([]machineryv1tasks.Arg, error)

func MarshalResponse ¶ added in v2.0.30

func MarshalResponse(v any) (string, error)

func UnmarshalRequest ¶

func UnmarshalRequest(data string, v any) error

func UnmarshalResponse ¶

func UnmarshalResponse(data []reflect.Value, v any) error

Types ¶

type Config ¶

type Config struct {
	Addrs      []string
	MasterName string
	Username   string
	Password   string
	BrokerDB   int
	BackendDB  int
}

type GroupJobState ¶

type GroupJobState struct {
	GroupUUID string
	State     string
	CreatedAt time.Time
	JobStates []*machineryv1tasks.TaskState
}

type Job ¶

type Job struct {
	Server *machinery.Server
	Worker *machinery.Worker
	Queue  Queue
}

func New ¶

func New(cfg *Config, queue Queue) (*Job, error)

func (*Job) GetGroupJobState ¶

func (t *Job) GetGroupJobState(groupID string) (*GroupJobState, error)

func (*Job) LaunchWorker ¶

func (t *Job) LaunchWorker(consumerTag string, concurrency int) error

func (*Job) RegisterJob ¶

func (t *Job) RegisterJob(namedJobFuncs map[string]any) error

type MachineryLogger ¶ added in v2.0.1

type MachineryLogger struct{}

func (*MachineryLogger) Fatal ¶ added in v2.0.1

func (m *MachineryLogger) Fatal(args ...any)

Fatal sends to logger.Fatal

func (*MachineryLogger) Fatalf ¶ added in v2.0.1

func (m *MachineryLogger) Fatalf(format string, args ...any)

Fatalf sends to logger.Fatalf

func (*MachineryLogger) Fatalln ¶ added in v2.0.1

func (m *MachineryLogger) Fatalln(args ...any)

Fatalln sends to logger.Fatal

func (*MachineryLogger) Panic ¶ added in v2.0.1

func (m *MachineryLogger) Panic(args ...any)

Panic sends to logger.Panic

func (*MachineryLogger) Panicf ¶ added in v2.0.1

func (m *MachineryLogger) Panicf(format string, args ...any)

Panicf sends to logger.Panic

func (*MachineryLogger) Panicln ¶ added in v2.0.1

func (m *MachineryLogger) Panicln(args ...any)

Panicln sends to logger.Panic

func (*MachineryLogger) Print ¶ added in v2.0.1

func (m *MachineryLogger) Print(args ...any)

Print sends to logger.Info

func (*MachineryLogger) Printf ¶ added in v2.0.1

func (m *MachineryLogger) Printf(format string, args ...any)

Printf sends to logger.Infof

func (*MachineryLogger) Println ¶ added in v2.0.1

func (m *MachineryLogger) Println(args ...any)

Println sends to logger.Info

type PreheatRequest ¶

type PreheatRequest struct {
	URL                 string            `json:"url" validate:"required,url"`
	Tag                 string            `json:"tag" validate:"omitempty"`
	Digest              string            `json:"digest" validate:"omitempty"`
	FilteredQueryParams string            `json:"filteredQueryParams" validate:"omitempty"`
	Headers             map[string]string `json:"headers" validate:"omitempty"`
	Application         string            `json:"application" validate:"omitempty"`
	Priority            int32             `json:"priority" validate:"omitempty"`
	PieceLength         uint32            `json:"pieceLength" validate:"omitempty"`
}

type PreheatResponse ¶

type PreheatResponse struct {
}

type Queue ¶

type Queue string

func GetSchedulerQueue ¶

func GetSchedulerQueue(clusterID uint, hostname string) (Queue, error)

func (Queue) String ¶

func (q Queue) String() string

Source Files ¶

View all Source files

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