Function runWriterMode

cmd/test-streammanager/main-test-streammanager.go:183–205

(config TestConfig, writerBroker *streamclient.Broker, streamMeta *wshrpc.StreamMeta)

}

func runWriterMode(config TestConfig, writerBroker *streamclient.Broker, streamMeta *wshrpc.StreamMeta) chan error {
	writer, err := writerBroker.CreateStreamWriter(streamMeta)
	if err != nil {
		fmt.Printf("failed to create stream writer: %v\n", err)
		return nil
	}
	fmt.Printf("  Stream writer created\n")

	generator := NewTestDataGenerator(config.DataSize)

	done := make(chan error, 1)
	go func() {
		_, copyErr := io.Copy(writer, generator)
		closeErr := writer.Close()
		if copyErr != nil && copyErr != io.EOF {
			done <- copyErr
		} else {
			done <- closeErr
		}
	}()

	return done
}

// BrokerDataSender implements DataSender interface
type BrokerDataSender struct {