rename streamService (#6)

Co-authored-by: Lovro Mažgon <lovro.mazgon@gmail.com>

destination.go

@@ -36,7 +36,7 @@ type Destination struct {
 
 	config Config
 	conn   *grpc.ClientConn
-	stream pb.StreamService_StreamClient
+	stream pb.SourceService_StreamClient
 
 	// for testing: always empty, unless it's a test
 	dialer func(ctx context.Context, _ string) (net.Conn, error)
@@ -91,7 +91,7 @@ func (d *Destination) Open(ctx context.Context) error {
 	d.conn = conn
 
 	// create the client
-	client := pb.NewStreamServiceClient(conn)
+	client := pb.NewSourceServiceClient(conn)
 	// call the Stream method to create a bidirectional streaming RPC stream
 	d.stream, err = client.Stream(ctx)
 	if err != nil {

destination_test.go

@@ -101,11 +101,11 @@ func startTestServer(t *testing.T, lis net.Listener, expected []sdk.Record) {
 	srv := grpc.NewServer()
 
 	// create and register simple mock server
-	mockServer := pb.NewMockStreamServiceServer(ctrl)
+	mockServer := pb.NewMockSourceServiceServer(ctrl)
 	mockServer.EXPECT().
 		Stream(gomock.Any()).
 		DoAndReturn(
-			func(stream pb.StreamService_StreamServer) error {
+			func(stream pb.SourceService_StreamServer) error {
 				i := 0
 				for {
 					// read from the stream to simulate receiving data from the client
@@ -134,7 +134,7 @@ func startTestServer(t *testing.T, lis net.Listener, expected []sdk.Record) {
 				}
 			},
 		)
-	pb.RegisterStreamServiceServer(srv, mockServer)
+	pb.RegisterSourceServiceServer(srv, mockServer)
 
 	// start gRPC server
 	var wg sync.WaitGroup