parser

Documentation

Index

• func ParseStream(reader io.Reader) <-chan *Payload
• type Payload

Functions

func ParseStream

func ParseStream(reader io.Reader) <-chan *Payload

ParseStream reads data from io.Reader and send payloads through channel

Types

type Payload

type Payload struct {
	Data reply.Reply
	Err  error
}

Payload stores redis.Reply or error