reader

Documentation

Index

• type InterfaceReader
• type PulsarReader
  • func NewPulsarReader(queue string, client pulsar.Client, runLog *logger.Logger) *PulsarReader
  • func (r *PulsarReader) Close()
  • func (r *PulsarReader) ReadLine() (string, error)
• type RdsReader
  • func NewRdsReader(queue string, rds *redis.Client, runLog *logger.Logger) *RdsReader
  • func (r *RdsReader) Close()
  • func (r *RdsReader) ReadLine() (string, error)

Types

type InterfaceReader

type InterfaceReader interface {
	ReadLine() (string, error)
	Close()
}

type PulsarReader

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

func NewPulsarReader

func NewPulsarReader(
	queue string,
	client pulsar.Client,
	runLog *logger.Logger,
) *PulsarReader

func (*PulsarReader) Close

func (r *PulsarReader) Close()

func (*PulsarReader) ReadLine

func (r *PulsarReader) ReadLine() (string, error)

type RdsReader

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

func NewRdsReader

func NewRdsReader(
	queue string,
	rds *redis.Client,
	runLog *logger.Logger,
) *RdsReader

func (*RdsReader) Close

func (r *RdsReader) Close()

func (*RdsReader) ReadLine

func (r *RdsReader) ReadLine() (string, error)