Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pump ¶
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 ¶
type PumpImpl struct {
// contains filtered or unexported fields
}
func NewPumpImpl ¶
func NewPumpImpl(logger *zap.SugaredLogger) *PumpImpl
func (PumpImpl) StartMessage ¶
func (PumpImpl) StartStream ¶
func (PumpImpl) StartStreamWithHeartBeat ¶
func (impl PumpImpl) StartStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, recv func() (*application.LogEntry, error), err error)
Click to show internal directories.
Click to hide internal directories.