input

Documentation

Index

• type Message
• type Parser
  • func NewCsvParser(key string, separator string) Parser
  • func NewJSONParser() Parser

Types

type Message

type Message struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

type Parser

type Parser interface {
	ParseLine(line string) (Message, error)
}

func NewCsvParser

func NewCsvParser(key string, separator string) Parser

func NewJSONParser

func NewJSONParser() Parser