func main()

in test-sending-tool/main.go [28:55]


func main() {
	filenamePtr := flag.String("file", "", "File whose contents will be sent")
	streamNamePtr := flag.String("stream", "", "Stream to send the data to")
	flag.Parse()

	//get credentails from default chain - https://docs.aws.amazon.com/sdk-for-go/api/
	sess, sessionErr := session.NewSession()
	if sessionErr != nil {
		log.Fatal("Could not set up AWS session: ", sessionErr)
	}

	svc := kinesis.New(sess)

	contentPtr := get_file(*filenamePtr)
	partKey := "1"
	rq := &kinesis.PutRecordInput{
		Data:         *contentPtr,
		PartitionKey: &partKey,
		StreamName:   streamNamePtr,
	}

	log.Printf("Sending to %s", *streamNamePtr)
	_, sendErr := svc.PutRecord(rq)
	if sendErr != nil {
		log.Fatal("Could not send to stream: ", sendErr)
	}
	log.Print("Successfully sent")
}