connector

Documentation

Index

• type Pump
• type PumpImpl
  • func NewPumpImpl(logger *zap.SugaredLogger) *PumpImpl
  • func (impl PumpImpl) StartMessage(w http.ResponseWriter, resp proto.Message, perr error)
  • func (impl PumpImpl) StartStream(w http.ResponseWriter, recv func() (proto.Message, error), err error)
  • func (impl PumpImpl) StartStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, ...)

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 (impl PumpImpl) StartMessage(w http.ResponseWriter, resp proto.Message, perr error)

func (PumpImpl) StartStream

func (impl PumpImpl) StartStream(w http.ResponseWriter, recv func() (proto.Message, error), err error)

func (PumpImpl) StartStreamWithHeartBeat

func (impl PumpImpl) StartStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, recv func() (*application.LogEntry, error), err error)