ttlscheduler

package
v0.0.0-...-0172641 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2020 License: GPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RunGRPC 

func RunGRPC(port int)

RunGRPC start the grpc endpoint

Types

type NodeFetcher 

type NodeFetcher interface {
	GetNodes() ([]*pb.Node, error)
}

NodeFetcher builds up the node list form a source e.g. kubernetes pods

type Scheduler 

type Scheduler interface {
	NodeBindings(context.Context, *pb.NodeBindingRequest) (*pb.NodeBindingResponse, error)
	BindStream(*pb.Stream) (*pb.Binding, error)
	Optimise() error
	Observe() error
}

Scheduler basic structure of a scheduler

func NewScheduler 

func NewScheduler(nf NodeFetcher, sf StreamFetcher) Scheduler

NewScheduler constructs a new scheduler which can assign streams work nodes

type StreamFetcher 

type StreamFetcher interface {
	GetStreams() ([]*pb.Stream, error)
}

StreamFetcher provides intereface to fetch stream lists

Source Files

View all Source files

Directories

Path Synopsis
Package evntsrc_ttlscheduler is a generated protocol buffer package.
 Package evntsrc_ttlscheduler is a generated protocol buffer package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.