scheduling

package
v1.0.15 Latest Latest
Warning

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

Go to latest
Published: Aug 17, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConstructSuccessNormalTaskResponse

func ConstructSuccessNormalTaskResponse(dynconfig config.DynconfigInterface, candidateParents []*resource.Peer) *schedulerv2.AnnouncePeerResponse_NormalTaskResponse

ConstructSuccessNormalTaskResponse constructs scheduling successful response of the normal task. Used only in v2 version of the grpc.

func ConstructSuccessPeerPacket

func ConstructSuccessPeerPacket(dynconfig config.DynconfigInterface, peer *resource.Peer, parent *resource.Peer, candidateParents []*resource.Peer) *schedulerv1.PeerPacket

ConstructSuccessPeerPacket constructs peer successful packet. Used only in v1 version of the grpc.

func ConstructSuccessSmallTaskResponse

func ConstructSuccessSmallTaskResponse(candidateParent *resource.Peer) *schedulerv2.AnnouncePeerResponse_SmallTaskResponse

ConstructSuccessSmallTaskResponse constructs scheduling successful response of the small task. Used only in v2 version of the grpc.

Types

type Scheduling

type Scheduling interface {
	// ScheduleCandidateParents schedules candidate parents to the normal peer.
	// Used only in v2 version of the grpc.
	ScheduleCandidateParents(context.Context, *resource.Peer, set.SafeSet[string]) error

	// ScheduleParentAndCandidateParents schedules a parent and candidate parents to the normal peer.
	// Used only in v1 version of the grpc.
	ScheduleParentAndCandidateParents(context.Context, *resource.Peer, set.SafeSet[string])

	// FindCandidateParents finds candidate parents for the peer.
	FindCandidateParents(context.Context, *resource.Peer, set.SafeSet[string]) ([]*resource.Peer, bool)

	// FindSuccessParent finds success parent for the peer.
	FindSuccessParent(context.Context, *resource.Peer, set.SafeSet[string]) (*resource.Peer, bool)
}

func New

func New(cfg *config.SchedulerConfig, dynconfig config.DynconfigInterface, pluginDir string) Scheduling

Directories

Path Synopsis
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.

Jump to

Keyboard shortcuts

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