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)
	StartStreamWithTransformer(w http.ResponseWriter, recv func() (proto.Message, error), err error, transformer func(interface{}) interface{})
	StartK8sStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, stream io.ReadCloser, err error)
}

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