datasetsvc

package main

import (
	"github.com/leftronic/dataset-api/datasetsvc"
	"google.golang.org/grpc"
	"context"
	"fmt"
	"encoding/json"
)

func main() {
	opts := []grpc.DialOption{grpc.WithInsecure()}
	clientConnection, err := grpc.Dial(":10000", opts...)

	datasetClient := datasetsvc.NewDataSetSvcClient(clientConnection)
	listRowsClient, err :=  datasetClient.ListRows(context.Background(), &datasetsvc.ListRowsRequest{SourceId: "", TargetId:"", Name: "test"})

	for {
		row, err := listRowsClient.Recv()
		if err != nil {
			// check for actual errors
			// IO - EOF no more to receive ?
			break
		}

		fmt.Println(row) // struct with data field as []byte

		var rowData []interface{}

		marshallError := json.Unmarshal(row.Data, rowData)
		if marshallError != nil {
			break
		}

		fmt.Println(rowData)
	}
}