format

Documentation

Index

• func ParseWriteFormat(format string, escape rune) (func([]byte, *kgo.Record, *kgo.FetchPartition) []byte, error)
• type Reader
  • func NewReader(infmt string, escape rune, maxBuf int, reader io.Reader, tombstone bool) (*Reader, error)
  • func (r *Reader) Next() (*kgo.Record, error)
  • func (r *Reader) ParsesTopic() bool
  • func (r *Reader) SetReader(reader io.Reader)

Functions

func ParseWriteFormat

func ParseWriteFormat(format string, escape rune) (func([]byte, *kgo.Record, *kgo.FetchPartition) []byte, error)

Types

type Reader

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

func NewReader

func NewReader(infmt string, escape rune, maxBuf int, reader io.Reader, tombstone bool) (*Reader, error)

func (*Reader) Next

func (r *Reader) Next() (*kgo.Record, error)

func (*Reader) ParsesTopic

func (r *Reader) ParsesTopic() bool

func (*Reader) SetReader

func (r *Reader) SetReader(reader io.Reader)