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
- type MachineryLogger
- func (m *MachineryLogger) Fatal(args ...any)
- func (m *MachineryLogger) Fatalf(format string, args ...any)
- func (m *MachineryLogger) Fatalln(args ...any)
- func (m *MachineryLogger) Panic(args ...any)
- func (m *MachineryLogger) Panicf(format string, args ...any)
- func (m *MachineryLogger) Panicln(args ...any)
- func (m *MachineryLogger) Print(args ...any)
- func (m *MachineryLogger) Printf(format string, args ...any)
- func (m *MachineryLogger) Println(args ...any)
- type PreheatRequest
- type PreheatResponse
- type Queue
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 UnmarshalRequest ¶
Types ¶
type GroupJobState ¶
type Job ¶
type Job struct { Server *machinery.Server Worker *machinery.Worker Queue Queue }
func (*Job) GetGroupJobState ¶
func (t *Job) GetGroupJobState(groupID string) (*GroupJobState, 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 { }
Click to show internal directories.
Click to hide internal directories.