connector

package
v0.0.0-...-c85924f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 28, 2021 License: Apache-2.0 Imports: 15 Imported by: 0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL