Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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
Directories
Click to show internal directories.
Click to hide internal directories.