connector

type Pump interface {
	StartStream(w http.ResponseWriter, recv func() (proto.Message, error), err error)
	StartStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, recv func() (*application.LogEntry, error), err error)
	StartMessage(w http.ResponseWriter, resp proto.Message, perr error)
}

type PumpImpl struct {
	// contains filtered or unexported fields
}