connector

Documentation

Index

• type Pump
• type PumpImpl
  • func NewPumpImpl(logger *zap.SugaredLogger) *PumpImpl
  • func (impl PumpImpl) StartK8sStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, stream io.ReadCloser, err error)
  • 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, ...)
  • func (impl PumpImpl) StartStreamWithTransformer(w http.ResponseWriter, recv func() (proto.Message, error), err error, ...)

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)
	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

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

func NewPumpImpl

func NewPumpImpl(logger *zap.SugaredLogger) *PumpImpl

func (PumpImpl) StartK8sStreamWithHeartBeat

func (impl PumpImpl) StartK8sStreamWithHeartBeat(w http.ResponseWriter, isReconnect bool, stream io.ReadCloser, err error)

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)

func (PumpImpl) StartStreamWithTransformer

func (impl PumpImpl) StartStreamWithTransformer(w http.ResponseWriter, recv func() (proto.Message, error), err error, transformer func(interface{}) interface{})