KSQL go client

A barebones go client for interacting with Confluent's KSQL

Examples

List all Streams

	c := ksql.NewClient("http://localhost:8088")
	log.Println("=>>> Streams")
	streams, err := c.ListStreams()
	if err != nil {
		log.Fatal(err)
	}
	for i, v := range streams {
		log.Printf("Stream %d: %s", i, v.Name)
	}

List all Tables

	c := ksql.NewClient("http://localhost:8088")
	log.Println("=>>> Tables")
	tables, err := c.ListTables()
	if err != nil {
		log.Fatal(err)
	}
	for i, v := range tables {
		log.Printf("Table %d: %s", i, v.Name)
	}

Query stream

	c := ksql.NewClient("http://localhost:8088")
	log.Println("=>>> Forever Query :")
	ch := make(chan *ksql.QueryResponse)
	go c.Query(ksql.Request{KSQL: "SELECT pageid FROM pageviews_original;"}, ch)
	for {
		select {
		case msg := <-ch:
			log.Println(msg.Row)
		}
	}