util

Documentation

Index

• Constants
• func CopyBuffer(src io.Reader, dst io.Writer) (err error)
• func ReadMessage(reader io.Reader) (res []byte, err error)
• func ReadObject(reader io.Reader, obj interface{}) error
• func WriteEOFMessage(writer io.Writer) (err error)
• func WriteMessage(writer io.Writer, msg []byte) (err error)
• func WriteObject(writer io.Writer, obj interface{}) error
• type Heap
  • func NewHeap() *Heap
  • func (h *Heap) GetExecutorLoc() *pb.Location
  • func (h *Heap) HasExecutor() bool
  • func (h *Heap) Len() int
  • func (h *Heap) Less(i, j int) bool
  • func (h *Heap) Pop() interface{}
  • func (h *Heap) Push(item interface{})
  • func (h *Heap) Swap(i, j int)
• type Item
  • func NewItem(loc *pb.Location, num int) *Item

Constants

const (
	MessageEOF = math.MinInt32
	BufferSize = 1024 * 512
)

Functions

func CopyBuffer

func CopyBuffer(src io.Reader, dst io.Writer) (err error)

func ReadMessage

func ReadMessage(reader io.Reader) (res []byte, err error)

func ReadObject

func ReadObject(reader io.Reader, obj interface{}) error

func WriteEOFMessage

func WriteEOFMessage(writer io.Writer) (err error)

func WriteMessage

func WriteMessage(writer io.Writer, msg []byte) (err error)

func WriteObject

func WriteObject(writer io.Writer, obj interface{}) error

Types

type Heap

type Heap struct {
	Items    []*Item
	AgentMap map[string]*pb.Location
}

func NewHeap

func NewHeap() *Heap

func (*Heap) GetExecutorLoc

func (h *Heap) GetExecutorLoc() *pb.Location

func (*Heap) HasExecutor

func (h *Heap) HasExecutor() bool

func (*Heap) Len

func (h *Heap) Len() int

func (*Heap) Less

func (h *Heap) Less(i, j int) bool

func (*Heap) Pop

func (h *Heap) Pop() interface{}

func (*Heap) Push

func (h *Heap) Push(item interface{})

func (*Heap) Swap

func (h *Heap) Swap(i, j int)

type Item

type Item struct {
	Location       *pb.Location
	ExecutorNumber int
}

func NewItem

func NewItem(loc *pb.Location, num int) *Item